#include "/cvmfs/nova.opensciencegrid.org/externals/art/v2_13_00/source/art/Framework/Core/WorkerT.h"
Public Types | |
using | ModuleType = T |
using | WorkerType = WorkerT< T > |
enum | State { Ready, Pass, Fail, Working, Exception } |
Public Member Functions | |
WorkerT (std::unique_ptr< T > &&, ModuleDescription const &, WorkerParams const &) | |
bool | modifiesEvent () const override |
template<typename T > | |
bool | doWork (typename T::MyPrincipal &, CurrentProcessingContext const *cpc) |
void | beginJob () |
void | endJob () |
void | respondToOpenInputFile (FileBlock const &fb) |
void | respondToCloseInputFile (FileBlock const &fb) |
void | respondToOpenOutputFiles (FileBlock const &fb) |
void | respondToCloseOutputFiles (FileBlock const &fb) |
void | reset () |
ModuleDescription const & | description () const |
ModuleDescription const * | descPtr () const |
void | setActivityRegistry (cet::exempt_ptr< ActivityRegistry > areg) |
void | clearCounters () |
std::size_t | timesRun () const |
std::size_t | timesVisited () const |
std::size_t | timesPassed () const |
std::size_t | timesFailed () const |
std::size_t | timesExcept () const |
State | state () const |
std::string const & | label () const |
Protected Member Functions | |
T & | module () |
T const & | module () const |
Private Member Functions | |
bool | implDoProcess (EventPrincipal &ep, CurrentProcessingContext const *cpc, CountingStatistics &) override |
bool | implDoBegin (RunPrincipal &rp, CurrentProcessingContext const *cpc) override |
bool | implDoEnd (RunPrincipal &rp, CurrentProcessingContext const *cpc) override |
bool | implDoBegin (SubRunPrincipal &srp, CurrentProcessingContext const *cpc) override |
bool | implDoEnd (SubRunPrincipal &srp, CurrentProcessingContext const *cpc) override |
void | implBeginJob () override |
void | implEndJob () override |
void | implRespondToOpenInputFile (FileBlock const &fb) override |
void | implRespondToCloseInputFile (FileBlock const &fb) override |
void | implRespondToOpenOutputFiles (FileBlock const &fb) override |
void | implRespondToCloseOutputFiles (FileBlock const &fb) override |
std::string | workerType () const override |
Private Attributes | |
std::unique_ptr< T > | module_ |
using art::WorkerT< T >::ModuleType = T |
using art::WorkerT< T >::WorkerType = WorkerT<T> |
|
inherited |
Enumerator | |
---|---|
Ready | |
Pass | |
Fail | |
Working | |
Exception |
Definition at line 53 of file Worker.h.
|
inline |
Definition at line 73 of file WorkerT.h.
References fetch_tb_beamline_files::md, art::WorkerT< T >::module(), and art::WorkerT< T >::module_.
|
inherited |
|
inlineinherited |
Definition at line 88 of file Worker.h.
References art::Worker::counts_.
|
inlineinherited |
Definition at line 79 of file Worker.h.
References art::Worker::md_, and art::Worker::setActivityRegistry().
|
inlineinherited |
Definition at line 74 of file Worker.h.
References art::Worker::md_.
|
inherited |
Definition at line 218 of file Worker.h.
References plot_validation_datamc::action, art::Worker::actions_, art::Worker::actReg_, ana::assert(), art::errors::BadAlloc, art::errors::BadExceptionType, plot_validation_datamc::c, art::Worker::cached_exception_, art::Worker::counts_, e, art::Event, art::Worker::Exception, art::detail::exceptionContext(), art::Worker::Fail, art::actions::FailModule, art::actions::FailPath, art::ActionTable::find(), art::actions::IgnoreCompletely, art::CurrentProcessingContext::isEndPath(), art::Worker::md_, art::errors::OtherArt, art::Worker::Pass, submit_cafana::rc, art::Worker::Ready, art::actions::Rethrow, art::errors::ScheduleExecutionFailure, art::actions::SkipEvent, art::Worker::state_, art::errors::StdException, string, art::errors::Unknown, and art::Worker::Working.
|
inherited |
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 130 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 93 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 107 of file WorkerT.h.
References art::WorkerT< T >::module_.
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 100 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 115 of file WorkerT.h.
References art::WorkerT< T >::module_, and string.
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 84 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 137 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 151 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 165 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 144 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 158 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
inlineinherited |
Definition at line 127 of file Worker.h.
References art::Worker::implBeginJob(), art::Worker::implDoBegin(), art::Worker::implDoEnd(), art::Worker::implDoProcess(), art::Worker::implEndJob(), art::Worker::md_, art::ModuleDescription::moduleLabel(), string, and art::Worker::workerType().
|
inlineoverridevirtual |
|
inlineprotected |
|
inlineprotected |
|
inlineinherited |
Definition at line 68 of file Worker.h.
References art::Worker::Ready, and art::Worker::state_.
|
inherited |
The signals are required to live longer than the last call to 'doWork' this was done to improve performance based on profiling
Referenced by art::Worker::descPtr().
|
inlineinherited |
Definition at line 119 of file Worker.h.
References art::Worker::modifiesEvent(), art::Worker::state_, and string.
|
inlineinherited |
Definition at line 114 of file Worker.h.
References art::Worker::counts_, and art::ExecutionCounts< ARGS >::times().
|
inlineinherited |
Definition at line 109 of file Worker.h.
References art::Worker::counts_, and art::ExecutionCounts< ARGS >::times().
|
inlineinherited |
Definition at line 104 of file Worker.h.
References art::Worker::counts_, and art::ExecutionCounts< ARGS >::times().
|
inlineinherited |
Definition at line 94 of file Worker.h.
References art::Worker::counts_, and art::ExecutionCounts< ARGS >::times().
|
inlineinherited |
Definition at line 99 of file Worker.h.
References art::Worker::counts_, and art::ExecutionCounts< ARGS >::times().
|
overrideprivatevirtual |
Implements art::Worker.
Definition at line 123 of file WorkerT.h.
References art::WorkerT< T >::module_.
Referenced by art::WorkerT< OutputModule >::module().
|
private |
Definition at line 69 of file WorkerT.h.
Referenced by art::WorkerT< T >::implBeginJob(), art::WorkerT< T >::implDoBegin(), art::WorkerT< T >::implDoEnd(), art::WorkerT< T >::implDoProcess(), art::WorkerT< T >::implEndJob(), art::WorkerT< T >::implRespondToCloseInputFile(), art::WorkerT< T >::implRespondToCloseOutputFiles(), art::WorkerT< T >::implRespondToOpenInputFile(), art::WorkerT< T >::implRespondToOpenOutputFiles(), art::WorkerT< OutputModule >::modifiesEvent(), art::WorkerT< OutputModule >::module(), art::WorkerT< T >::WorkerT(), and art::WorkerT< T >::workerType().