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

Method pumpFlushReduce

Parallel/NetworkSequenceCollection.cpp:44–49  ·  view source on GitHub ↗

Receive, process, send, and synchronize. * @return the number of inflight messages */

Source from the content-addressed store, hash-verified

42 * @return the number of inflight messages
43 */
44size_t NetworkSequenceCollection::pumpFlushReduce()
45{
46 pumpNetwork();
47 m_comm.flush();
48 return m_comm.reduceInflight();
49}
50
51/** Receive packets and process them until no more work exists for any
52 * slave processor.

Callers

nothing calls this directly

Calls 2

flushMethod · 0.80
reduceInflightMethod · 0.80

Tested by

no test coverage detected