88a89,172
>
> void
> AbstractController::stallBuffer(MessageBuffer* buf, Address addr)
> {
> if (m_waiting_buffers.count(addr) == 0) {
> MsgVecType* msgVec = new MsgVecType;
> msgVec->resize(m_max_in_port_rank, NULL);
> m_waiting_buffers[addr] = msgVec;
> }
> (*(m_waiting_buffers[addr]))[m_cur_in_port_rank] = buf;
> }
>
> void
> AbstractController::wakeUpBuffers(Address addr)
> {
> if (m_waiting_buffers.count(addr) > 0) {
> //
> // Wake up all possible lower rank (i.e. lower priority) buffers that could
> // be waiting on this message.
> //
> for (int in_port_rank = m_cur_in_port_rank - 1;
> in_port_rank >= 0;
> in_port_rank--) {
> if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
> (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
> }
> }
> delete m_waiting_buffers[addr];
> m_waiting_buffers.erase(addr);
> }
> }
>
> void
> AbstractController::wakeUpAllBuffers(Address addr)
> {
> if (m_waiting_buffers.count(addr) > 0) {
> //
> // Wake up all possible lower rank (i.e. lower priority) buffers that could
> // be waiting on this message.
> //
> for (int in_port_rank = m_max_in_port_rank - 1;
> in_port_rank >= 0;
> in_port_rank--) {
> if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
> (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
> }
> }
> delete m_waiting_buffers[addr];
> m_waiting_buffers.erase(addr);
> }
> }
>
> void
> AbstractController::wakeUpAllBuffers()
> {
> //
> // Wake up all possible buffers that could be waiting on any message.
> //
>
> std::vector<MsgVecType*> wokeUpMsgVecs;
>
> if(m_waiting_buffers.size() > 0) {
> for (WaitingBufType::iterator buf_iter = m_waiting_buffers.begin();
> buf_iter != m_waiting_buffers.end();
> ++buf_iter) {
> for (MsgVecType::iterator vec_iter = buf_iter->second->begin();
> vec_iter != buf_iter->second->end();
> ++vec_iter) {
> if (*vec_iter != NULL) {
> (*vec_iter)->reanalyzeAllMessages();
> }
> }
> wokeUpMsgVecs.push_back(buf_iter->second);
> }
>
> for (std::vector<MsgVecType*>::iterator wb_iter = wokeUpMsgVecs.begin();
> wb_iter != wokeUpMsgVecs.end();
> ++wb_iter) {
> delete (*wb_iter);
> }
>
> m_waiting_buffers.clear();
> }
> }