Method pumpNetwork

Parallel/NetworkSequenceCollection.cpp:697–728

Receive and dispatch packets. * @return the number of packets received */

 * @return the number of packets received
 */
size_t NetworkSequenceCollection::pumpNetwork()
{
	for (size_t count = 0; ; count++) {
		int senderID;
		APMessage msg = m_comm.checkMessage(senderID);
		switch(msg)
		{
			case APM_CONTROL:
				parseControlMessage(senderID);
				// Deal with the control packet before we continue
				// processing further packets.
				return ++count;
			case APM_BUFFERED:
				{
					MessagePtrVector msgs;
					m_comm.receiveBufferedMessage(msgs);
					for (MessagePtrVector::iterator
							iter = msgs.begin();
							iter != msgs.end(); iter++) {
						// Handle each message based on its type
						(*iter)->handle(senderID, *this);
						// Delete the message
						delete (*iter);
						*iter = 0;
					}
					break;
				}
			case APM_NONE:
				return count;
		}
	}
}

/** Call the observers of the specified sequence. */
void NetworkSequenceCollection::notify(const V& key)