AthenaMPToolBase Node1 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() Node9 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() Node1->Node9 Node10 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() Node1->Node10 Node11 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() Node1->Node11 Node12 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() Node1->Node12 Node2 AthAlgTool + AthAlgTool() + ~AthAlgTool() - AthAlgTool() - AthAlgTool() - operator=() Node2->Node1 Node3 AthCommonDataStore < AthCommonMsg< AlgTool > > - m_evtStore - m_detStore - m_vhka - m_varHandleArraysDeclared + AthCommonDataStore() + evtStore() + evtStore() + detStore() + sysInitialize() + sysStart() + inputHandles() + outputHandles() + declareProperty() + declareProperty() + declareProperty() + declareProperty() + declareProperty() + declareProperty() + updateVHKA() # renounceArray() # renounce() # extraDeps_update_handler() - declareGaudiProperty() - declareGaudiProperty() - declareGaudiProperty() - declareGaudiProperty() Node3->Node2 Node6 IAthenaMPTool + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + ATLAS_NOT_THREAD_SAFE() + reportSubprocessStatuses() + subProcessLogs() + generateOutputReport() + useFdsRegistry() + setRandString() + killChildren() + interfaceID() Node6->Node1 Node8 AthenaInterprocess ::IMessageDecoder + ~IMessageDecoder() + operator() Node8->Node1