AthenaMPToolBase(const std::string &type, const std::string &name, const IInterface *parent) | AthenaMPToolBase | |
AthenaMPToolBase() | AthenaMPToolBase | private |
AthenaMPToolBase(const AthenaMPToolBase &) | AthenaMPToolBase | private |
ATLAS_NOT_THREAD_SAFE(int maxevt, int nprocs, const std::string &topdir) override | EvtRangeProcessor | virtual |
ATLAS_NOT_THREAD_SAFE() override | EvtRangeProcessor | virtual |
ATLAS_NOT_THREAD_SAFE(pid_t &pid) override | EvtRangeProcessor | virtual |
ATLAS_NOT_THREAD_SAFE() | EvtRangeProcessor | private |
AthenaMPToolBase::ATLAS_NOT_THREAD_SAFE(Func_Flag flag, pid_t pid=0) | AthenaMPToolBase | protected |
bootstrap_func() override | EvtRangeProcessor | virtual |
AthenaMPToolBase::bootstrap_func()=0 | AthenaMPToolBase | pure virtual |
ESRANGE_BADINPFILE enum value | AthenaMPToolBase | protected |
ESRANGE_FILENOTMADE enum value | AthenaMPToolBase | protected |
ESRANGE_NOTFOUND enum value | AthenaMPToolBase | protected |
ESRANGE_PROCFAILED enum value | AthenaMPToolBase | protected |
ESRANGE_SEEKFAILED enum value | AthenaMPToolBase | protected |
ESRange_Status enum name | AthenaMPToolBase | protected |
ESRANGE_SUCCESS enum value | AthenaMPToolBase | protected |
EvtRangeProcessor(const std::string &type, const std::string &name, const IInterface *parent) | EvtRangeProcessor | |
evtSelector() | AthenaMPToolBase | inlineprotected |
exec_func() override | EvtRangeProcessor | virtual |
fin_func() override | EvtRangeProcessor | virtual |
finalize() override | AthenaMPToolBase | virtual |
fmterror(int errnum) | AthenaMPToolBase | protected |
FUNC_BOOTSTRAP enum value | AthenaMPToolBase | protected |
FUNC_EXEC enum value | AthenaMPToolBase | protected |
FUNC_FIN enum value | AthenaMPToolBase | protected |
Func_Flag enum name | AthenaMPToolBase | protected |
generateOutputReport() override | EvtRangeProcessor | virtual |
handleSavedPfc(const std::filesystem::path &dest_path) | AthenaMPToolBase | protected |
initialize() override | EvtRangeProcessor | virtual |
killChildren() override | AthenaMPToolBase | virtual |
m_activeWorkers | EvtRangeProcessor | private |
m_appMgr | AthenaMPToolBase | protected |
m_channel2EvtSel | EvtRangeProcessor | private |
m_channel2Scatterer | EvtRangeProcessor | private |
m_chronoStatSvc | EvtRangeProcessor | private |
m_debug | EvtRangeProcessor | private |
m_evtProcessor | AthenaMPToolBase | protected |
m_evtSeek | EvtRangeProcessor | private |
m_evtSelector | AthenaMPToolBase | protected |
m_evtSelName | AthenaMPToolBase | protected |
m_fdsRegistry | AthenaMPToolBase | protected |
m_fileMgr | AthenaMPToolBase | protected |
m_fileMgrLog | AthenaMPToolBase | protected |
m_finQueue | EvtRangeProcessor | private |
m_incidentSvc | EvtRangeProcessor | private |
m_inpFile | EvtRangeProcessor | private |
m_ioMgr | AthenaMPToolBase | protected |
m_isPileup | AthenaMPToolBase | protected |
m_maxEvt | AthenaMPToolBase | protected |
m_mpRunStop | AthenaMPToolBase | protected |
m_nEventsBeforeFork | EvtRangeProcessor | private |
m_nProcessedEvents | EvtRangeProcessor | private |
m_nprocs | AthenaMPToolBase | protected |
m_processGroup | AthenaMPToolBase | protected |
m_procStates | EvtRangeProcessor | private |
m_randStr | AthenaMPToolBase | protected |
m_rankId | EvtRangeProcessor | private |
m_sharedFailedPidQueue | EvtRangeProcessor | private |
m_sharedRankQueue | EvtRangeProcessor | private |
m_subprocDirPrefix | AthenaMPToolBase | protected |
m_subprocTopDir | AthenaMPToolBase | protected |
operator() ATLAS_NOT_THREAD_SAFE(const ScheduledWork &)=0 | AthenaInterprocess::IMessageDecoder | pure virtual |
operator=(const AthenaMPToolBase &) | AthenaMPToolBase | private |
PROC_STATE_EXEC enum value | EvtRangeProcessor | private |
PROC_STATE_FIN enum value | EvtRangeProcessor | private |
PROC_STATE_INIT enum value | EvtRangeProcessor | private |
PROC_STATE_STOP enum value | EvtRangeProcessor | private |
ProcessState enum name | EvtRangeProcessor | private |
redirectLog(const std::string &rundir, bool addTimeStamp=true) | AthenaMPToolBase | protected |
reopenFd(int fd, const std::string &name) | AthenaMPToolBase | private |
reopenFds() | AthenaMPToolBase | protected |
reportError(yampl::ISocket *socket, AthenaMPToolBase::ESRange_Status status) | EvtRangeProcessor | private |
reportSubprocessStatuses() override | EvtRangeProcessor | virtual |
setMaxEvt(int maxEvt) override | AthenaMPToolBase | inlinevirtual |
setMPRunStop(const AthenaInterprocess::IMPRunStop *runStop) override | AthenaMPToolBase | inlinevirtual |
setNewInputFile(const std::string &newFile) | EvtRangeProcessor | private |
setRandString(const std::string &randStr) override | AthenaMPToolBase | virtual |
subProcessLogs(std::vector< std::string > &) override | EvtRangeProcessor | virtual |
updateIoReg(const std::string &rundir) | AthenaMPToolBase | protected |
useFdsRegistry(std::shared_ptr< AthenaInterprocess::FdsRegistry >) override | AthenaMPToolBase | virtual |
waitForSignal() | AthenaMPToolBase | protected |
~AthenaMPToolBase() override | AthenaMPToolBase | virtual |
~EvtRangeProcessor() override | EvtRangeProcessor | virtual |
~IMessageDecoder() | AthenaInterprocess::IMessageDecoder | inlinevirtual |