Receive packets and process them until no more work exists for any * slave processor. */
| 52 | * slave processor. |
| 53 | */ |
| 54 | void NetworkSequenceCollection::completeOperation() |
| 55 | { |
| 56 | Timer timer("completeOperation"); |
| 57 | |
| 58 | while (pumpFlushReduce() > 0) |
| 59 | ; |
| 60 | |
| 61 | assert(m_comm.transmitBufferEmpty()); // Nothing to send. |
| 62 | m_comm.barrier(); // Synchronize. |
| 63 | assert(m_comm.receiveEmpty()); // Nothing to receive. |
| 64 | assert(m_comm.reduceInflight() == 0); |
| 65 | } |
| 66 | |
| 67 | /** Run the assembly state machine. */ |
| 68 | void NetworkSequenceCollection::run() |
nothing calls this directly
no test coverage detected