AbstractController.cc (9819:e4b12145f4eb) AbstractController.cc (9996:150338b8ba12)
1/*
2 * Copyright (c) 2011 Mark D. Hill and David A. Wood
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;

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

99 c->getQueuesFromPeer(this);
100}
101
102void
103AbstractController::stallBuffer(MessageBuffer* buf, Address addr)
104{
105 if (m_waiting_buffers.count(addr) == 0) {
106 MsgVecType* msgVec = new MsgVecType;
1/*
2 * Copyright (c) 2011 Mark D. Hill and David A. Wood
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;

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

99 c->getQueuesFromPeer(this);
100}
101
102void
103AbstractController::stallBuffer(MessageBuffer* buf, Address addr)
104{
105 if (m_waiting_buffers.count(addr) == 0) {
106 MsgVecType* msgVec = new MsgVecType;
107 msgVec->resize(m_max_in_port_rank, NULL);
107 msgVec->resize(m_in_ports, NULL);
108 m_waiting_buffers[addr] = msgVec;
109 }
108 m_waiting_buffers[addr] = msgVec;
109 }
110 (*(m_waiting_buffers[addr]))[m_cur_in_port_rank] = buf;
110 (*(m_waiting_buffers[addr]))[m_cur_in_port] = buf;
111}
112
113void
114AbstractController::wakeUpBuffers(Address addr)
115{
116 if (m_waiting_buffers.count(addr) > 0) {
117 //
118 // Wake up all possible lower rank (i.e. lower priority) buffers that could
119 // be waiting on this message.
120 //
111}
112
113void
114AbstractController::wakeUpBuffers(Address addr)
115{
116 if (m_waiting_buffers.count(addr) > 0) {
117 //
118 // Wake up all possible lower rank (i.e. lower priority) buffers that could
119 // be waiting on this message.
120 //
121 for (int in_port_rank = m_cur_in_port_rank - 1;
121 for (int in_port_rank = m_cur_in_port - 1;
122 in_port_rank >= 0;
123 in_port_rank--) {
124 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
125 (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
126 }
127 }
128 delete m_waiting_buffers[addr];
129 m_waiting_buffers.erase(addr);
130 }
131}
132
133void
134AbstractController::wakeUpAllBuffers(Address addr)
135{
136 if (m_waiting_buffers.count(addr) > 0) {
137 //
138 // Wake up all possible lower rank (i.e. lower priority) buffers that could
139 // be waiting on this message.
140 //
122 in_port_rank >= 0;
123 in_port_rank--) {
124 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
125 (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
126 }
127 }
128 delete m_waiting_buffers[addr];
129 m_waiting_buffers.erase(addr);
130 }
131}
132
133void
134AbstractController::wakeUpAllBuffers(Address addr)
135{
136 if (m_waiting_buffers.count(addr) > 0) {
137 //
138 // Wake up all possible lower rank (i.e. lower priority) buffers that could
139 // be waiting on this message.
140 //
141 for (int in_port_rank = m_max_in_port_rank - 1;
141 for (int in_port_rank = m_in_ports - 1;
142 in_port_rank >= 0;
143 in_port_rank--) {
144 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
145 (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
146 }
147 }
148 delete m_waiting_buffers[addr];
149 m_waiting_buffers.erase(addr);

--- 51 unchanged lines hidden --- 		142 in_port_rank >= 0;
143 in_port_rank--) {
144 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
145 (*(m_waiting_buffers[addr]))[in_port_rank]->reanalyzeMessages(addr);
146 }
147 }
148 delete m_waiting_buffers[addr];
149 m_waiting_buffers.erase(addr);

--- 51 unchanged lines hidden ---