1# Copyright (c) 1999-2008 Mark D. Hill and David A. Wood
2# Copyright (c) 2009 The Hewlett-Packard Development Company
3# All rights reserved.
4#
5# Redistribution and use in source and binary forms, with or without
6# modification, are permitted provided that the following conditions are
7# met: redistributions of source code must retain the above copyright
8# notice, this list of conditions and the following disclaimer;

--- 707 unchanged lines hidden (view full) ---

716 m_waiting_buffers[addr] = msgVec;
717 }
718 (*(m_waiting_buffers[addr]))[m_cur_in_port_rank] = buf;
719}
720
721void
722$c_ident::wakeUpBuffers(Address addr)
723{
724 //
725 // Wake up all possible lower rank (i.e. lower priority) buffers that could
726 // be waiting on this message.
727 //
728 for (int in_port_rank = m_cur_in_port_rank - 1;
729 in_port_rank >= 0;
730 in_port_rank--) {
731 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
732 (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
733 }
734 }
735 delete m_waiting_buffers[addr];
736 m_waiting_buffers.erase(addr);
737}
738
739void
740$c_ident::wakeUpAllBuffers()
741{
742 //
743 // Wake up all possible buffers that could be waiting on any message.
744 //

--- 893 unchanged lines hidden ---