LArSoft
v06_85_00
Liquid Argon Software toolkit - http://larsoft.org/
|
#include "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 art::WorkerT< T >::module(), and art::WorkerT< T >::module_.
|
inherited |
Definition at line 18 of file Worker.cc.
References art::Worker::actReg_, art::errors::BadExceptionType, art::Worker::description(), e, art::Worker::implBeginJob(), art::Worker::md_, art::errors::OtherArt, s, art::errors::StdException, art::errors::Unknown, and art::Worker::workerType().
|
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_.
Referenced by art::Worker::beginJob(), art::OutputWorker::closeFile(), art::Worker::endJob(), art::OutputWorker::openFile(), and art::OutputWorker::OutputWorker().
|
inherited |
Definition at line 218 of file Worker.h.
References art::Worker::actions_, art::Worker::actReg_, art::errors::BadAlloc, art::errors::BadExceptionType, 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, art::Worker::Ready, art::actions::Rethrow, s, art::errors::ScheduleExecutionFailure, art::actions::SkipEvent, art::Worker::state_, art::errors::StdException, art::errors::Unknown, and art::Worker::Working.
|
inherited |
Definition at line 68 of file Worker.cc.
References art::Worker::actReg_, art::errors::BadExceptionType, art::Worker::description(), e, art::Worker::implEndJob(), art::Worker::md_, art::errors::OtherArt, s, art::errors::StdException, art::errors::Unknown, and art::Worker::workerType().
Referenced by art::EndPathExecutor::endJob(), and art::Schedule::endJob().
|
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_.
|
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(), and art::Worker::workerType().
Referenced by art::EndPathExecutor::closeAllOutputFiles(), art::EndPathExecutor::openAllOutputFiles(), and art::OutputWorker::OutputWorker().
|
inlineoverridevirtual |
|
inlineprotected |
|
inlineprotected |
|
inlineinherited |
Definition at line 68 of file Worker.h.
References art::Worker::Ready, and art::Worker::state_.
|
inherited |
Definition at line 128 of file Worker.cc.
References art::Worker::actReg_, art::Worker::implRespondToCloseInputFile(), and art::Worker::md_.
|
inherited |
Definition at line 146 of file Worker.cc.
References art::Worker::actReg_, art::Worker::implRespondToCloseOutputFiles(), and art::Worker::md_.
|
inherited |
Definition at line 119 of file Worker.cc.
References art::Worker::actReg_, art::Worker::implRespondToOpenInputFile(), and art::Worker::md_.
|
inherited |
Definition at line 137 of file Worker.cc.
References art::Worker::actReg_, art::Worker::implRespondToOpenOutputFiles(), and art::Worker::md_.
|
inherited |
The signals are required to live longer than the last call to 'doWork' this was done to improve performance based on profiling
Definition at line 12 of file Worker.cc.
References art::Worker::actReg_.
Referenced by art::Worker::descPtr().
|
inlineinherited |
Definition at line 119 of file Worker.h.
References art::Worker::modifiesEvent(), and art::Worker::state_.
|
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().