![]() |
![]() |
#include <FUEventProcessor.h>
Public Member Functions | |
void | actionPerformed (xdata::Event &e) |
bool | configuring (toolbox::task::WorkLoop *wl) |
void | css (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception) |
void | defaultWebPage (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception) |
bool | enabling (toolbox::task::WorkLoop *wl) |
xoap::MessageReference | fsmCallback (xoap::MessageReference msg) throw (xoap::exception::Exception) |
FUEventProcessor (xdaq::ApplicationStub *s) | |
bool | halting (toolbox::task::WorkLoop *wl) |
void | microState (xgi::Input *in, xgi::Output *out) |
void | moduleWeb (xgi::Input *in, xgi::Output *out) |
void | pathNames (xgi::Input *, xgi::Output *) throw (xgi::exception::Exception) |
void | procStat (xgi::Input *in, xgi::Output *out) |
void | scalersWeb (xgi::Input *, xgi::Output *) throw (xgi::exception::Exception) |
void | sendMessageOverMonitorQueue (MsgBuf &) |
void | serviceWeb (xgi::Input *in, xgi::Output *out) |
void | spotlightWebPage (xgi::Input *, xgi::Output *) throw (xgi::exception::Exception) |
bool | stopping (toolbox::task::WorkLoop *wl) |
void | subWeb (xgi::Input *in, xgi::Output *out) |
void | updater (xgi::Input *in, xgi::Output *out) |
XDAQ_INSTANTIATOR () | |
virtual | ~FUEventProcessor () |
Private Member Functions | |
void | attachDqmToShm () throw (evf::Exception) |
void | detachDqmFromShm () throw (evf::Exception) |
bool | enableClassic () |
bool | enableCommon () |
bool | enableMPEPSlave () |
void | localLog (std::string) |
std::string | logsAsString () |
void | makeStaticInfo () |
bool | receiving (toolbox::task::WorkLoop *wl) |
bool | receivingAndMonitor (toolbox::task::WorkLoop *wl) |
bool | scalers (toolbox::task::WorkLoop *wl) |
void | startReceivingLoop () |
void | startReceivingMonitorLoop () |
void | startScalersWorkLoop () throw (evf::Exception) |
void | startSummarizeWorkLoop () throw (evf::Exception) |
void | startSupervisorLoop () |
bool | stopClassic () |
void | stopSlavesAndAcknowledge () |
bool | summarize (toolbox::task::WorkLoop *wl) |
bool | supervisor (toolbox::task::WorkLoop *wl) |
Private Attributes | |
int | anonymousPipe_ [2] |
xdata::InfoSpace * | applicationInfoSpace_ |
toolbox::task::ActionSignature * | asReceiveMsgAndExecute_ |
toolbox::task::ActionSignature * | asReceiveMsgAndRead_ |
toolbox::task::ActionSignature * | asScalers_ |
toolbox::task::ActionSignature * | asSummarize_ |
toolbox::task::ActionSignature * | asSupervisor_ |
xdata::Boolean | autoRestartSlaves_ |
xdata::String | class_ |
xdata::String | configString_ |
std::string | configuration_ |
CPUStat * | cpustat_ |
Css | css_ |
xdata::Boolean | epInitialized_ |
FWEPWrapper | evtProcessor_ |
xdata::Boolean | exitOnError_ |
evf::StateMachine | fsm_ |
xdata::Boolean | hasModuleWebRegistry_ |
xdata::Boolean | hasPrescaleService_ |
xdata::Boolean | hasServiceWebRegistry_ |
xdata::Boolean | hasShMem_ |
xdata::Boolean | iDieStatisticsGathering_ |
xdata::String | iDieUrl_ |
xdata::UnsignedInteger32 | instance_ |
xdata::Boolean | isRunNumberSetter_ |
Logger | log_ |
std::vector< std::string > | logRing_ |
unsigned int | logRingIndex_ |
bool | logWrap_ |
MsgBuf | master_message_prg_ |
MsgBuf | master_message_prr_ |
MsgBuf | master_message_trr_ |
xdata::InfoSpace * | monitorInfoSpace_ |
xdata::InfoSpace * | monitorLegendaInfoSpace_ |
SubProcess * | myProcess_ |
std::list< std::string > | names_ |
xdata::Serializable * | nbAccepted |
unsigned int | nbdead_ |
unsigned int | nblive_ |
xdata::Serializable * | nbProcessed |
xdata::UnsignedInteger32 | nbSubProcesses_ |
xdata::UnsignedInteger32 | nbSubProcessesReporting_ |
unsigned int | nbTotalDQM_ |
bool | outprev_ |
xdata::Boolean | outPut_ |
pthread_mutex_t | pickup_lock_ |
RateStat * | ratestat_ |
std::string | reasonForFailedState_ |
bool | receiving_ |
bool | receivingM_ |
xdata::UnsignedInteger32 | runNumber_ |
xdata::InfoSpace * | scalersInfoSpace_ |
xdata::InfoSpace * | scalersLegendaInfoSpace_ |
unsigned int | scalersUpdates_ |
MsgBuf | slave_message_monitoring_ |
MsgBuf | slave_message_prr_ |
xdata::UnsignedInteger32 | slaveRestartDelaySecs_ |
std::string | sourceId_ |
xdata::Vector< xdata::Integer > | spMStates_ |
xdata::Vector< xdata::Integer > | spmStates_ |
SquidNet | squidnet_ |
xdata::Boolean | squidPresent_ |
pthread_mutex_t | start_lock_ |
pthread_mutex_t | stop_lock_ |
std::vector< SubProcess > | subs_ |
xdata::UnsignedInteger32 | superSleepSec_ |
bool | supervising_ |
std::string | updaterStatic_ |
xdata::String | url_ |
pid_t | vp_ |
Vulture * | vulture_ |
toolbox::task::WorkLoop * | wlReceiving_ |
toolbox::task::WorkLoop * | wlReceivingMonitor_ |
toolbox::task::WorkLoop * | wlScalers_ |
bool | wlScalersActive_ |
toolbox::task::WorkLoop * | wlSummarize_ |
bool | wlSummarizeActive_ |
toolbox::task::WorkLoop * | wlSupervising_ |
Static Private Attributes | |
static const unsigned int | logRingSize_ = 50 |
Definition at line 58 of file FUEventProcessor.h.
FUEventProcessor::FUEventProcessor | ( | xdaq::ApplicationStub * | s | ) |
Definition at line 61 of file FUEventProcessor.cc.
References anonymousPipe_, applicationInfoSpace_, autoRestartSlaves_, evf::SquidNet::check(), class_, configString_, css(), defaultWebPage(), epInitialized_, evtProcessor_, evf::StateMachine::findRcmsStateListener(), evf::StateMachine::foundRcmsStateListener(), fsm_, edm::PresenceFactory::get(), hasModuleWebRegistry_, hasPrescaleService_, hasServiceWebRegistry_, hasShMem_, iDieStatisticsGathering_, iDieUrl_, evf::StateMachine::initialize(), instance_, isRunNumberSetter_, edm::PresenceFactory::makePresence(), makeStaticInfo(), microState(), moduleWeb(), monitorInfoSpace_, monitorLegendaInfoSpace_, names_, nbSubProcesses_, nbSubProcessesReporting_, outPut_, pathNames(), pickup_lock_, pipe::pipe(), procStat(), evf::FWEPWrapper::publishConfigAndMonitorItems(), evf::StateMachine::rcmsStateListener(), runNumber_, scalersInfoSpace_, scalersLegendaInfoSpace_, scalersWeb(), serviceWeb(), evf::FWEPWrapper::setAppCtxt(), evf::FWEPWrapper::setAppDesc(), ML::MLlog4cplus::setAppl(), evf::FWEPWrapper::setApplicationInfoSpace(), evf::FWEPWrapper::setMonitorInfoSpace(), evf::FWEPWrapper::setRcms(), evf::FWEPWrapper::setScalersInfoSpace(), slaveRestartDelaySecs_, sourceId_, spMStates_, spmStates_, spotlightWebPage(), squidnet_, squidPresent_, start_lock_, startSupervisorLoop(), evf::StateMachine::stateName(), stop_lock_, subWeb(), superSleepSec_, updater(), url_, and vulture_.
|
virtual |
void FUEventProcessor::actionPerformed | ( | xdata::Event & | e | ) |
Definition at line 540 of file FUEventProcessor.cc.
References edm::EventProcessor::enableEndPaths(), epInitialized_, evtProcessor_, fsm_, outprev_, outPut_, and evf::StateMachine::stateName().
|
private |
Definition at line 769 of file FUEventProcessor.cc.
References evtProcessor_, edm::EventProcessor::getToken(), edm::Service< T >::isAvailable(), summarizeEdmComparisonLogfiles::success, and cms::Exception::what().
Referenced by enableCommon().
bool FUEventProcessor::configuring | ( | toolbox::task::WorkLoop * | wl | ) |
Definition at line 315 of file FUEventProcessor.cc.
References edm::EventProcessor::beginJob(), configString_, evf::FWEPWrapper::configuration(), configuration_, cpustat_, epInitialized_, evtProcessor_, cmsCodeRules.cppFunctionSkipper::exception, edm::hlt::Exception, cms::Exception::explainSelf(), evf::StateMachine::fireEvent(), evf::StateMachine::fireFailed(), fsm_, evf::FWEPWrapper::getmicromap(), evf::FWEPWrapper::getNumberOfMicrostates(), hasModuleWebRegistry_, hasPrescaleService_, hasServiceWebRegistry_, i, iDieStatisticsGathering_, iDieUrl_, evf::FWEPWrapper::init(), instance_, localLog(), evf::Vulture::makeProcess(), nbSubProcesses_, ratestat_, reasonForFailedState_, scalersLegendaInfoSpace_, evf::RateStat::sendLegenda(), evf::CPUStat::sendLegenda(), edm::event_processor::sInit, spMStates_, spmStates_, evf::FWEPWrapper::startMonitoringWorkLoop(), vp_, and vulture_.
|
inline |
Definition at line 101 of file FUEventProcessor.h.
References evf::Css::css(), and css_.
Referenced by FUEventProcessor().
void FUEventProcessor::defaultWebPage | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) | |||
throw | ( | xgi::exception::Exception | |
) |
Definition at line 642 of file FUEventProcessor.cc.
References nbSubProcesses_, and dbtoconf::out.
Referenced by FUEventProcessor(), and receivingAndMonitor().
|
private |
Definition at line 787 of file FUEventProcessor.cc.
References evtProcessor_, edm::EventProcessor::getToken(), edm::Service< T >::isAvailable(), summarizeEdmComparisonLogfiles::success, and cms::Exception::what().
Referenced by stopClassic().
|
private |
Definition at line 1564 of file FUEventProcessor.cc.
References enableCommon(), evtProcessor_, edm::EventProcessor::getState(), localLog(), stor::utils::sleep(), and edm::event_processor::sRunning.
Referenced by enabling().
|
private |
Definition at line 1505 of file FUEventProcessor.cc.
References attachDqmToShm(), edm::EventProcessor::clearCounters(), gather_cfg::cout, edm::EventProcessor::declareRunNumber(), evtProcessor_, cmsCodeRules.cppFunctionSkipper::exception, edm::hlt::Exception, cms::Exception::explainSelf(), evf::StateMachine::fireEvent(), evf::StateMachine::fireFailed(), fsm_, hasShMem_, isRunNumberSetter_, localLog(), reasonForFailedState_, edm::EventProcessor::runAsync(), runNumber_, edm::EventProcessor::setRunNumber(), stor::utils::sleep(), and edm::EventProcessor::statusAsync().
Referenced by enableClassic(), and enableMPEPSlave().
|
private |
Definition at line 1577 of file FUEventProcessor.cc.
References enableCommon(), evtProcessor_, edm::hlt::Exception, evf::StateMachine::fireFailed(), fsm_, edm::PresenceFactory::get(), evf::FWEPWrapper::isWaitingForLs(), localLog(), edm::PresenceFactory::makePresence(), reasonForFailedState_, evf::FWEPWrapper::resetWaiting(), ML::MLlog4cplus::setAppl(), stor::utils::sleep(), startReceivingLoop(), startReceivingMonitorLoop(), and startScalersWorkLoop().
Referenced by enabling(), and supervisor().
bool FUEventProcessor::enabling | ( | toolbox::task::WorkLoop * | wl | ) |
Definition at line 408 of file FUEventProcessor.cc.
References toolbox::mem::_s_mutex_ptr_, edm::EventProcessor::beginJob(), configString_, evf::FWEPWrapper::configuration(), configuration_, cpustat_, evf::StateMachine::disableRcmsStateNotification(), enableClassic(), enableMPEPSlave(), epInitialized_, evtProcessor_, evf::StateMachine::fireEvent(), evf::FWEPWrapper::forceInitEventProcessorMaybe(), fsm_, evf::FWEPWrapper::getmicromap(), evf::FWEPWrapper::getNumberOfMicrostates(), hasModuleWebRegistry_, hasPrescaleService_, hasServiceWebRegistry_, i, iDieStatisticsGathering_, iDieUrl_, evf::FWEPWrapper::init(), instance_, localLog(), myProcess_, nbSubProcesses_, nbTotalDQM_, ratestat_, evf::FWEPWrapper::resetLumiSectionReferenceIndex(), runNumber_, scalersInfoSpace_, scalersUpdates_, evf::RateStat::sendLegenda(), evf::CPUStat::sendLegenda(), evf::Vulture::start(), start_lock_, startSummarizeWorkLoop(), stop_lock_, subs_, vp_, and vulture_.
xoap::MessageReference FUEventProcessor::fsmCallback | ( | xoap::MessageReference | msg | ) | |
throw | ( | xoap::exception::Exception | |||
) |
Definition at line 532 of file FUEventProcessor.cc.
References evf::StateMachine::commandCallback(), fsm_, and runTheMatrix::msg.
bool FUEventProcessor::halting | ( | toolbox::task::WorkLoop * | wl | ) |
Definition at line 508 of file FUEventProcessor.cc.
References evtProcessor_, evf::StateMachine::fireEvent(), evf::StateMachine::fireFailed(), fsm_, localLog(), nbSubProcesses_, reasonForFailedState_, evf::FWEPWrapper::stopAndHalt(), and stopSlavesAndAcknowledge().
|
private |
Definition at line 821 of file FUEventProcessor.cc.
References logRing_, logRingIndex_, logRingSize_, logWrap_, m, and cond::timestamp.
Referenced by configuring(), enableClassic(), enableCommon(), enableMPEPSlave(), enabling(), halting(), stopClassic(), stopSlavesAndAcknowledge(), and supervisor().
|
private |
Definition at line 804 of file FUEventProcessor.cc.
References i, logRing_, logRingIndex_, and logWrap_.
|
private |
Definition at line 1886 of file FUEventProcessor.cc.
References applicationInfoSpace_, evf::utils::cDiv(), edm::hlt::Exception, edm::getReleaseVersion(), hasModuleWebRegistry_, hasServiceWebRegistry_, hasShMem_, evf::utils::mDiv(), outPut_, and updaterStatic_.
Referenced by FUEventProcessor().
void FUEventProcessor::microState | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) |
Definition at line 1694 of file FUEventProcessor.cc.
References autoRestartSlaves_, gather_cfg::cout, evtProcessor_, cmsCodeRules.cppFunctionSkipper::exception, fsm_, evf::FWEPWrapper::getScalersUpdates(), i, evf::FWEPWrapper::microState(), evf::FWEPWrapper::moduleNameFromIndex(), myProcess_, nbdead_, nblive_, nbSubProcesses_, nbTotalDQM_, pickup_lock_, start_lock_, evf::StateMachine::stateName(), evf::FWEPWrapper::stateNameFromIndex(), subs_, and cms::Exception::what().
Referenced by FUEventProcessor().
|
inline |
Definition at line 107 of file FUEventProcessor.h.
References evtProcessor_, and evf::FWEPWrapper::moduleWeb().
Referenced by FUEventProcessor(), and receivingAndMonitor().
void FUEventProcessor::pathNames | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) | |||
throw | ( | xgi::exception::Exception | |
) |
Definition at line 756 of file FUEventProcessor.cc.
References evtProcessor_, dbtoconf::out, and scalersLegendaInfoSpace_.
Referenced by FUEventProcessor().
void FUEventProcessor::procStat | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) |
Definition at line 1876 of file FUEventProcessor.cc.
References evf::utils::procStat().
Referenced by FUEventProcessor(), and receivingAndMonitor().
|
private |
Definition at line 893 of file FUEventProcessor.cc.
References cmsRelvalreport::exit, evf::StateMachine::fireEvent(), fsm_, edm::PresenceFactory::get(), edm::PresenceFactory::makePresence(), runTheMatrix::msg, MSQM_MESSAGE_TYPE_FSTOP, MSQM_MESSAGE_TYPE_STOP, MSQS_MESSAGE_TYPE_STOP, myProcess_, evf::SubProcess::postSlave(), evf::SubProcess::rcvSlave(), stop_lock_, and stopClassic().
Referenced by startReceivingLoop().
|
private |
Definition at line 1361 of file FUEventProcessor.cc.
References anonymousPipe_, applicationInfoSpace_, harvestRelVal::args, prof2calltree::count, gather_cfg::cout, cycle, runTheMatrix::data, defaultWebPage(), evf::prg::dqm, evf::prg::eols, evf::FWEPWrapper::epMAltState_, evf::FWEPWrapper::epmAltState_, evtProcessor_, edm::hlt::Exception, exitOnError_, spr::find(), first, fsm_, evf::internal::MyCgi::getEnvironment(), recoMuon::in, Input, evf::FWEPWrapper::lastLumiUsingEol_, evf::prg::ls, evf::FWEPWrapper::lsid_, MAX_PIPE_BUFFER_SIZE, evf::FWEPWrapper::microState(), moduleWeb(), evf::FWEPWrapper::monitoring(), evf::prg::Ms, evf::prg::ms, MSQM_MESSAGE_TYPE_MCS, MSQM_MESSAGE_TYPE_PRG, MSQM_MESSAGE_TYPE_TRP, MSQM_MESSAGE_TYPE_WEB, MSQS_MESSAGE_TYPE_MCR, MSQS_MESSAGE_TYPE_WEB, myProcess_, evf::prg::nba, evf::prg::nbp, NUMERIC_MESSAGE_SIZE, dbtoconf::out, Output, PIPE_WRITE, pos, evf::SubProcess::postSlave(), procStat(), evf::prg::ps, evf::FWEPWrapper::psid_, o2o::query, evf::SubProcess::rcvSlave(), scalersUpdates_, edm::second(), edm::event_processor::sError, slave_message_monitoring_, slave_message_prr_, stor::utils::sleep(), spotlightWebPage(), edm::event_processor::sStopping, evf::StateMachine::stateName(), stop_lock_, EcalElecEmulTccFlatFileProducerFromTPG_cfg::tokens, edm::EventProcessor::totalEvents(), edm::EventProcessor::totalEventsPassed(), and evf::prg::trp.
Referenced by startReceivingMonitorLoop().
|
private |
Definition at line 1245 of file FUEventProcessor.cc.
References gather_cfg::cout, evtProcessor_, evf::FWEPWrapper::fireScalersUpdate(), evf::FWEPWrapper::getPackedTriggerReport(), evf::FWEPWrapper::getTriggerReport(), myProcess_, evf::SubProcess::postSlave(), runTheMatrix::ret, scalersUpdates_, and wlScalersActive_.
Referenced by startScalersWorkLoop().
void FUEventProcessor::scalersWeb | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) | |||
throw | ( | xgi::exception::Exception | |
) |
Definition at line 743 of file FUEventProcessor.cc.
References evtProcessor_, evf::FWEPWrapper::getPackedTriggerReportAsStruct(), and dbtoconf::out.
Referenced by FUEventProcessor().
void FUEventProcessor::sendMessageOverMonitorQueue | ( | MsgBuf & | buf | ) |
Definition at line 1881 of file FUEventProcessor.cc.
References myProcess_, and evf::SubProcess::postSlave().
|
inline |
Definition at line 108 of file FUEventProcessor.h.
References evtProcessor_, and evf::FWEPWrapper::serviceWeb().
Referenced by FUEventProcessor().
void FUEventProcessor::spotlightWebPage | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) | |||
throw | ( | xgi::exception::Exception | |
) |
Definition at line 658 of file FUEventProcessor.cc.
References configuration_, evtProcessor_, fsm_, recoMuon::in, myProcess_, nbSubProcesses_, dbtoconf::out, evf::StateMachine::stateName(), evf::FWEPWrapper::summaryWebPage(), and evf::FWEPWrapper::taskWebPage().
Referenced by FUEventProcessor(), and receivingAndMonitor().
|
private |
Definition at line 856 of file FUEventProcessor.cc.
References asReceiveMsgAndExecute_, edm::hlt::Exception, runTheMatrix::msg, receiving(), receiving_, and wlReceiving_.
Referenced by enableMPEPSlave().
|
private |
Definition at line 873 of file FUEventProcessor.cc.
References asReceiveMsgAndRead_, edm::hlt::Exception, runTheMatrix::msg, receivingAndMonitor(), receivingM_, and wlReceivingMonitor_.
Referenced by enableMPEPSlave().
|
private |
Definition at line 1202 of file FUEventProcessor.cc.
References asScalers_, edm::hlt::Exception, runTheMatrix::msg, scalers(), wlScalers_, and wlScalersActive_.
Referenced by enableMPEPSlave().
|
private |
Definition at line 1223 of file FUEventProcessor.cc.
References asSummarize_, edm::hlt::Exception, runTheMatrix::msg, summarize(), wlSummarize_, and wlSummarizeActive_.
Referenced by enabling().
|
private |
Definition at line 838 of file FUEventProcessor.cc.
References asSupervisor_, edm::hlt::Exception, runTheMatrix::msg, supervising_, supervisor(), and wlSupervising_.
Referenced by FUEventProcessor().
|
private |
Definition at line 1620 of file FUEventProcessor.cc.
References detachDqmFromShm(), edm::IEventProcessor::epSuccess, edm::IEventProcessor::epTimedOut, evtProcessor_, edm::hlt::Exception, evf::StateMachine::fireEvent(), evf::StateMachine::fireFailed(), fsm_, hasShMem_, localLog(), reasonForFailedState_, and evf::FWEPWrapper::stop().
Referenced by receiving(), and stopping().
bool FUEventProcessor::stopping | ( | toolbox::task::WorkLoop * | wl | ) |
Definition at line 498 of file FUEventProcessor.cc.
References nbSubProcesses_, evf::Vulture::stop(), stopClassic(), stopSlavesAndAcknowledge(), and vulture_.
Referenced by supervisor().
|
private |
Definition at line 1649 of file FUEventProcessor.cc.
References i, localLog(), MAX_MSG_SIZE, runTheMatrix::msg, MSQM_MESSAGE_TYPE_STOP, MSQS_MESSAGE_TYPE_STOP, nbSubProcesses_, reasonForFailedState_, stop_lock_, and subs_.
Referenced by halting(), and stopping().
void FUEventProcessor::subWeb | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) |
Definition at line 574 of file FUEventProcessor.cc.
References anonymousPipe_, gather_cfg::cout, generateEDF::done, asciidump::els, i, j, python.multivaluedict::map(), MAX_MSG_SIZE, MAX_PIPE_BUFFER_SIZE, mod(), runTheMatrix::msg, MSGQ_MESSAGE_TYPE_RANGE, MSQM_MESSAGE_TYPE_WEB, MSQS_MESSAGE_TYPE_WEB, evf::utils::pid, csv2json::pieces, PIPE_READ, SiPixelLorentzAngle_cfi::read, stor::utils::sleep(), subs_, and superSleepSec_.
Referenced by FUEventProcessor().
|
private |
Definition at line 1273 of file FUEventProcessor.cc.
References gather_cfg::cout, cpustat_, evtProcessor_, evf::FWEPWrapper::fireScalersUpdate(), fsm_, evf::FWEPWrapper::getLumiSectionReferenceIndex(), evf::FWEPWrapper::getPackedTriggerReportAsStruct(), i, iDieStatisticsGathering_, evf::TriggerReportStatic::lumiSection, master_message_trr_, MSQS_MESSAGE_TYPE_TRR, nbSubProcessesReporting_, ratestat_, evf::CPUStat::reset(), evf::FWEPWrapper::resetPackedTriggerReport(), runTheMatrix::ret, evf::RateStat::sendStat(), evf::CPUStat::sendStat(), stor::utils::sleep(), evf::StateMachine::stateName(), subs_, evf::FWEPWrapper::sumAndPackTriggerReport(), evf::FWEPWrapper::updateRollingReport(), evf::FWEPWrapper::withdrawLumiSectionIncrement(), and wlScalersActive_.
Referenced by startSummarizeWorkLoop().
|
private |
Definition at line 932 of file FUEventProcessor.cc.
References evf::CPUStat::addEntry(), evf::FWEPWrapper::adjustLsIndexForRestart(), applicationInfoSpace_, autoRestartSlaves_, gather_cfg::cout, cpustat_, evf::StateMachine::disableRcmsStateNotification(), evf::prg::dqm, enableMPEPSlave(), evtProcessor_, cmsCodeRules.cppFunctionSkipper::exception, edm::hlt::Exception, spr::find(), evf::StateMachine::fireEvent(), fsm_, i, localLog(), log_, evf::prg::ls, python.rootplot.utilities::ls(), master_message_prg_, master_message_prr_, evf::FWEPWrapper::moduleNameFromIndex(), monitorInfoSpace_, evf::prg::Ms, evf::prg::ms, MSQM_MESSAGE_TYPE_FSTOP, myProcess_, names_, nbAccepted, nbdead_, nblive_, nbProcessed, nbSubProcesses_, nbTotalDQM_, evf::FWEPWrapper::notstarted_state_code(), NUMERIC_MESSAGE_SIZE, L1TEmulatorMonitor_cff::p, pickup_lock_, evf::utils::pid, evf::prg::ps, evf::FWEPWrapper::resetPackedTriggerReport(), scalersUpdates_, edm::event_processor::sError, edm::event_processor::sInit, edm::event_processor::sInvalid, slaveRestartDelaySecs_, stor::utils::sleep(), spMStates_, spmStates_, edm::event_processor::sStopping, evf::StateMachine::stateName(), evf::FWEPWrapper::stateNameFromIndex(), stop_lock_, stopping(), subs_, superSleepSec_, and evf::prg::trp.
Referenced by startSupervisorLoop().
void FUEventProcessor::updater | ( | xgi::Input * | in, |
xgi::Output * | out | ||
) |
Definition at line 1805 of file FUEventProcessor.cc.
References evf::lsTriplet::acc, evf::utils::cDiv(), configString_, evtProcessor_, fsm_, evf::Vulture::hasStarted(), i, iDieUrl_, evf::FWEPWrapper::lastLumi(), logRing_, logRingIndex_, logRingSize_, logWrap_, evf::lsTriplet::ls, evf::utils::mDiv(), myProcess_, nbAccepted, nbProcessed, nbSubProcesses_, nbSubProcessesReporting_, evf::lsTriplet::proc, runNumber_, squidPresent_, evf::StateMachine::stateName(), supervising_, updaterStatic_, evf::utils::uptime(), vp_, vulture_, evf::FWEPWrapper::wlMonitoring(), wlScalersActive_, and wlSummarizeActive_.
Referenced by FUEventProcessor().
evf::FUEventProcessor::XDAQ_INSTANTIATOR | ( | ) |
|
private |
Definition at line 244 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), receivingAndMonitor(), and subWeb().
|
private |
Definition at line 222 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), makeStaticInfo(), receivingAndMonitor(), and supervisor().
|
private |
Definition at line 210 of file FUEventProcessor.h.
Referenced by startReceivingLoop().
|
private |
Definition at line 213 of file FUEventProcessor.h.
Referenced by startReceivingMonitorLoop().
|
private |
Definition at line 236 of file FUEventProcessor.h.
Referenced by startScalersWorkLoop().
|
private |
Definition at line 242 of file FUEventProcessor.h.
Referenced by startSummarizeWorkLoop().
|
private |
Definition at line 217 of file FUEventProcessor.h.
Referenced by startSupervisorLoop().
|
private |
Definition at line 167 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), microState(), and supervisor().
|
private |
Definition at line 158 of file FUEventProcessor.h.
Referenced by FUEventProcessor().
|
private |
Definition at line 162 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), FUEventProcessor(), and updater().
|
private |
Definition at line 163 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), and spotlightWebPage().
|
private |
Definition at line 252 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), summarize(), and supervisor().
|
private |
Definition at line 189 of file FUEventProcessor.h.
Referenced by css().
|
private |
Definition at line 161 of file FUEventProcessor.h.
Referenced by actionPerformed(), configuring(), enabling(), and FUEventProcessor().
|
private |
Definition at line 154 of file FUEventProcessor.h.
Referenced by actionPerformed(), attachDqmToShm(), configuring(), detachDqmFromShm(), enableClassic(), enableCommon(), enableMPEPSlave(), enabling(), FUEventProcessor(), halting(), microState(), moduleWeb(), pathNames(), receivingAndMonitor(), scalers(), scalersWeb(), serviceWeb(), spotlightWebPage(), stopClassic(), summarize(), supervisor(), and updater().
|
private |
Definition at line 186 of file FUEventProcessor.h.
Referenced by receivingAndMonitor().
|
private |
Definition at line 148 of file FUEventProcessor.h.
Referenced by actionPerformed(), configuring(), enableCommon(), enableMPEPSlave(), enabling(), fsmCallback(), FUEventProcessor(), halting(), microState(), receiving(), receivingAndMonitor(), spotlightWebPage(), stopClassic(), summarize(), supervisor(), and updater().
|
private |
Definition at line 172 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), FUEventProcessor(), and makeStaticInfo().
|
private |
Definition at line 171 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), and FUEventProcessor().
|
private |
Definition at line 173 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), FUEventProcessor(), and makeStaticInfo().
|
private |
Definition at line 170 of file FUEventProcessor.h.
Referenced by enableCommon(), FUEventProcessor(), makeStaticInfo(), and stopClassic().
|
private |
Definition at line 175 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), FUEventProcessor(), and summarize().
|
private |
Definition at line 249 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), FUEventProcessor(), and updater().
|
private |
Definition at line 159 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), and FUEventProcessor().
|
private |
Definition at line 174 of file FUEventProcessor.h.
Referenced by enableCommon(), and FUEventProcessor().
|
private |
Definition at line 151 of file FUEventProcessor.h.
Referenced by supervisor().
|
private |
Definition at line 195 of file FUEventProcessor.h.
Referenced by localLog(), logsAsString(), and updater().
|
private |
Definition at line 196 of file FUEventProcessor.h.
Referenced by localLog(), logsAsString(), and updater().
|
staticprivate |
Definition at line 197 of file FUEventProcessor.h.
Referenced by localLog(), and updater().
|
private |
Definition at line 198 of file FUEventProcessor.h.
Referenced by localLog(), logsAsString(), and updater().
|
private |
Definition at line 255 of file FUEventProcessor.h.
Referenced by supervisor().
|
private |
Definition at line 256 of file FUEventProcessor.h.
Referenced by supervisor().
|
private |
Definition at line 259 of file FUEventProcessor.h.
Referenced by summarize().
|
private |
Definition at line 220 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), and supervisor().
|
private |
Definition at line 221 of file FUEventProcessor.h.
Referenced by FUEventProcessor().
|
private |
Definition at line 215 of file FUEventProcessor.h.
Referenced by enabling(), microState(), receiving(), receivingAndMonitor(), scalers(), sendMessageOverMonitorQueue(), spotlightWebPage(), supervisor(), and updater().
|
private |
Definition at line 248 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), and supervisor().
|
private |
Definition at line 228 of file FUEventProcessor.h.
Referenced by supervisor(), and updater().
|
private |
Definition at line 204 of file FUEventProcessor.h.
Referenced by microState(), and supervisor().
|
private |
Definition at line 203 of file FUEventProcessor.h.
Referenced by microState(), and supervisor().
|
private |
Definition at line 227 of file FUEventProcessor.h.
Referenced by supervisor(), and updater().
|
private |
Definition at line 200 of file FUEventProcessor.h.
Referenced by configuring(), defaultWebPage(), enabling(), FUEventProcessor(), halting(), microState(), spotlightWebPage(), stopping(), stopSlavesAndAcknowledge(), supervisor(), and updater().
|
private |
Definition at line 201 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), summarize(), and updater().
|
private |
Definition at line 206 of file FUEventProcessor.h.
Referenced by enabling(), microState(), and supervisor().
|
private |
Definition at line 176 of file FUEventProcessor.h.
Referenced by actionPerformed().
|
private |
Definition at line 165 of file FUEventProcessor.h.
Referenced by actionPerformed(), FUEventProcessor(), and makeStaticInfo().
|
private |
Definition at line 225 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), microState(), and supervisor().
|
private |
Definition at line 253 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), and summarize().
|
private |
Definition at line 192 of file FUEventProcessor.h.
Referenced by configuring(), enableCommon(), enableMPEPSlave(), halting(), stopClassic(), and stopSlavesAndAcknowledge().
|
private |
Definition at line 211 of file FUEventProcessor.h.
Referenced by startReceivingLoop().
|
private |
Definition at line 214 of file FUEventProcessor.h.
Referenced by startReceivingMonitorLoop().
|
private |
Definition at line 160 of file FUEventProcessor.h.
Referenced by enableCommon(), enabling(), FUEventProcessor(), and updater().
|
private |
Definition at line 231 of file FUEventProcessor.h.
Referenced by enabling(), and FUEventProcessor().
|
private |
Definition at line 232 of file FUEventProcessor.h.
Referenced by configuring(), FUEventProcessor(), and pathNames().
|
private |
Definition at line 238 of file FUEventProcessor.h.
Referenced by enabling(), receivingAndMonitor(), scalers(), and supervisor().
|
private |
Definition at line 258 of file FUEventProcessor.h.
Referenced by receivingAndMonitor().
|
private |
Definition at line 257 of file FUEventProcessor.h.
Referenced by receivingAndMonitor().
|
private |
Definition at line 168 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), and supervisor().
|
private |
Definition at line 179 of file FUEventProcessor.h.
Referenced by FUEventProcessor().
|
private |
Definition at line 245 of file FUEventProcessor.h.
Referenced by configuring(), FUEventProcessor(), and supervisor().
|
private |
Definition at line 246 of file FUEventProcessor.h.
Referenced by configuring(), FUEventProcessor(), and supervisor().
|
private |
Definition at line 194 of file FUEventProcessor.h.
Referenced by FUEventProcessor().
|
private |
Definition at line 182 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), and updater().
|
private |
Definition at line 224 of file FUEventProcessor.h.
Referenced by enabling(), FUEventProcessor(), and microState().
|
private |
Definition at line 223 of file FUEventProcessor.h.
Referenced by enabling(), FUEventProcessor(), receiving(), receivingAndMonitor(), stopSlavesAndAcknowledge(), and supervisor().
|
private |
Definition at line 202 of file FUEventProcessor.h.
Referenced by enabling(), microState(), stopSlavesAndAcknowledge(), subWeb(), summarize(), and supervisor().
|
private |
Definition at line 247 of file FUEventProcessor.h.
Referenced by FUEventProcessor(), subWeb(), and supervisor().
|
private |
Definition at line 218 of file FUEventProcessor.h.
Referenced by startSupervisorLoop(), and updater().
|
private |
Definition at line 226 of file FUEventProcessor.h.
Referenced by makeStaticInfo(), and updater().
|
private |
Definition at line 157 of file FUEventProcessor.h.
Referenced by FUEventProcessor().
|
private |
Definition at line 251 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), and updater().
|
private |
Definition at line 250 of file FUEventProcessor.h.
Referenced by configuring(), enabling(), FUEventProcessor(), stopping(), updater(), and ~FUEventProcessor().
|
private |
Definition at line 209 of file FUEventProcessor.h.
Referenced by startReceivingLoop().
|
private |
Definition at line 212 of file FUEventProcessor.h.
Referenced by startReceivingMonitorLoop().
|
private |
Definition at line 235 of file FUEventProcessor.h.
Referenced by startScalersWorkLoop().
|
private |
Definition at line 237 of file FUEventProcessor.h.
Referenced by scalers(), startScalersWorkLoop(), summarize(), and updater().
|
private |
Definition at line 241 of file FUEventProcessor.h.
Referenced by startSummarizeWorkLoop().
|
private |
Definition at line 243 of file FUEventProcessor.h.
Referenced by startSummarizeWorkLoop(), and updater().
|
private |
Definition at line 216 of file FUEventProcessor.h.
Referenced by startSupervisorLoop().