1 #ifndef FWCore_Framework_MessageReceiverForSource_h
2 #define FWCore_Framework_MessageReceiverForSource_h
unsigned long numberOfConsecutiveIndices() const
unsigned long m_numberOfConsecutiveIndices
MessageReceiverForSource(int iQueueID)
Takes the ID of the posix message queue used for the messages.
unsigned long m_numberToSkip
unsigned long numberToSkip() const
unsigned long m_startIndex
unsigned long startIndex() const
After calling receive this holds the index to the first event to process.
const MessageReceiverForSource & operator=(const MessageReceiverForSource &)