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< T > WorkerType
 
- 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, EventSetup const &c, ModuleCallingContext const *mcc)
 
template<typename D >
void callWorkerStreamBegin (D, StreamID id, LuminosityBlockPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc)
 
template<typename D >
void callWorkerStreamEnd (D, StreamID id, RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc)
 
template<typename D >
void callWorkerStreamEnd (D, StreamID id, LuminosityBlockPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc)
 
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) override
 
void setModule (std::shared_ptr< T > iModule)
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &) override
 
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 &, EventSetup const &c, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)
 
template<typename T >
void doWorkAsync (WaitingTask *task, typename T::MyPrincipal const &, EventSetup const &c, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)
 
template<typename T >
void doWorkNoPrefetchingAsync (WaitingTask *task, typename T::MyPrincipal const &, EventSetup const &c, StreamID stream, ParentContext const &parentContext, typename T::Context const *context)
 
void endJob ()
 
void endStream (StreamID id, StreamContext &streamContext)
 
Worker & operator= (Worker const &)=delete
 
void postDoEvent (EventPrincipal const &)
 
void prePrefetchSelectionAsync (WaitingTask *task, StreamID stream, EventPrincipal const *)
 
void prePrefetchSelectionAsync (WaitingTask *task, 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, EventSetup 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

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

Private Member Functions

std::vector< ConsumesInfo > consumesInfo () const override
 
void convertCurrentProcessAlias (std::string const &processName) override
 
bool hasAcquire () const override
 
void implBeginJob () override
 
void implBeginStream (StreamID) override
 
bool implDo (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc) override
 
void implDoAcquire (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder) final
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
bool implDoBegin (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
bool implDoBegin (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
bool implDoEnd (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
bool implDoEnd (LuminosityBlockPrincipal const &lbp, EventSetup 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, EventSetup const &c, ModuleCallingContext const *mcc) override
 
bool implDoStreamBegin (StreamID id, LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
bool implDoStreamEnd (StreamID id, RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
bool implDoStreamEnd (StreamID id, LuminosityBlockPrincipal const &lbp, EventSetup 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 49 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 120 of file WorkerT.cc.

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

120  :
121  Worker(md, actions),
122  module_(ed) {
123  assert(module_ != nullptr);
124  }
actions
roAction_t actions[nactions]
Definition: GenABIO.cc:187
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:73
template<typename T >
edm::WorkerT< T >::~WorkerT ( )
override

Definition at line 127 of file WorkerT.cc.

127  {
128  }

Member Function Documentation

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

Definition at line 444 of file WorkerT.cc.

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

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

444  {
445  module_->doBeginStream(id);
446  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerEndStream ( D  ,
StreamID  id 
)

Definition at line 460 of file WorkerT.cc.

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

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

460  {
461  module_->doEndStream(id);
462  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamBegin ( D  ,
StreamID  id,
RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 310 of file WorkerT.cc.

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

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

312  {
313  module_->doStreamBeginRun(id, rp, c, mcc);
314  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamBegin ( D  ,
StreamID  id,
LuminosityBlockPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 371 of file WorkerT.cc.

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

373  {
374  module_->doStreamBeginLuminosityBlock(id, rp, c, mcc);
375  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamEnd ( D  ,
StreamID  id,
RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 319 of file WorkerT.cc.

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

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

321  {
322  module_->doStreamEndRun(id, rp, c, mcc);
323  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamEnd ( D  ,
StreamID  id,
LuminosityBlockPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)

Definition at line 380 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 135 of file WorkerT.h.

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

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

Implements edm::Worker.

Definition at line 131 of file WorkerT.h.

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

131  {
132  module_->convertCurrentProcessAlias(processName);
133  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
modifiedElectrons_cfi.processName
processName
Definition: modifiedElectrons_cfi.py:5
template<typename T>
bool edm::WorkerT< T >::hasAcquire ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 155 of file WorkerT.h.

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

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

Implements edm::Worker.

Definition at line 431 of file WorkerT.cc.

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

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

431  {
432  module_->doBeginJob();
433  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
void edm::WorkerT< T >::implBeginStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 451 of file WorkerT.cc.

References relativeConstraints::value.

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

451  {
452  std::conditional_t<workerimpl::has_stream_functions<T>::value,
453  workerimpl::DoBeginStream<T>,
454  workerimpl::DoNothing> might_call;
455  might_call(this,id);
456  }
template<typename T >
bool edm::WorkerT< T >::implDo ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 154 of file WorkerT.cc.

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

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

154  {
155  std::shared_ptr<Worker> sentry(this,[&ep](Worker* obj) {obj->postDoEvent(ep);});
156  return module_->doEvent(ep, c, activityRegistry(), mcc);
157  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:266
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:73
GetRecoTauVFromDQM_MC_cff.obj
obj
Definition: GetRecoTauVFromDQM_MC_cff.py:87
template<typename T >
void edm::WorkerT< T >::implDoAcquire ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 162 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 170 of file WorkerT.cc.

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

172  {
173  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
174  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:266
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
void edm::WorkerT< global::EDFilterBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 179 of file WorkerT.cc.

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

181  {
182  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
183  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:266
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
void edm::WorkerT< stream::EDProducerAdaptorBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 188 of file WorkerT.cc.

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

190  {
191  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
192  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:266
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
void edm::WorkerT< stream::EDFilterAdaptorBase >::implDoAcquire ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 197 of file WorkerT.cc.

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

199  {
200  module_->doAcquire(ep, c, activityRegistry(), mcc, holder);
201  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:266
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::implDoBegin ( RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 302 of file WorkerT.cc.

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

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

302  {
303  module_->doBeginRun(rp, c, mcc);
304  return true;
305  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::implDoBegin ( LuminosityBlockPrincipal const &  lbp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 362 of file WorkerT.cc.

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

363  {
364  module_->doBeginLuminosityBlock(lbp, c, mcc);
365  return true;
366  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::implDoEnd ( RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 353 of file WorkerT.cc.

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

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

354  {
355  module_->doEndRun(rp, c, mcc);
356  return true;
357  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::implDoEnd ( LuminosityBlockPrincipal const &  lbp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 415 of file WorkerT.cc.

References edm::WorkerT< T >::module_, and AlCaHLTBitMon_QueryRunRegistry::string.

416  {
417  module_->doEndLuminosityBlock(lbp, c, mcc);
418  return true;
419  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 211 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 229 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 249 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 268 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 287 of file WorkerT.cc.

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

289  {
290  return module_->prePrefetchSelection(id,ep,mcc);
291  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::implDoStreamBegin ( StreamID  id,
RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 329 of file WorkerT.cc.

References relativeConstraints::value.

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

330  {
331  std::conditional_t<workerimpl::has_stream_functions<T>::value,
332  workerimpl::DoStreamBeginTrans<T,RunPrincipal const>,
333  workerimpl::DoNothing> might_call;
334  might_call(this,id,rp,c, mcc);
335  return true;
336  }
template<typename T >
bool edm::WorkerT< T >::implDoStreamBegin ( StreamID  id,
LuminosityBlockPrincipal const &  lbp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 390 of file WorkerT.cc.

References relativeConstraints::value.

391  {
392  std::conditional_t<workerimpl::has_stream_functions<T>::value,
393  workerimpl::DoStreamBeginTrans<T,LuminosityBlockPrincipal>,
394  workerimpl::DoNothing> might_call;
395  might_call(this,id,lbp,c, mcc);
396  return true;
397  }
template<typename T >
bool edm::WorkerT< T >::implDoStreamEnd ( StreamID  id,
RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 341 of file WorkerT.cc.

References relativeConstraints::value.

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

342  {
343  std::conditional_t<workerimpl::has_stream_functions<T>::value,
344  workerimpl::DoStreamEndTrans<T,RunPrincipal const>,
345  workerimpl::DoNothing> might_call;
346  might_call(this,id,rp,c, mcc);
347  return true;
348  }
template<typename T >
bool edm::WorkerT< T >::implDoStreamEnd ( StreamID  id,
LuminosityBlockPrincipal const &  lbp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 402 of file WorkerT.cc.

References relativeConstraints::value.

403  {
404  std::conditional_t<workerimpl::has_stream_functions<T>::value,
405  workerimpl::DoStreamEndTrans<T,LuminosityBlockPrincipal>,
406  workerimpl::DoNothing> might_call;
407  might_call(this,id,lbp,c,mcc);
408 
409  return true;
410  }
template<typename T >
void edm::WorkerT< T >::implEndJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 438 of file WorkerT.cc.

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

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

438  {
439  module_->doEndJob();
440  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
void edm::WorkerT< T >::implEndStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 467 of file WorkerT.cc.

References relativeConstraints::value.

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

467  {
468  std::conditional_t<workerimpl::has_stream_functions<T>::value,
469  workerimpl::DoEndStream<T>,
470  workerimpl::DoNothing> might_call;
471  might_call(this,id);
472  }
template<typename T >
bool edm::WorkerT< T >::implNeedToRunSelection ( ) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 206 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 225 of file WorkerT.cc.

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

Implements edm::Worker.

Definition at line 244 of file WorkerT.cc.

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

Implements edm::Worker.

Definition at line 264 of file WorkerT.cc.

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

Implements edm::Worker.

Definition at line 283 of file WorkerT.cc.

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

Implements edm::Worker.

Definition at line 491 of file WorkerT.cc.

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

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

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

Implements edm::Worker.

Definition at line 484 of file WorkerT.cc.

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

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

484  {
485  module_->doRespondToCloseInputFile(fb);
486  }
benchmark_cfg.fb
fb
Definition: benchmark_cfg.py:14
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
void edm::WorkerT< T >::implRespondToOpenInputFile ( FileBlock const &  fb)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 477 of file WorkerT.cc.

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

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

477  {
478  module_->doRespondToOpenInputFile(fb);
479  }
benchmark_cfg.fb
fb
Definition: benchmark_cfg.py:14
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T>
void edm::WorkerT< T >::itemsMayGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 143 of file WorkerT.h.

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

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

Implements edm::Worker.

Definition at line 635 of file WorkerT.cc.

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

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

635  {
636  return itemsShouldPutInEventImpl(&module());
637  }
edm::WorkerT::module
T & module()
Definition: WorkerT.h:81
template<typename T>
void edm::WorkerT< T >::itemsToGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 139 of file WorkerT.h.

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

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

Implements edm::Worker.

Definition at line 219 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 237 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 257 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 276 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 295 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 147 of file WorkerT.h.

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

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

Definition at line 81 of file WorkerT.h.

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

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

81 {return *module_;}
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T>
T const& edm::WorkerT< T >::module ( ) const
inlineprotected

Definition at line 82 of file WorkerT.h.

References benchmark_cfg::fb, edm::WorkerT< T >::implBeginJob(), edm::WorkerT< T >::implBeginStream(), edm::WorkerT< T >::implDo(), edm::WorkerT< T >::implDoAcquire(), edm::WorkerT< T >::implDoBegin(), edm::WorkerT< T >::implDoEnd(), edm::WorkerT< T >::implDoPrePrefetchSelection(), edm::WorkerT< T >::implDoStreamBegin(), edm::WorkerT< T >::implDoStreamEnd(), edm::WorkerT< T >::implEndJob(), edm::WorkerT< T >::implEndStream(), edm::WorkerT< T >::implNeedToRunSelection(), edm::WorkerT< T >::implRegisterThinnedAssociations(), edm::WorkerT< T >::implRespondToCloseInputFile(), edm::WorkerT< T >::implRespondToOpenInputFile(), edm::WorkerT< T >::itemsToGetForSelection(), edm::WorkerT< T >::module_, edm::WorkerT< T >::serializeRunModule(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::WorkerT< T >::workerType().

82 {return *module_;}
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
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 125 of file WorkerT.h.

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

127  {
128  module_->modulesWhoseProductsAreConsumed(modules, preg, labelsToDesc, module_->moduleDescription().processName());
129  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
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 641 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 643 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 645 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 647 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 649 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 651 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 653 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 655 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 658 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 660 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 662 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 664 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 667 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 669 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 671 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 673 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 677 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 679 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 681 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 151 of file WorkerT.h.

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

151  {
152  module_->preActionBeforeRunEventAsync(iTask,iModuleCallingContext,iPrincipal);
153  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
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 
)
overridevirtual

Implements edm::Worker.

Definition at line 626 of file WorkerT.cc.

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

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

628  {
629  resolvePutIndiciesImpl(&module(), iBranchType,iIndicies, description().moduleLabel());
630  }
edm::Worker::description
ModuleDescription const & description() const
Definition: Worker.h:182
edm::WorkerT::module
T & module()
Definition: WorkerT.h:81
template<typename T >
Worker::TaskQueueAdaptor edm::WorkerT< T >::serializeRunModule ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 498 of file WorkerT.cc.

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

498  {
499  return Worker::TaskQueueAdaptor{};
500  }
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDAnalyzer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 501 of file WorkerT.cc.

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

501  {
502  return &(module_->sharedResourcesAcquirer().serialQueueChain());
503  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDFilter >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 504 of file WorkerT.cc.

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

504  {
505  return &(module_->sharedResourcesAcquirer().serialQueueChain());
506  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDProducer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 507 of file WorkerT.cc.

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

507  {
508  return &(module_->sharedResourcesAcquirer().serialQueueChain());
509  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< OutputModule >::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::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 513 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 516 of file WorkerT.cc.

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

516  {
517  return &(module_->sharedResourcesAcquirer().serialQueueChain());
518  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 519 of file WorkerT.cc.

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

519  {
520  return &(module_->sharedResourcesAcquirer().serialQueueChain());
521  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::OutputModuleBase >::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::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 525 of file WorkerT.cc.

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

525  {
526  return &(module_->queue());
527  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 528 of file WorkerT.cc.

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

528  {
529  return &(module_->queue());
530  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 531 of file WorkerT.cc.

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

531  {
532  return &(module_->queue());
533  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 534 of file WorkerT.cc.

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

534  {
535  return &(module_->queue());
536  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T>
void edm::WorkerT< T >::setModule ( std::shared_ptr< T >  iModule)
inline

Definition at line 41 of file WorkerT.h.

References EnergyCorrector::c, edm::WorkerT< T >::callWorkerBeginStream(), edm::WorkerT< T >::callWorkerEndStream(), edm::WorkerT< T >::callWorkerStreamBegin(), edm::WorkerT< T >::callWorkerStreamEnd(), edm::WorkerT< T >::module_, edm::WorkerT< T >::moduleType(), edm::Worker::resetModuleDescription(), edm::WorkerT< T >::resolvePutIndicies(), AlCaHLTBitMon_QueryRunRegistry::string, edm::WorkerT< T >::updateLookup(), edm::WorkerT< T >::wantsGlobalLuminosityBlocks(), edm::WorkerT< T >::wantsGlobalRuns(), edm::WorkerT< T >::wantsStreamLuminosityBlocks(), and edm::WorkerT< T >::wantsStreamRuns().

41  {
42  module_ = iModule;
43  resetModuleDescription(&(module_->moduleDescription()));
44  }
edm::Worker::resetModuleDescription
void resetModuleDescription(ModuleDescription const *)
Definition: Worker.cc:285
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
void edm::WorkerT< T >::updateLookup ( BranchType  iBranchType,
ProductResolverIndexHelper const &  iHelper 
)
overridevirtual

Implements edm::Worker.

Definition at line 570 of file WorkerT.cc.

References edm::ProducerBase::indiciesForPutProducts(), edm::stream::ProducingModuleAdaptorBase< T >::indiciesForPutProducts(), edm::InEvent, edm::WorkerT< T >::module_, edm::ProducerBase::resolvePutIndicies(), edm::stream::ProducingModuleAdaptorBase< T >::resolvePutIndicies(), and AlCaHLTBitMon_QueryRunRegistry::string.

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

571  {
572  module_->updateLookup(iBranchType,iHelper,mustPrefetchMayGet<T>());
573  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::wantsGlobalLuminosityBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 137 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().

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

Implements edm::Worker.

Definition at line 132 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().

132  {
133  return module_->wantsGlobalRuns();
134  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::wantsStreamLuminosityBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 147 of file WorkerT.cc.

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

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

147  {
148  return module_->wantsStreamLuminosityBlocks();
149  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
bool edm::WorkerT< T >::wantsStreamRuns ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 142 of file WorkerT.cc.

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

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

142  {
143  return module_->wantsStreamRuns();
144  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159
template<typename T >
std::string edm::WorkerT< T >::workerType ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 424 of file WorkerT.cc.

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

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

424  {
425  return module_->workerType();
426  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:159

Member Data Documentation

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

Definition at line 159 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 >::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().

Generated for CMSSW Reference Manual by doxygen 1.8.11