MCPcopy Create free account
hub / github.com/BirolLab/abyss / completeOperation

Method completeOperation

Parallel/NetworkSequenceCollection.cpp:54–65  ·  view source on GitHub ↗

Receive packets and process them until no more work exists for any * slave processor. */

Source from the content-addressed store, hash-verified

52 * slave processor.
53 */
54void 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. */
68void NetworkSequenceCollection::run()

Callers

nothing calls this directly

Calls 4

transmitBufferEmptyMethod · 0.80
barrierMethod · 0.80
receiveEmptyMethod · 0.80
reduceInflightMethod · 0.80

Tested by

no test coverage detected