#include <StreamSchedule.h>
Classes | |
struct | AliasInfo |
class | SendTerminationSignalIfException |
Public Types | |
typedef std::vector< Worker * > | AllWorkers |
typedef std::vector< Path > | NonTrigPaths |
typedef std::vector< WorkerInPath > | PathWorkers |
typedef std::vector< Path > | TrigPaths |
typedef std::shared_ptr< HLTGlobalStatus const > | TrigResConstPtr |
typedef std::shared_ptr< HLTGlobalStatus > | TrigResPtr |
typedef std::vector< std::string > | vstring |
typedef std::shared_ptr< Worker > | WorkerPtr |
typedef std::vector< Worker * > | Workers |
Public Member Functions | |
AllWorkers const & | allWorkers () const |
returns the collection of pointers to workers More... | |
void | availablePaths (std::vector< std::string > &oLabelsToFill) const |
adds to oLabelsToFill the labels for all paths in the process More... | |
void | beginStream () |
void | clearCounters () |
Clear all the counters in the trigger report. More... | |
StreamContext const & | context () const |
void | deleteModule (std::string const &iLabel) |
Delete the module with label iLabel. More... | |
void | endStream () |
std::vector< ModuleDescription const * > | getAllModuleDescriptions () const |
void | getTriggerReport (TriggerReport &rep) const |
void | initializeEarlyDelete (ModuleRegistry &modReg, std::vector< std::string > const &branchesToDeleteEarly, edm::ProductRegistry const &preg) |
void | moduleDescriptionsInEndPath (std::string const &iEndPathLabel, std::vector< ModuleDescription const *> &descriptions, unsigned int hint) const |
void | moduleDescriptionsInPath (std::string const &iPathLabel, std::vector< ModuleDescription const *> &descriptions, unsigned int hint) const |
void | modulesInPath (std::string const &iPathLabel, std::vector< std::string > &oLabelsToFill) const |
adds to oLabelsToFill in execution order the labels of all modules in path iPathLabel More... | |
unsigned int | numberOfUnscheduledModules () const |
void | processOneEventAsync (WaitingTaskHolder iTask, EventTransitionInfo &, ServiceToken const &token, std::vector< edm::propagate_const< std::shared_ptr< PathStatusInserter >>> &pathStatusInserters) |
template<typename T > | |
void | processOneStreamAsync (WaitingTaskHolder iTask, typename T::TransitionInfoType &transitionInfo, ServiceToken const &token, bool cleaningUpAfterException=false) |
void | replaceModule (maker::ModuleHolder *iMod, std::string const &iLabel) |
clone the type of module with label iLabel but configure with iPSet. More... | |
StreamID | streamID () const |
StreamSchedule (std::shared_ptr< TriggerResultInserter > inserter, std::vector< edm::propagate_const< std::shared_ptr< PathStatusInserter >>> &pathStatusInserters, std::vector< edm::propagate_const< std::shared_ptr< EndPathStatusInserter >>> &endPathStatusInserters, std::shared_ptr< ModuleRegistry >, ParameterSet &proc_pset, service::TriggerNamesService const &tns, PreallocationConfiguration const &prealloc, ProductRegistry &pregistry, BranchIDListHelper &branchIDListHelper, ExceptionToActionTable const &actions, std::shared_ptr< ActivityRegistry > areg, std::shared_ptr< ProcessConfiguration > processConfiguration, StreamID streamID, ProcessContext const *processContext) | |
StreamSchedule (StreamSchedule const &)=delete | |
int | totalEvents () const |
int | totalEventsFailed () const |
int | totalEventsPassed () const |
Private Member Functions | |
ExceptionToActionTable const & | actionTable () const |
returns the action table More... | |
void | addToAllWorkers (Worker *w) |
void | fillEndPath (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, int bitpos, std::string const &name, std::vector< std::string > const &endPathNames, ConditionalTaskHelper const &conditionalTaskHelper) |
void | fillTrigPath (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, int bitpos, std::string const &name, TrigResPtr, std::vector< std::string > const &endPathNames, ConditionalTaskHelper const &conditionalTaskHelper) |
void | fillWorkers (ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration, std::string const &name, bool ignoreFilters, PathWorkers &out, std::vector< std::string > const &endPathNames, ConditionalTaskHelper const &conditionalTaskHelper) |
void | finishedPaths (std::atomic< std::exception_ptr *> &, WaitingTaskHolder, EventTransitionInfo &) |
std::exception_ptr | finishProcessOneEvent (std::exception_ptr) |
void | makePathStatusInserters (std::vector< edm::propagate_const< std::shared_ptr< PathStatusInserter >>> &pathStatusInserters, std::vector< edm::propagate_const< std::shared_ptr< EndPathStatusInserter >>> &endPathStatusInserters, ExceptionToActionTable const &actions) |
void | reportSkipped (EventPrincipal const &ep) const |
void | resetAll () |
void | resetEarlyDelete () |
TrigResConstPtr | results () const |
TrigResPtr & | results () |
std::vector< Worker * > | tryToPlaceConditionalModules (Worker *, std::unordered_set< std::string > &conditionalModules, std::multimap< std::string, edm::BranchDescription const *> const &conditionalModuleBranches, std::multimap< std::string, AliasInfo > const &aliasMap, ParameterSet &proc_pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration const > processConfiguration) |
Private Attributes | |
std::shared_ptr< ActivityRegistry > | actReg_ |
std::vector< BranchToCount > | earlyDeleteBranchToCount_ |
std::vector< EarlyDeleteHelper > | earlyDeleteHelpers_ |
std::vector< unsigned int > | earlyDeleteHelperToBranchIndicies_ |
std::vector< int > | empty_end_paths_ |
std::vector< int > | empty_trig_paths_ |
TrigPaths | end_paths_ |
std::vector< edm::propagate_const< WorkerPtr > > | endPathStatusInserterWorkers_ |
unsigned int | number_of_unscheduled_modules_ |
std::vector< edm::propagate_const< WorkerPtr > > | pathStatusInserterWorkers_ |
edm::propagate_const< TrigResPtr > | results_ |
edm::propagate_const< WorkerPtr > | results_inserter_ |
std::atomic< bool > | skippingEvent_ |
StreamContext | streamContext_ |
StreamID | streamID_ |
int | total_events_ |
int | total_passed_ |
TrigPaths | trig_paths_ |
WorkerManager | workerManager_ |
Definition at line 155 of file StreamSchedule.h.
typedef std::vector<Worker*> edm::StreamSchedule::AllWorkers |
Definition at line 163 of file StreamSchedule.h.
typedef std::vector<Path> edm::StreamSchedule::NonTrigPaths |
Definition at line 159 of file StreamSchedule.h.
typedef std::vector<WorkerInPath> edm::StreamSchedule::PathWorkers |
Definition at line 167 of file StreamSchedule.h.
typedef std::vector<Path> edm::StreamSchedule::TrigPaths |
Definition at line 158 of file StreamSchedule.h.
typedef std::shared_ptr<HLTGlobalStatus const> edm::StreamSchedule::TrigResConstPtr |
Definition at line 161 of file StreamSchedule.h.
typedef std::shared_ptr<HLTGlobalStatus> edm::StreamSchedule::TrigResPtr |
Definition at line 160 of file StreamSchedule.h.
typedef std::vector<std::string> edm::StreamSchedule::vstring |
Definition at line 157 of file StreamSchedule.h.
typedef std::shared_ptr<Worker> edm::StreamSchedule::WorkerPtr |
Definition at line 162 of file StreamSchedule.h.
typedef std::vector<Worker*> edm::StreamSchedule::Workers |
Definition at line 165 of file StreamSchedule.h.
edm::StreamSchedule::StreamSchedule | ( | std::shared_ptr< TriggerResultInserter > | inserter, |
std::vector< edm::propagate_const< std::shared_ptr< PathStatusInserter >>> & | pathStatusInserters, | ||
std::vector< edm::propagate_const< std::shared_ptr< EndPathStatusInserter >>> & | endPathStatusInserters, | ||
std::shared_ptr< ModuleRegistry > | modReg, | ||
ParameterSet & | proc_pset, | ||
service::TriggerNamesService const & | tns, | ||
PreallocationConfiguration const & | prealloc, | ||
ProductRegistry & | pregistry, | ||
BranchIDListHelper & | branchIDListHelper, | ||
ExceptionToActionTable const & | actions, | ||
std::shared_ptr< ActivityRegistry > | areg, | ||
std::shared_ptr< ProcessConfiguration > | processConfiguration, | ||
StreamID | streamID, | ||
ProcessContext const * | processContext | ||
) |
Definition at line 264 of file StreamSchedule.cc.
References actions, actReg_, addToAllWorkers(), edm::WorkerManager::addToUnscheduledWorkers(), allWorkers(), cms::cuda::assert(), end_paths_, fillEndPath(), fillTrigPath(), edm::propagate_const< T >::get(), edm::service::TriggerNamesService::getEndPaths(), edm::ParameterSet::getParameter(), edm::ParameterSet::getPSetForUpdate(), edm::service::TriggerNamesService::getTrigPaths(), label, makePathStatusInserters(), number_of_unscheduled_modules_, results(), results_inserter_, DBoxMetadataHelper::set_difference(), streamID(), trig_paths_, edm::StreamID::value(), and workerManager_.
|
delete |
|
inlineprivate |
returns the action table
Definition at line 291 of file StreamSchedule.h.
References edm::WorkerManager::actionTable(), and workerManager_.
Referenced by fillEndPath(), fillTrigPath(), and finishedPaths().
|
private |
Definition at line 1203 of file StreamSchedule.cc.
References edm::WorkerManager::addToAllWorkers(), w(), and workerManager_.
Referenced by fillEndPath(), fillTrigPath(), makePathStatusInserters(), and StreamSchedule().
|
inline |
returns the collection of pointers to workers
Definition at line 256 of file StreamSchedule.h.
References edm::WorkerManager::allWorkers(), and workerManager_.
Referenced by clearCounters(), getAllModuleDescriptions(), getTriggerReport(), initializeEarlyDelete(), replaceModule(), and StreamSchedule().
void edm::StreamSchedule::availablePaths | ( | std::vector< std::string > & | oLabelsToFill | ) | const |
adds to oLabelsToFill the labels for all paths in the process
Definition at line 1058 of file StreamSchedule.cc.
References edm::Path::name(), HcalDetIdTransform::transform(), and trig_paths_.
void edm::StreamSchedule::beginStream | ( | ) |
Definition at line 829 of file StreamSchedule.cc.
References edm::WorkerManager::beginStream(), streamContext_, streamID_, and workerManager_.
void edm::StreamSchedule::clearCounters | ( | ) |
Clear all the counters in the trigger report.
Definition at line 1190 of file StreamSchedule.cc.
References allWorkers(), edm::Path::clearCounters(), edm::Worker::clearCounters(), end_paths_, edm::for_all(), total_events_, total_passed_, and trig_paths_.
|
inline |
void edm::StreamSchedule::deleteModule | ( | std::string const & | iLabel | ) |
Delete the module with label iLabel.
Definition at line 849 of file StreamSchedule.cc.
References edm::WorkerManager::deleteModuleIfExists(), and workerManager_.
void edm::StreamSchedule::endStream | ( | ) |
Definition at line 831 of file StreamSchedule.cc.
References edm::WorkerManager::endStream(), streamContext_, streamID_, and workerManager_.
|
private |
Definition at line 798 of file StreamSchedule.cc.
References actionTable(), actReg_, addToAllWorkers(), empty_end_paths_, end_paths_, fillWorkers(), edm::PathContext::kEndPath, Skims_PA_cff::name, and streamContext_.
Referenced by StreamSchedule().
|
private |
Definition at line 766 of file StreamSchedule.cc.
References actionTable(), actReg_, addToAllWorkers(), empty_trig_paths_, fillWorkers(), edm::PathContext::kPath, Skims_PA_cff::name, skippingEvent_, streamContext_, and trig_paths_.
Referenced by StreamSchedule().
|
private |
Definition at line 662 of file StreamSchedule.cc.
References edm::ConditionalTaskHelper::aliasMap(), edm::ConditionalTaskHelper::conditionalModuleBranches(), edm::errors::Configuration, edm::Worker::description(), Exception, spr::find(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), edm::WorkerInPath::Ignore, edm::Worker::kFilter, HerwigMaxPtPartonFilter_cfi::moduleLabel, edm::ModuleDescription::moduleName(), edm::Worker::moduleType(), Skims_PA_cff::name, edm::WorkerInPath::Normal, or, MillePedeFileConverter_cfg::out, hltMonBTagIPClient_cfi::pathName, edm::search_all(), AlCaHLTBitMon_QueryRunRegistry::string, tryToPlaceConditionalModules(), edm::WorkerInPath::Veto, and workerManager_.
Referenced by fillEndPath(), and fillTrigPath().
|
private |
Definition at line 968 of file StreamSchedule.cc.
References writedatasetfile::action, actionTable(), cms::Exception::addContext(), cms::cuda::assert(), CMS_SA_ALLOW, cms::Exception::context(), edm::WaitingTaskHolder::doneWaiting(), MillePedeFileConverter_cfg::e, edm::exception_actions::FailPath, edm::ExceptionToActionTable::find(), edm::propagate_const< T >::get(), edm::exception_actions::IgnoreCompletely, info(), edm::printCmsExceptionWarning(), results_, results_inserter_, edm::exception_actions::SkipEvent, streamContext_, streamID_, and total_passed_.
Referenced by processOneEventAsync().
|
private |
Definition at line 1026 of file StreamSchedule.cc.
References actReg_, edm::addContextAndPrintException(), CMS_SA_ALLOW, cms::Exception::context(), edm::ExceptionFromThisContext, resetEarlyDelete(), streamContext_, and edm::convertException::wrap().
Referenced by processOneEventAsync().
std::vector< ModuleDescription const * > edm::StreamSchedule::getAllModuleDescriptions | ( | ) | const |
Return a vector allowing const access to all the ModuleDescriptions for this StreamSchedule. *** N.B. *** Ownership of the ModuleDescriptions is not *** passed to the caller. Do not call delete on these *** pointers!
Definition at line 851 of file StreamSchedule.cc.
References allWorkers(), AlCaHLTBitMon_ParallelJobs::p, mps_fire::result, and findQualityFiles::size.
void edm::StreamSchedule::getTriggerReport | ( | TriggerReport & | rep | ) | const |
Return the trigger report information on paths, modules-in-path, modules-in-endpath, and modules.
Definition at line 1180 of file StreamSchedule.cc.
References allWorkers(), end_paths_, edm::fillPathSummary(), edm::fillWorkerSummary(), cuy::rep, totalEvents(), totalEventsFailed(), totalEventsPassed(), and trig_paths_.
void edm::StreamSchedule::initializeEarlyDelete | ( | ModuleRegistry & | modReg, |
std::vector< std::string > const & | branchesToDeleteEarly, | ||
edm::ProductRegistry const & | preg | ||
) |
Definition at line 376 of file StreamSchedule.cc.
References allWorkers(), MicroEventContent_cff::branch, edm::maker::ModuleHolder::createOutputModuleCommunicator(), dumpMFGeometry_cfg::delta, submitPVResolutionJobs::desc, earlyDeleteBranchToCount_, earlyDeleteHelpers_, earlyDeleteHelperToBranchIndicies_, end_paths_, edm::ModuleRegistry::forAllModuleHolders(), newFWLiteAna::found, edm::pset::Registry::getMapped(), edm::InEvent, edm::pset::Registry::instance(), B2GTnPMonitor_cfi::item, gpuClustering::pixelStatus::kEmpty, MainPageGenerator::l, dqmiodumpmetadata::n, AlCaHLTBitMon_ParallelJobs::p, muonDTDigis_cfi::pset, resetEarlyDelete(), AlCaHLTBitMon_QueryRunRegistry::string, groupFilesInBlocks::temp, trig_paths_, mitigatedMETSequence_cff::U, and w().
|
private |
Definition at line 1219 of file StreamSchedule.cc.
References actions, actReg_, addToAllWorkers(), empty_end_paths_, empty_trig_paths_, end_paths_, endPathStatusInserterWorkers_, edm::get_underlying(), pathStatusInserterWorkers_, and trig_paths_.
Referenced by StreamSchedule().
void edm::StreamSchedule::moduleDescriptionsInEndPath | ( | std::string const & | iEndPathLabel, |
std::vector< ModuleDescription const *> & | descriptions, | ||
unsigned int | hint | ||
) | const |
Definition at line 1108 of file StreamSchedule.cc.
References end_paths_, newFWLiteAna::found, mps_fire::i, and edm::Path::name().
void edm::StreamSchedule::moduleDescriptionsInPath | ( | std::string const & | iPathLabel, |
std::vector< ModuleDescription const *> & | descriptions, | ||
unsigned int | hint | ||
) | const |
Definition at line 1079 of file StreamSchedule.cc.
References newFWLiteAna::found, mps_fire::i, edm::Path::name(), and trig_paths_.
void edm::StreamSchedule::modulesInPath | ( | std::string const & | iPathLabel, |
std::vector< std::string > & | oLabelsToFill | ||
) | const |
adds to oLabelsToFill in execution order the labels of all modules in path iPathLabel
Definition at line 1066 of file StreamSchedule.cc.
References mps_fire::i, edm::Path::name(), and trig_paths_.
|
inline |
Definition at line 258 of file StreamSchedule.h.
References number_of_unscheduled_modules_.
void edm::StreamSchedule::processOneEventAsync | ( | WaitingTaskHolder | iTask, |
EventTransitionInfo & | info, | ||
ServiceToken const & | token, | ||
std::vector< edm::propagate_const< std::shared_ptr< PathStatusInserter >>> & | pathStatusInserters | ||
) |
Definition at line 862 of file StreamSchedule.cc.
References actReg_, CMS_SA_ALLOW, edm::WaitingTaskHolder::doneWaiting(), empty_end_paths_, empty_trig_paths_, end_paths_, endPathStatusInserterWorkers_, SiStripBadComponentsDQMServiceTemplate_cfg::ep, finishedPaths(), finishProcessOneEvent(), edm::WaitingTaskHolder::group(), info(), edm::ServiceWeakToken::lock(), edm::make_waiting_task(), eostools::move(), edm::hlt::Pass, pathStatusInserterWorkers_, edm::WorkerManager::processAccumulatorsAsync(), resetAll(), results_, edm::WorkerManager::setupOnDemandSystem(), edm::WorkerManager::setupResolvers(), streamContext_, streamID_, total_events_, trig_paths_, and workerManager_.
void edm::StreamSchedule::processOneStreamAsync | ( | WaitingTaskHolder | iTask, |
typename T::TransitionInfoType & | transitionInfo, | ||
ServiceToken const & | token, | ||
bool | cleaningUpAfterException = false |
||
) |
Definition at line 393 of file StreamSchedule.h.
References actReg_, edm::addContextAndPrintException(), CMS_SA_ALLOW, cms::Exception::context(), edm::WaitingTaskHolder::doneWaiting(), end_paths_, edm::ExceptionFromThisContext, edm::WaitingTaskHolder::group(), h, triggerObjects_cff::id, info(), edm::ServiceWeakToken::lock(), edm::make_functor_task(), edm::make_waiting_task(), AlCaHLTBitMon_ParallelJobs::p, edm::WorkerManager::processOneOccurrenceAsync(), edm::WorkerManager::resetAll(), alignCSCRings::s, streamContext_, streamID_, TrackValidation_cff::task, unpackBuffers-CaloStage2::token, trig_paths_, edm::StreamID::value(), workerManager_, and edm::convertException::wrap().
void edm::StreamSchedule::replaceModule | ( | maker::ModuleHolder * | iMod, |
std::string const & | iLabel | ||
) |
clone the type of module with label iLabel but configure with iPSet.
Definition at line 833 of file StreamSchedule.cc.
References allWorkers(), newFWLiteAna::found, edm::maker::ModuleHolder::replaceModuleFor(), streamContext_, and streamID_.
|
inlineprivate |
Definition at line 387 of file StreamSchedule.h.
References SiStripBadComponentsDQMServiceTemplate_cfg::ep.
|
private |
Definition at line 1198 of file StreamSchedule.cc.
References results_, and skippingEvent_.
Referenced by processOneEventAsync().
|
private |
Definition at line 1205 of file StreamSchedule.cc.
References submitPVResolutionJobs::count, earlyDeleteBranchToCount_, earlyDeleteHelpers_, and earlyDeleteHelperToBranchIndicies_.
Referenced by finishProcessOneEvent(), and initializeEarlyDelete().
|
inlineprivate |
Definition at line 341 of file StreamSchedule.h.
References edm::get_underlying_safe(), and results_.
Referenced by StreamSchedule().
|
inlineprivate |
Definition at line 342 of file StreamSchedule.h.
References edm::get_underlying_safe(), and results_.
|
inline |
Definition at line 201 of file StreamSchedule.h.
References streamID_.
Referenced by StreamSchedule().
|
inline |
Return the number of events this StreamSchedule has tried to process (inclues both successes and failures, including failures due to exceptions during processing).
Definition at line 228 of file StreamSchedule.h.
References total_events_.
Referenced by getTriggerReport(), and totalEventsFailed().
|
inline |
Return the number of events that have not passed any trigger. (N.B. totalEventsFailed() + totalEventsPassed() == totalEvents()
Definition at line 236 of file StreamSchedule.h.
References totalEvents(), and totalEventsPassed().
Referenced by getTriggerReport().
|
inline |
Return the number of events which have been passed by one or more trigger paths.
Definition at line 232 of file StreamSchedule.h.
References total_passed_.
Referenced by getTriggerReport(), and totalEventsFailed().
|
private |
Definition at line 521 of file StreamSchedule.cc.
References cms::cuda::assert(), MicroEventContent_cff::branch, edm::TypeID::className(), edm::Worker::consumesInfo(), edm::Worker::description(), edm::ELEMENT_TYPE, HerwigMaxPtPartonFilter_cfi::moduleLabel, edm::ModuleDescription::moduleLabel(), or, edm::PRODUCT_TYPE, edm::productholderindexhelper::typeIsViewCompatible(), and workerManager_.
Referenced by fillWorkers().
|
private |
Definition at line 350 of file StreamSchedule.h.
Referenced by fillEndPath(), fillTrigPath(), finishProcessOneEvent(), makePathStatusInserters(), processOneEventAsync(), processOneStreamAsync(), and StreamSchedule().
|
private |
Definition at line 366 of file StreamSchedule.h.
Referenced by initializeEarlyDelete(), and resetEarlyDelete().
|
private |
Definition at line 376 of file StreamSchedule.h.
Referenced by initializeEarlyDelete(), and resetEarlyDelete().
|
private |
Definition at line 373 of file StreamSchedule.h.
Referenced by initializeEarlyDelete(), and resetEarlyDelete().
|
private |
Definition at line 361 of file StreamSchedule.h.
Referenced by fillEndPath(), makePathStatusInserters(), and processOneEventAsync().
|
private |
Definition at line 360 of file StreamSchedule.h.
Referenced by fillTrigPath(), makePathStatusInserters(), and processOneEventAsync().
|
private |
Definition at line 359 of file StreamSchedule.h.
Referenced by clearCounters(), fillEndPath(), getTriggerReport(), initializeEarlyDelete(), makePathStatusInserters(), moduleDescriptionsInEndPath(), processOneEventAsync(), processOneStreamAsync(), and StreamSchedule().
|
private |
Definition at line 356 of file StreamSchedule.h.
Referenced by makePathStatusInserters(), and processOneEventAsync().
|
private |
Definition at line 380 of file StreamSchedule.h.
Referenced by numberOfUnscheduledModules(), and StreamSchedule().
|
private |
Definition at line 355 of file StreamSchedule.h.
Referenced by makePathStatusInserters(), and processOneEventAsync().
|
private |
Definition at line 352 of file StreamSchedule.h.
Referenced by finishedPaths(), processOneEventAsync(), resetAll(), and results().
|
private |
Definition at line 354 of file StreamSchedule.h.
Referenced by finishedPaths(), and StreamSchedule().
|
private |
Definition at line 384 of file StreamSchedule.h.
Referenced by fillTrigPath(), and resetAll().
|
private |
Definition at line 383 of file StreamSchedule.h.
Referenced by beginStream(), context(), endStream(), fillEndPath(), fillTrigPath(), finishedPaths(), finishProcessOneEvent(), processOneEventAsync(), processOneStreamAsync(), and replaceModule().
|
private |
Definition at line 382 of file StreamSchedule.h.
Referenced by beginStream(), endStream(), finishedPaths(), processOneEventAsync(), processOneStreamAsync(), replaceModule(), and streamID().
|
private |
Definition at line 378 of file StreamSchedule.h.
Referenced by clearCounters(), processOneEventAsync(), and totalEvents().
|
private |
Definition at line 379 of file StreamSchedule.h.
Referenced by clearCounters(), finishedPaths(), and totalEventsPassed().
|
private |
Definition at line 358 of file StreamSchedule.h.
Referenced by availablePaths(), clearCounters(), fillTrigPath(), getTriggerReport(), initializeEarlyDelete(), makePathStatusInserters(), moduleDescriptionsInPath(), modulesInPath(), processOneEventAsync(), processOneStreamAsync(), and StreamSchedule().
|
private |
Definition at line 349 of file StreamSchedule.h.
Referenced by actionTable(), addToAllWorkers(), allWorkers(), beginStream(), deleteModule(), endStream(), fillWorkers(), processOneEventAsync(), processOneStreamAsync(), StreamSchedule(), and tryToPlaceConditionalModules().