CMS 3D CMS Logo

List of all members | Public Types | Public Member Functions | Protected Member Functions | Private Member Functions | Private Attributes
edm::WorkerT< T > Class Template Reference

#include <Frameworkfwd.h>

Inheritance diagram for edm::WorkerT< T >:
edm::Worker

Public Types

typedef T ModuleType
 
typedef WorkerT< TWorkerType
 
- Public Types inherited from edm::Worker
enum  State { Ready, Pass, Fail, Exception }
 
enum  Types { kAnalyzer, kFilter, kProducer, kOutputModule }
 

Public Member Functions

template<typename D >
void callWorkerBeginStream (D, StreamID)
 
template<typename D >
void callWorkerEndStream (D, StreamID)
 
template<typename D >
void callWorkerStreamBegin (D, StreamID id, RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc)
 
template<typename D >
void callWorkerStreamBegin (D, StreamID id, LuminosityBlockPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc)
 
template<typename D >
void callWorkerStreamEnd (D, StreamID id, RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc)
 
template<typename D >
void callWorkerStreamEnd (D, StreamID id, LuminosityBlockPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc)
 
SerialTaskQueueglobalLuminosityBlocksQueue () final
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
SerialTaskQueueglobalRunsQueue () final
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
template<>
SerialTaskQueueglobalRunsQueue ()
 
Types moduleType () const override
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
template<>
Worker::Types moduleType () const
 
void resolvePutIndicies (BranchType iBranchType, std::unordered_multimap< std::string, std::tuple< TypeID const *, const char *, edm::ProductResolverIndex >> const &iIndicies) final
 
void setModule (std::shared_ptr< T > iModule)
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &) final
 
void updateLookup (eventsetup::ESRecordsToProxyIndices const &) final
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () const final
 
bool wantsStreamLuminosityBlocks () const final
 
bool wantsStreamRuns () const final
 
 WorkerT (std::shared_ptr< T >, ModuleDescription const &, ExceptionToActionTable const *actions)
 
 ~WorkerT () override
 
- Public Member Functions inherited from edm::Worker
void addedToPath ()
 
void beginJob ()
 
void beginStream (StreamID id, StreamContext &streamContext)
 
void callWhenDoneAsync (WaitingTask *task)
 
void clearCounters ()
 
ModuleDescription const * descPtr () const
 
ModuleDescription const & description () const
 
template<typename T >
bool doWork (typename T::MyPrincipal const &, EventSetupImpl const &c, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)
 
template<typename T >
void doWorkAsync (WaitingTask *task, typename T::MyPrincipal const &, EventSetupImpl const &c, ServiceToken const &token, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)
 
template<typename T >
void doWorkNoPrefetchingAsync (WaitingTask *task, typename T::MyPrincipal const &, EventSetupImpl const &c, ServiceToken const &token, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)
 
void endJob ()
 
void endStream (StreamID id, StreamContext &streamContext)
 
Workeroperator= (Worker const &)=delete
 
void postDoEvent (EventPrincipal const &)
 
void prePrefetchSelectionAsync (WaitingTask *task, ServiceToken const &, StreamID stream, EventPrincipal const *)
 
void prePrefetchSelectionAsync (WaitingTask *task, ServiceToken const &, StreamID stream, void const *)
 
void registerThinnedAssociations (ProductRegistry const &registry, ThinnedAssociationsHelper &helper)
 
void reset ()
 
void respondToCloseInputFile (FileBlock const &fb)
 
void respondToOpenInputFile (FileBlock const &fb)
 
template<typename T >
std::exception_ptr runModuleDirectly (typename T::MyPrincipal const &ep, EventSetupImpl const &es, StreamID streamID, ParentContext const &parentContext, typename T::Context const *context)
 
void setActivityRegistry (std::shared_ptr< ActivityRegistry > areg)
 
void setEarlyDeleteHelper (EarlyDeleteHelper *iHelper)
 
void skipOnPath ()
 
State state () const
 
int timesExcept () const
 
int timesFailed () const
 
int timesPass () const
 
int timesPassed () const
 
int timesRun () const
 
