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

Method flush

Parallel/MessageBuffer.cpp:122–130  ·  view source on GitHub ↗

Flush the message buffer by sending all messages that are queued

Source from the content-addressed store, hash-verified

120
121// Flush the message buffer by sending all messages that are queued
122void MessageBuffer::flush()
123{
124 // Send all messages in all queues
125 for(size_t id = 0; id < m_msgQueues.size(); ++id)
126 {
127 // force the queue to send any pending messages
128 checkQueueForSend(id, SM_IMMEDIATE);
129 }
130}
131
132// Check if all the queues are empty
133bool MessageBuffer::transmitBufferEmpty() const

Callers 13

mainFunction · 0.80
indexFastaFunction · 0.80
mainFunction · 0.80
mainFunction · 0.80
writeBloomFunction · 0.80
combineFunction · 0.80
pumpFlushReduceMethod · 0.80
EndStateMethod · 0.80
parseControlMessageMethod · 0.80
assembleFunction · 0.80
mainFunction · 0.80

Calls 1

sizeMethod · 0.45

Tested by

no test coverage detected