AthenaInterprocess::IMessageDecoder Node1 AthenaInterprocess ::IMessageDecoder + ~IMessageDecoder() + operator() Node2 AthenaMPToolBase # m_nprocs # m_subprocTopDir # m_subprocDirPrefix # m_evtSelName # m_processGroup # m_evtProcessor # m_appMgr # m_fileMgr # m_ioMgr # m_evtSelector # m_fileMgrLog # m_fdsRegistry # m_randStr # m_isPileup + AthenaMPToolBase() + ~AthenaMPToolBase() + initialize() + finalize() + ATLAS_NOT_THREAD_SAFE() + reportSubprocessStatuses() + generateOutputReport() + useFdsRegistry() + setRandString() + killChildren() + bootstrap_func() + exec_func() + fin_func() # ATLAS_NOT_THREAD_SAFE() # redirectLog() # updateIoReg() # fmterror() # reopenFds() # handleSavedPfc() # waitForSignal() # evtSelector() - AthenaMPToolBase() - AthenaMPToolBase() - operator=() - reopenFd() Node1->Node2 Node3 EvtRangeProcessor - m_rankId - m_nEventsBeforeFork - m_activeWorkers - m_inpFile - m_chronoStatSvc - m_incidentSvc - m_evtSeek - m_channel2Scatterer - m_channel2EvtSel - m_sharedRankQueue - m_sharedFailedPidQueue - m_nProcessedEvents - m_finQueue - m_procStates - m_debug + EvtRangeProcessor() + ~EvtRangeProcessor() + initialize() + finalize() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + reportSubprocessStatuses() + subProcessLogs() + generateOutputReport() + bootstrap_func() + exec_func() + fin_func() - EvtRangeProcessor() - EvtRangeProcessor() - operator=() - ATLAS_NOT_THREAD_SAFE() - setNewInputFile() - reportError() Node2->Node3 Node4 EvtRangeScatterer - m_processorChannel - m_eventRangeChannel - m_doCaching - m_pid2RangeID + EvtRangeScatterer() + ~EvtRangeScatterer() + initialize() + finalize() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + subProcessLogs() + generateOutputReport() + bootstrap_func() + exec_func() + fin_func() - EvtRangeScatterer() - EvtRangeScatterer() - operator=() - trimRangeStrings() - getNewRangeRequest() - pollFailedPidQueue() Node2->Node4 Node5 SharedEvtQueueConsumer - m_useSharedReader - m_useSharedWriter - m_isRoundRobin - m_nEventsBeforeFork - m_nSkipEvents - m_debug - m_rankId - m_chronoStatSvc - m_evtSeek - m_evtSelSeek and 11 more... + SharedEvtQueueConsumer() + ~SharedEvtQueueConsumer() + initialize() + finalize() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + reportSubprocessStatuses() + subProcessLogs() + bootstrap_func() + exec_func() + fin_func() - SharedEvtQueueConsumer() - SharedEvtQueueConsumer() - operator=() - ATLAS_NOT_THREAD_SAFE() Node2->Node5 Node6 SharedEvtQueueProvider - m_nprocesses - m_useSharedReader - m_nEventsBeforeFork - m_nChunkSize - m_nChunkStart - m_nPositionInChunk - m_nEvtRequested - m_nEvtCounted - m_sharedEventQueue - m_evtShare + SharedEvtQueueProvider() + ~SharedEvtQueueProvider() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + subProcessLogs() + generateOutputReport() + handle() + bootstrap_func() + exec_func() + fin_func() - SharedEvtQueueProvider() - SharedEvtQueueProvider() - operator=() - addEventsToQueue() Node2->Node6 Node7 SharedHiveEvtQueueConsumer - m_nEventsBeforeFork - m_debug - m_useSharedWriter - m_rankId - m_chronoStatSvc - m_dataShare - m_evtSelSeek - m_evtContext - m_sharedEventQueue - m_sharedRankQueue - m_nProcessedEvents - m_finQueue - m_schedulerSvc + SharedHiveEvtQueueConsumer() + ~SharedHiveEvtQueueConsumer() + initialize() + finalize() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + reportSubprocessStatuses() + subProcessLogs() + bootstrap_func() + exec_func() + fin_func() - SharedHiveEvtQueueConsumer() - SharedHiveEvtQueueConsumer() - operator=() - initHive() - ATLAS_NOT_THREAD_SAFE() Node2->Node7 Node8 SharedWriterTool - m_nMotherProcess - m_debug - m_rankId - m_sharedRankQueue - m_cnvSvc + SharedWriterTool() + ~SharedWriterTool() + initialize() + finalize() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + subProcessLogs() + generateOutputReport() + bootstrap_func() + exec_func() + fin_func() - SharedWriterTool() - SharedWriterTool() - operator=() Node2->Node8