ByteStreamInputSvc Node1 ByteStreamInputSvc + ByteStreamInputSvc() + ~ByteStreamInputSvc() + nextEvent() + previousEvent() + setEvent() + currentEvent() + currentEventStatus() + getBlockIterator() + closeBlockIterator() + ready() + generateDataHeader() + positionInBlock() + validateEvent() + interfaceID() Node5 ByteStreamEmonInputSvc - m_totalEventCounter - m_re - m_partition - m_key - m_value - m_key_count - m_publish - m_exit - m_is_server - m_include and 32 more... + ByteStreamEmonInputSvc() + initialize() + start() + finalize() + previousEvent() + nextEvent() + currentEvent() - getIterator() - check_publish() - get_runparams() - updateHandler() Node1->Node5 Node6 ByteStreamEventStorageInputSvc - m_readerMutex - m_eventsCache - m_reader - m_evtOffsets - m_evtInFile - m_evtFileOffset - m_fileGUID - m_storeGate - m_inputMetadata - m_robProvider - m_sequential - m_dump - m_wait - m_valEvent - m_eventInfoKey + ByteStreamEventStorageInputSvc() + ~ByteStreamEventStorageInputSvc() + initialize() + stop() + finalize() + queryInterface() + currentEvent() + nextEvent() + previousEvent() + setEvent() and 8 more... - loadMetadata() - buildFragment() - readerReady() - ROBFragmentCheck() - validateEvent() - setEvent() - getEvent() - makeBSProvenance() - deleteEntry() Node1->Node6 Node7 TrigByteStreamInputSvc - m_robDataProviderSvc - m_evtStore - m_monTool - m_checkCTPFragmentModuleID - m_eventsCache - m_maxLB + TrigByteStreamInputSvc() + ~TrigByteStreamInputSvc() + queryInterface() + initialize() + finalize() + nextEvent() + previousEvent() + currentEvent() Node1->Node7 Node2 AthService - AthService() - AthService() - operator=() Node2->Node1 Node3 AthCommonMsg< Service > + msg() + msg() + msgLvl() Node3->Node2 Node4 Service Node4->Node3