int timesVisited () const
 
 Worker (ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
 
 Worker (Worker const &)=delete
 
virtual ~Worker ()
 

Protected Member Functions

Tmodule ()
 
T const & module () const
 
- Protected Member Functions inherited from edm::Worker
ActivityRegistryactivityRegistry ()
 
void resetModuleDescription (ModuleDescription const *)
 

Private Member Functions

std::vector< ConsumesInfoconsumesInfo () const override
 
void convertCurrentProcessAlias (std::string const &processName) override
 
bool hasAccumulator () const override
 
bool hasAcquire () const override
 
void implBeginJob () override
 
void implBeginStream (StreamID) override
 
bool implDo (EventPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
void implDoAcquire (EventPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder) final
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
bool implDoBegin (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoBegin (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoEnd (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoEnd (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoPrePrefetchSelection (StreamID id, EventPrincipal const &ep, ModuleCallingContext const *mcc) override
 
template<>
bool implDoPrePrefetchSelection (StreamID id, EventPrincipal const &ep, ModuleCallingContext const *mcc)
 
template<>
bool implDoPrePrefetchSelection (StreamID id, EventPrincipal const &ep, ModuleCallingContext const *mcc)
 
template<>
bool implDoPrePrefetchSelection (StreamID id, EventPrincipal const &ep, ModuleCallingContext const *mcc)
 
template<>
bool implDoPrePrefetchSelection (StreamID id, EventPrincipal const &ep, ModuleCallingContext const *mcc)
 
bool implDoStreamBegin (StreamID id, RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoStreamBegin (StreamID id, LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoStreamEnd (StreamID id, RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
bool implDoStreamEnd (StreamID id, LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *mcc) override
 
void implEndJob () override
 
void implEndStream (StreamID) override
 
bool implNeedToRunSelection () const final
 
template<>
bool implNeedToRunSelection () const
 
template<>
bool implNeedToRunSelection () const
 
template<>
bool implNeedToRunSelection () const
 
template<>
bool implNeedToRunSelection () const
 
void implRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &) override
 
void implRespondToCloseInputFile (FileBlock const &fb) override
 
void implRespondToOpenInputFile (FileBlock const &fb) override
 
void itemsMayGet (BranchType branchType, std::vector< ProductResolverIndexAndSkipBit > &indexes) const override
 
std::vector< ProductResolverIndex > const & itemsShouldPutInEvent () const override
 
void itemsToGet (BranchType branchType, std::vector< ProductResolverIndexAndSkipBit > &indexes) const override
 
void itemsToGetForSelection (std::vector< ProductResolverIndexAndSkipBit > &) const final
 
template<>
void itemsToGetForSelection (std::vector< ProductResolverIndexAndSkipBit > &iItems) const
 
template<>
void itemsToGetForSelection (std::vector< ProductResolverIndexAndSkipBit > &iItems) const
 
template<>
void itemsToGetForSelection (std::vector< ProductResolverIndexAndSkipBit > &iItems) const
 
template<>
void itemsToGetForSelection (std::vector< ProductResolverIndexAndSkipBit > &iItems) const
 
std::vector< ProductResolverIndexAndSkipBit > const & itemsToGetFrom (BranchType iType) const final
 
void modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc) const override
 
void preActionBeforeRunEventAsync (WaitingTask *iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const override
 
TaskQueueAdaptor serializeRunModule () override
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
template<>
Worker::TaskQueueAdaptor serializeRunModule ()
 
std::string workerType () const override
 

Private Attributes

edm::propagate_const< std::shared_ptr< T > > module_
 

Detailed Description

template<typename T>
class edm::WorkerT< T >

Definition at line 52 of file Frameworkfwd.h.

Member Typedef Documentation

template<typename T>
typedef T edm::WorkerT< T >::ModuleType

Definition at line 33 of file WorkerT.h.

template<typename T>
typedef WorkerT<T> edm::WorkerT< T >::WorkerType

Definition at line 34 of file WorkerT.h.

Constructor & Destructor Documentation

template<typename T >
edm::WorkerT< T >::WorkerT ( std::shared_ptr< T ed,
ModuleDescription const &  md,
ExceptionToActionTable const *  actions 
)
inline

Definition at line 113 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

114  : Worker(md, actions), module_(ed) {
115  assert(module_ != nullptr);
116  }
roAction_t actions[nactions]
Definition: GenABIO.cc:181
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:83
template<typename T >
edm::WorkerT< T >::~WorkerT ( )
override

Definition at line 119 of file WorkerT.cc.

119 {}

Member Function Documentation

template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerBeginStream ( ,
StreamID  id 
)

Definition at line 465 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::workerimpl::DoBeginStream< T >::operator()(), and edm::WorkerT< T >::setModule().

465  {
466  module_->doBeginStream(id);
467  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerEndStream ( ,
StreamID  id 
)

Definition at line 478 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::workerimpl::DoEndStream< T >::operator()(), and edm::WorkerT< T >::setModule().

478  {
479  module_->doEndStream(id);
480  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamBegin ( ,
StreamID  id,
RunPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 347 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::workerimpl::DoStreamBeginTrans< T, P >::operator()(), and edm::WorkerT< T >::setModule().

348  {
349  module_->doStreamBeginRun(id, rp, c, mcc);
350  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamBegin ( ,
StreamID  id,
LuminosityBlockPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 401 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

402  {
403  module_->doStreamBeginLuminosityBlock(id, rp, c, mcc);
404  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamEnd ( ,
StreamID  id,
RunPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 354 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::workerimpl::DoStreamEndTrans< T, P >::operator()(), and edm::WorkerT< T >::setModule().

355  {
356  module_->doStreamEndRun(id, rp, c, mcc);
357  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamEnd ( ,
StreamID  id,
LuminosityBlockPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 408 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

409  {
410  module_->doStreamEndLuminosityBlock(id, rp, c, mcc);
411  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
std::vector<ConsumesInfo> edm::WorkerT< T >::consumesInfo ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 139 of file WorkerT.h.

References edm::WorkerT< T >::module_.

139 { return module_->consumesInfo(); }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
void edm::WorkerT< T >::convertCurrentProcessAlias ( std::string const &  processName)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 135 of file WorkerT.h.

References edm::WorkerT< T >::module_.

135  {
136  module_->convertCurrentProcessAlias(processName);
137  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
SerialTaskQueue * edm::WorkerT< T >::globalLuminosityBlocksQueue ( )
finalvirtual
template<>
SerialTaskQueue * edm::WorkerT< EDProducer >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 154 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

154  {
155  return module_->globalLuminosityBlocksQueue();
156  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< EDFilter >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 162 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

162  {
163  return module_->globalLuminosityBlocksQueue();
164  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< EDAnalyzer >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 170 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

170  {
171  return module_->globalLuminosityBlocksQueue();
172  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< OutputModule >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 178 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

178  {
179  return module_->globalLuminosityBlocksQueue();
180  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::EDProducerBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 187 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

187  {
188  return module_->globalLuminosityBlocksQueue();
189  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::EDFilterBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 195 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

195  {
196  return module_->globalLuminosityBlocksQueue();
197  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::EDAnalyzerBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 203 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

203  {
204  return module_->globalLuminosityBlocksQueue();
205  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::OutputModuleBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 211 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

211  {
212  return module_->globalLuminosityBlocksQueue();
213  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
SerialTaskQueue * edm::WorkerT< T >::globalRunsQueue ( )
finalvirtual
template<>
SerialTaskQueue * edm::WorkerT< EDProducer >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 150 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

150  {
151  return module_->globalRunsQueue();
152  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< EDFilter >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 158 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

158  {
159  return module_->globalRunsQueue();
160  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< EDAnalyzer >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 166 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

166  {
167  return module_->globalRunsQueue();
168  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< OutputModule >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 174 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

174  {
175  return module_->globalRunsQueue();
176  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::EDProducerBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 183 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

183  {
184  return module_->globalRunsQueue();
185  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::EDFilterBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 191 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

191  {
192  return module_->globalRunsQueue();
193  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::EDAnalyzerBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 199 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

199  {
200  return module_->globalRunsQueue();
201  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
SerialTaskQueue * edm::WorkerT< one::OutputModuleBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 207 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

207  {
208  return module_->globalRunsQueue();
209  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
bool edm::WorkerT< T >::hasAccumulator ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 163 of file WorkerT.h.

References edm::WorkerT< T >::module_.

163 { return module_->hasAccumulator(); }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
bool edm::WorkerT< T >::hasAcquire ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 161 of file WorkerT.h.

References edm::WorkerT< T >::module_.

161 { return module_->hasAcquire(); }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
void edm::WorkerT< T >::implBeginJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 454 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

454  {
455  module_->doBeginJob();
456  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
void edm::WorkerT< T >::implBeginStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 470 of file WorkerT.cc.

References relativeConstraints::value.

Referenced by edm::WorkerT< T >::module().

470  {
471  std::conditional_t<workerimpl::has_stream_functions<T>::value, workerimpl::DoBeginStream<T>, workerimpl::DoNothing>
472  might_call;
473  might_call(this, id);
474  }
template<typename T >
bool edm::WorkerT< T >::implDo ( EventPrincipal const &  ep,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 216 of file WorkerT.cc.

References edm::Worker::activityRegistry(), edm::WorkerT< T >::module_, haddnano::obj, and edm::Worker::postDoEvent().

Referenced by edm::WorkerT< T >::module().

216  {
217  std::shared_ptr<Worker> sentry(this, [&ep](Worker* obj) { obj->postDoEvent(ep); });
218  return module_->doEvent(ep, c, activityRegistry(), mcc);
219  }
ActivityRegistry * activityRegistry()
Definition: Worker.h:284
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:83
template<typename T >
void edm::WorkerT< T >::implDoAcquire ( EventPrincipal const &  ep,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder holder 
)
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 222 of file WorkerT.cc.

Referenced by edm::WorkerT< T >::module().

225  {}
template<>
void edm::WorkerT< global::EDProducerBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 228 of file WorkerT.cc.

References edm::Worker::activityRegistry(), and edm::WorkerT< T >::module_.

231  {
232  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
233  }
ActivityRegistry * activityRegistry()
Definition: Worker.h:284
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
void edm::WorkerT< global::EDFilterBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 236 of file WorkerT.cc.

References edm::Worker::activityRegistry(), and edm::WorkerT< T >::module_.

239  {
240  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
241  }
ActivityRegistry * activityRegistry()
Definition: Worker.h:284
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
void edm::WorkerT< stream::EDProducerAdaptorBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 244 of file WorkerT.cc.

References edm::Worker::activityRegistry(), and edm::WorkerT< T >::module_.

247  {
248  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
249  }
ActivityRegistry * activityRegistry()
Definition: Worker.h:284
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
void edm::WorkerT< stream::EDFilterAdaptorBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 252 of file WorkerT.cc.

References edm::Worker::activityRegistry(), and edm::WorkerT< T >::module_.

255  {
256  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
257  }
ActivityRegistry * activityRegistry()
Definition: Worker.h:284
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::implDoBegin ( RunPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 338 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

340  {
341  module_->doBeginRun(rp, c, mcc);
342  return true;
343  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::implDoBegin ( LuminosityBlockPrincipal const &  lbp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 392 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

394  {
395  module_->doBeginLuminosityBlock(lbp, c, mcc);
396  return true;
397  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::implDoEnd ( RunPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 386 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

386  {
387  module_->doEndRun(rp, c, mcc);
388  return true;
389  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::implDoEnd ( LuminosityBlockPrincipal const &  lbp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 441 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

443  {
444  module_->doEndLuminosityBlock(lbp, c, mcc);
445  return true;
446  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 265 of file WorkerT.cc.

Referenced by edm::WorkerT< T >::module().

267  {
268  return true;
269  }
template<>
bool edm::WorkerT< OutputModule >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 278 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

280  {
281  return module_->prePrefetchSelection(id, ep, mcc);
282  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
bool edm::WorkerT< edm::one::OutputModuleBase >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 294 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

296  {
297  return module_->prePrefetchSelection(id, ep, mcc);
298  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
bool edm::WorkerT< edm::global::OutputModuleBase >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 310 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

312  {
313  return module_->prePrefetchSelection(id, ep, mcc);
314  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
bool edm::WorkerT< edm::limited::OutputModuleBase >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 326 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

328  {
329  return module_->prePrefetchSelection(id, ep, mcc);
330  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::implDoStreamBegin ( StreamID  id,
RunPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 360 of file WorkerT.cc.

References relativeConstraints::value.

Referenced by edm::WorkerT< T >::module().

363  {
365  workerimpl::DoStreamBeginTrans<T, RunPrincipal const>,
366  workerimpl::DoNothing>
367  might_call;
368  might_call(this, id, rp, c, mcc);
369  return true;
370  }
template<typename T >
bool edm::WorkerT< T >::implDoStreamBegin ( StreamID  id,
LuminosityBlockPrincipal const &  lbp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 414 of file WorkerT.cc.

References relativeConstraints::value.

417  {
419  workerimpl::DoStreamBeginTrans<T, LuminosityBlockPrincipal>,
420  workerimpl::DoNothing>
421  might_call;
422  might_call(this, id, lbp, c, mcc);
423  return true;
424  }
template<typename T >
bool edm::WorkerT< T >::implDoStreamEnd ( StreamID  id,
RunPrincipal const &  rp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 373 of file WorkerT.cc.

References relativeConstraints::value.

Referenced by edm::WorkerT< T >::module().

376  {
378  workerimpl::DoStreamEndTrans<T, RunPrincipal const>,
379  workerimpl::DoNothing>
380  might_call;
381  might_call(this, id, rp, c, mcc);
382  return true;
383  }
template<typename T >
bool edm::WorkerT< T >::implDoStreamEnd ( StreamID  id,
LuminosityBlockPrincipal const &  lbp,
EventSetupImpl const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 427 of file WorkerT.cc.

References relativeConstraints::value.

430  {
432  workerimpl::DoStreamEndTrans<T, LuminosityBlockPrincipal>,
433  workerimpl::DoNothing>
434  might_call;
435  might_call(this, id, lbp, c, mcc);
436 
437  return true;
438  }
template<typename T >
void edm::WorkerT< T >::implEndJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 459 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

459  {
460  module_->doEndJob();
461  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
void edm::WorkerT< T >::implEndStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 483 of file WorkerT.cc.

References relativeConstraints::value.

Referenced by edm::WorkerT< T >::module().

483  {
484  std::conditional_t<workerimpl::has_stream_functions<T>::value, workerimpl::DoEndStream<T>, workerimpl::DoNothing>
485  might_call;
486  might_call(this, id);
487  }
template<typename T >
bool edm::WorkerT< T >::implNeedToRunSelection ( ) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 260 of file WorkerT.cc.

Referenced by edm::WorkerT< T >::module().

260  {
261  return false;
262  }
template<>
bool edm::WorkerT< OutputModule >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 274 of file WorkerT.cc.

274  {
275  return true;
276  }
template<>
bool edm::WorkerT< edm::one::OutputModuleBase >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 289 of file WorkerT.cc.

289  {
290  return true;
291  }
template<>
bool edm::WorkerT< edm::global::OutputModuleBase >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 306 of file WorkerT.cc.

306  {
307  return true;
308  }
template<>
bool edm::WorkerT< edm::limited::OutputModuleBase >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 322 of file WorkerT.cc.

322  {
323  return true;
324  }
template<typename T >
void edm::WorkerT< T >::implRegisterThinnedAssociations ( ProductRegistry const &  registry,
ThinnedAssociationsHelper helper 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 500 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

501  {
502  module_->doRegisterThinnedAssociations(registry, helper);
503  }
Definition: helper.py:1
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
static Interceptor::Registry registry("Interceptor")
template<typename T >
void edm::WorkerT< T >::implRespondToCloseInputFile ( FileBlock const &  fb)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 495 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

495  {
496  module_->doRespondToCloseInputFile(fb);
497  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
void edm::WorkerT< T >::implRespondToOpenInputFile ( FileBlock const &  fb)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 490 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

490  {
491  module_->doRespondToOpenInputFile(fb);
492  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
void edm::WorkerT< T >::itemsMayGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 145 of file WorkerT.h.

References edm::WorkerT< T >::module_.

145  {
146  module_->itemsMayGet(branchType, indexes);
147  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
def branchType(schema, name)
Definition: revisionDML.py:114
template<typename T >
std::vector< ProductResolverIndex > const & edm::WorkerT< T >::itemsShouldPutInEvent ( ) const
overrideprivatevirtual

Implements edm::Worker.

Definition at line 712 of file WorkerT.cc.

References edm::WorkerT< T >::module().

Referenced by edm::WorkerT< T >::itemsToGetFrom().

712  {
713  return itemsShouldPutInEventImpl(&module());
714  }
T & module()
Definition: WorkerT.h:79
template<typename T>
void edm::WorkerT< T >::itemsToGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 141 of file WorkerT.h.

References edm::WorkerT< T >::module_.

141  {
142  module_->itemsToGet(branchType, indexes);
143  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
def branchType(schema, name)
Definition: revisionDML.py:114
template<typename T >
void edm::WorkerT< T >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  ) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 271 of file WorkerT.cc.

Referenced by edm::WorkerT< T >::module().

271 {}
template<>
void edm::WorkerT< OutputModule >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 284 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

284  {
285  iItems = module_->productsUsedBySelection();
286  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
void edm::WorkerT< edm::one::OutputModuleBase >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 300 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

301  {
302  iItems = module_->productsUsedBySelection();
303  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
void edm::WorkerT< edm::global::OutputModuleBase >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 316 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

317  {
318  iItems = module_->productsUsedBySelection();
319  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
void edm::WorkerT< edm::limited::OutputModuleBase >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 332 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

333  {
334  iItems = module_->productsUsedBySelection();
335  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
std::vector<ProductResolverIndexAndSkipBit> const& edm::WorkerT< T >::itemsToGetFrom ( BranchType  iType) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 149 of file WorkerT.h.

References edm::WorkerT< T >::itemsShouldPutInEvent(), and edm::WorkerT< T >::module_.

149  {
150  return module_->itemsToGetFrom(iType);
151  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
T& edm::WorkerT< T >::module ( )
inlineprotected

Definition at line 79 of file WorkerT.h.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::itemsShouldPutInEvent(), and edm::WorkerT< T >::resolvePutIndicies().

79 { return *module_; }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
T const& edm::WorkerT< T >::module ( ) const
inlineprotected
template<typename T>
void edm::WorkerT< T >::modulesWhoseProductsAreConsumed ( std::vector< ModuleDescription const * > &  modules,
ProductRegistry const &  preg,
std::map< std::string, ModuleDescription const * > const &  labelsToDesc 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 128 of file WorkerT.h.

References edm::WorkerT< T >::module_.

131  {
132  module_->modulesWhoseProductsAreConsumed(modules, preg, labelsToDesc, module_->moduleDescription().processName());
133  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
Types edm::WorkerT< T >::moduleType ( ) const
overridevirtual

Implements edm::Worker.

Referenced by edm::WorkerT< T >::setModule().

template<>
Worker::Types edm::WorkerT< EDAnalyzer >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 717 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

717  {
718  return Worker::kAnalyzer;
719  }
template<>
Worker::Types edm::WorkerT< EDProducer >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 721 of file WorkerT.cc.

References edm::Worker::kProducer.

721  {
722  return Worker::kProducer;
723  }
template<>
Worker::Types edm::WorkerT< EDFilter >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 725 of file WorkerT.cc.

References edm::Worker::kFilter.

725  {
726  return Worker::kFilter;
727  }
template<>
Worker::Types edm::WorkerT< OutputModule >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 729 of file WorkerT.cc.

References edm::Worker::kOutputModule.

729  {
730  return Worker::kOutputModule;
731  }
template<>
Worker::Types edm::WorkerT< edm::one::EDProducerBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 733 of file WorkerT.cc.

References edm::Worker::kProducer.

733  {
734  return Worker::kProducer;
735  }
template<>
Worker::Types edm::WorkerT< edm::one::EDFilterBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 737 of file WorkerT.cc.

References edm::Worker::kFilter.

737  {
738  return Worker::kFilter;
739  }
template<>
Worker::Types edm::WorkerT< edm::one::EDAnalyzerBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 741 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

741  {
742  return Worker::kAnalyzer;
743  }
template<>
Worker::Types edm::WorkerT< edm::one::OutputModuleBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 745 of file WorkerT.cc.

References edm::Worker::kOutputModule.

745  {
746  return Worker::kOutputModule;
747  }
template<>
Worker::Types edm::WorkerT< edm::global::EDProducerBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 750 of file WorkerT.cc.

References edm::Worker::kProducer.

750  {
751  return Worker::kProducer;
752  }
template<>
Worker::Types edm::WorkerT< edm::global::EDFilterBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 754 of file WorkerT.cc.

References edm::Worker::kFilter.

754  {
755  return Worker::kFilter;
756  }
template<>
Worker::Types edm::WorkerT< edm::global::EDAnalyzerBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 758 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

758  {
759  return Worker::kAnalyzer;
760  }
template<>
Worker::Types edm::WorkerT< edm::global::OutputModuleBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 762 of file WorkerT.cc.

References edm::Worker::kOutputModule.

762  {
763  return Worker::kOutputModule;
764  }
template<>
Worker::Types edm::WorkerT< edm::limited::EDProducerBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 767 of file WorkerT.cc.

References edm::Worker::kProducer.

767  {
768  return Worker::kProducer;
769  }
template<>
Worker::Types edm::WorkerT< edm::limited::EDFilterBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 771 of file WorkerT.cc.

References edm::Worker::kFilter.

771  {
772  return Worker::kFilter;
773  }
template<>
Worker::Types edm::WorkerT< edm::limited::EDAnalyzerBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 775 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

775  {
776  return Worker::kAnalyzer;
777  }
template<>
Worker::Types edm::WorkerT< edm::limited::OutputModuleBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 779 of file WorkerT.cc.

References edm::Worker::kOutputModule.

779  {
780  return Worker::kOutputModule;
781  }
template<>
Worker::Types edm::WorkerT< edm::stream::EDProducerAdaptorBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 784 of file WorkerT.cc.

References edm::Worker::kProducer.

784  {
785  return Worker::kProducer;
786  }
template<>
Worker::Types edm::WorkerT< edm::stream::EDFilterAdaptorBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 788 of file WorkerT.cc.

References edm::Worker::kFilter.

788  {
789  return Worker::kFilter;
790  }
template<>
Worker::Types edm::WorkerT< edm::stream::EDAnalyzerAdaptorBase >::moduleType ( ) const
virtual

Implements edm::Worker.

Definition at line 792 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

792  {
793  return Worker::kAnalyzer;
794  }
template<typename T>
void edm::WorkerT< T >::preActionBeforeRunEventAsync ( WaitingTask iTask,
ModuleCallingContext const &  iModuleCallingContext,
Principal const &  iPrincipal 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 155 of file WorkerT.h.

References edm::WorkerT< T >::module_.

157  {
158  module_->preActionBeforeRunEventAsync(iTask, iModuleCallingContext, iPrincipal);
159  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
void edm::WorkerT< T >::resolvePutIndicies ( BranchType  iBranchType,
std::unordered_multimap< std::string, std::tuple< TypeID const *, const char *, edm::ProductResolverIndex >> const &  iIndicies 
)
finalvirtual

Implements edm::Worker.

Definition at line 704 of file WorkerT.cc.

References edm::Worker::description(), and edm::WorkerT< T >::module().

Referenced by edm::WorkerT< T >::setModule().

707  {
708  resolvePutIndiciesImpl(&module(), iBranchType, iIndicies, description().moduleLabel());
709  }
ModuleDescription const & description() const
Definition: Worker.h:190
T & module()
Definition: WorkerT.h:79
template<typename T >
Worker::TaskQueueAdaptor edm::WorkerT< T >::serializeRunModule ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 506 of file WorkerT.cc.

Referenced by edm::WorkerT< T >::module().

506  {
507  return Worker::TaskQueueAdaptor{};
508  }
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDAnalyzer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 510 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

510  {
511  return &(module_->sharedResourcesAcquirer().serialQueueChain());
512  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDFilter >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 514 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

514  {
515  return &(module_->sharedResourcesAcquirer().serialQueueChain());
516  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDProducer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 518 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

518  {
519  return &(module_->sharedResourcesAcquirer().serialQueueChain());
520  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< OutputModule >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 522 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

522  {
523  return &(module_->sharedResourcesAcquirer().serialQueueChain());
524  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 526 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

526  {
527  return &(module_->sharedResourcesAcquirer().serialQueueChain());
528  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 530 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

530  {
531  return &(module_->sharedResourcesAcquirer().serialQueueChain());
532  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 534 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

534  {
535  return &(module_->sharedResourcesAcquirer().serialQueueChain());
536  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 538 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

538  {
539  return &(module_->sharedResourcesAcquirer().serialQueueChain());
540  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 542 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

542  {
543  return &(module_->queue());
544  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 546 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

546  {
547  return &(module_->queue());
548  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 550 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

550  {
551  return &(module_->queue());
552  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 554 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

554  {
555  return &(module_->queue());
556  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T>
void edm::WorkerT< T >::setModule ( std::shared_ptr< T iModule)
inline
template<typename T >
void edm::WorkerT< T >::updateLookup ( BranchType  iBranchType,
ProductResolverIndexHelper const &  iHelper 
)
finalvirtual

Implements edm::Worker.

Definition at line 646 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::setModule().

646  {
647  module_->updateLookup(iBranchType, iHelper, mustPrefetchMayGet<T>());
648  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
void edm::WorkerT< T >::updateLookup ( eventsetup::ESRecordsToProxyIndices const &  iPI)
finalvirtual
template<typename T >
bool edm::WorkerT< T >::wantsGlobalLuminosityBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 127 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::one::EDFilterBase::moduleDescription(), edm::one::EDProducerBase::moduleDescription(), edm::limited::EDFilterBase::moduleDescription(), edm::global::EDFilterBase::moduleDescription(), and edm::WorkerT< T >::setModule().

127  {
128  return module_->wantsGlobalLuminosityBlocks();
129  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::wantsGlobalRuns ( ) const
finalvirtual
template<typename T >
bool edm::WorkerT< T >::wantsStreamLuminosityBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 137 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::global::EDFilterBase::moduleDescription(), edm::limited::EDFilterBase::moduleDescription(), and edm::WorkerT< T >::setModule().

137  {
138  return module_->wantsStreamLuminosityBlocks();
139  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
bool edm::WorkerT< T >::wantsStreamRuns ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 132 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::global::EDFilterBase::moduleDescription(), edm::limited::EDFilterBase::moduleDescription(), and edm::WorkerT< T >::setModule().

132  {
133  return module_->wantsStreamRuns();
134  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165
template<typename T >
std::string edm::WorkerT< T >::workerType ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 449 of file WorkerT.cc.

References edm::WorkerT< T >::module_.

Referenced by edm::WorkerT< T >::module().

449  {
450  return module_->workerType();
451  }
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:165

Member Data Documentation

template<typename T>
edm::propagate_const<std::shared_ptr<T> > edm::WorkerT< T >::module_
private

Definition at line 165 of file WorkerT.h.

Referenced by edm::WorkerT< T >::callWorkerBeginStream(), edm::WorkerT< T >::callWorkerEndStream(), edm::WorkerT< T >::callWorkerStreamBegin(), edm::WorkerT< T >::callWorkerStreamEnd(), edm::WorkerT< T >::consumesInfo(), edm::WorkerT< T >::convertCurrentProcessAlias(), edm::WorkerT< T >::globalLuminosityBlocksQueue(), edm::WorkerT< T >::globalRunsQueue(), edm::WorkerT< T >::hasAccumulator(), edm::WorkerT< T >::hasAcquire(), edm::WorkerT< T >::implBeginJob(), edm::WorkerT< T >::implDo(), edm::WorkerT< T >::implDoAcquire(), edm::WorkerT< T >::implDoBegin(), edm::WorkerT< T >::implDoEnd(), edm::WorkerT< T >::implDoPrePrefetchSelection(), edm::WorkerT< T >::implEndJob(), edm::WorkerT< T >::implRegisterThinnedAssociations(), edm::WorkerT< T >::implRespondToCloseInputFile(), edm::WorkerT< T >::implRespondToOpenInputFile(), edm::WorkerT< T >::itemsMayGet(), edm::WorkerT< T >::itemsToGet(), edm::WorkerT< T >::itemsToGetForSelection(), edm::WorkerT< T >::itemsToGetFrom(), edm::WorkerT< T >::module(), edm::WorkerT< T >::modulesWhoseProductsAreConsumed(), edm::WorkerT< T >::preActionBeforeRunEventAsync(), edm::WorkerT< T >::serializeRunModule(), edm::WorkerT< T >::setModule(), edm::WorkerT< T >::updateLookup(), edm::WorkerT< T >::wantsGlobalLuminosityBlocks(), edm::WorkerT< T >::wantsGlobalRuns(), edm::WorkerT< T >::wantsStreamLuminosityBlocks(), edm::WorkerT< T >::wantsStreamRuns(), edm::WorkerT< T >::WorkerT(), and edm::WorkerT< T >::workerType().