Lines Matching refs:m_waiting_buffers
113 if (m_waiting_buffers.count(addr) == 0) {
116 m_waiting_buffers[addr] = msgVec;
121 (*(m_waiting_buffers[addr]))[m_cur_in_port] = buf;
127 if (m_waiting_buffers.count(addr) > 0) {
135 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
136 (*(m_waiting_buffers[addr]))[in_port_rank]->
140 delete m_waiting_buffers[addr];
141 m_waiting_buffers.erase(addr);
148 if (m_waiting_buffers.count(addr) > 0) {
156 if ((*(m_waiting_buffers[addr]))[in_port_rank] != NULL) {
157 (*(m_waiting_buffers[addr]))[in_port_rank]->
161 delete m_waiting_buffers[addr];
162 m_waiting_buffers.erase(addr);
176 if (m_waiting_buffers.size() > 0) {
177 for (WaitingBufType::iterator buf_iter = m_waiting_buffers.begin();
178 buf_iter != m_waiting_buffers.end();
201 m_waiting_buffers.clear();