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)
 
virtual 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
 
virtual void resolvePutIndicies (BranchType iBranchType, std::unordered_multimap< std::string, edm::ProductResolverIndex > const &iIndicies) override
 
void setModule (std::shared_ptr< T > iModule)
 
virtual void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &) override
 
 WorkerT (std::shared_ptr< T >, ModuleDescription const &, ExceptionToActionTable const *actions)
 
virtual ~WorkerT ()
 
- 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 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

virtual std::vector< ConsumesInfo > consumesInfo () const override
 
virtual void convertCurrentProcessAlias (std::string const &processName) override
 
virtual void implBeginJob () override
 
virtual void implBeginStream (StreamID) override
 
virtual bool implDo (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoBegin (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoBegin (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoEnd (RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoEnd (LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual 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)
 
virtual bool implDoStreamBegin (StreamID id, RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoStreamBegin (StreamID id, LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoStreamEnd (StreamID id, RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual bool implDoStreamEnd (StreamID id, LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *mcc) override
 
virtual void implEndJob () override
 
virtual void implEndStream (StreamID) override
 
virtual void implRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &) override
 
virtual void implRespondToCloseInputFile (FileBlock const &fb) override
 
virtual void implRespondToOpenInputFile (FileBlock const &fb) override
 
virtual void itemsMayGet (BranchType branchType, std::vector< ProductResolverIndexAndSkipBit > &indexes) const override
 
virtual std::vector< ProductResolverIndex > const & itemsShouldPutInEvent () const override
 
virtual void itemsToGet (BranchType branchType, std::vector< ProductResolverIndexAndSkipBit > &indexes) const override
 
virtual std::vector< ProductResolverIndexAndSkipBit > const & itemsToGetFrom (BranchType iType) const override final
 
virtual void modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc) const override
 
virtual void preActionBeforeRunEventAsync (WaitingTask *iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const override
 
virtual SerialTaskQueueChain * serializeRunModule () override
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
template<>
SerialTaskQueueChain * serializeRunModule ()
 
virtual 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 32 of file WorkerT.h.

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

Definition at line 33 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 100 of file WorkerT.cc.

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

100  :
101  Worker(md, actions),
102  module_(ed) {
103  assert(module_ != 0);
104  }
actions
roAction_t actions[nactions]
Definition: GenABIO.cc:187
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:72
template<typename T >
edm::WorkerT< T >::~WorkerT ( )
virtual

Definition at line 107 of file WorkerT.cc.

107  {
108  }

Member Function Documentation

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

Definition at line 299 of file WorkerT.cc.

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

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

299  {
300  module_->doBeginStream(id);
301  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerEndStream ( D  ,
StreamID  id 
)

Definition at line 315 of file WorkerT.cc.

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

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

315  {
316  module_->doEndStream(id);
317  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 165 of file WorkerT.cc.

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

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

167  {
168  module_->doStreamBeginRun(id, rp, c, mcc);
169  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 226 of file WorkerT.cc.

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

228  {
229  module_->doStreamBeginLuminosityBlock(id, rp, c, mcc);
230  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 174 of file WorkerT.cc.

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

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

176  {
177  module_->doStreamEndRun(id, rp, c, mcc);
178  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 235 of file WorkerT.cc.

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

237  {
238  module_->doStreamEndLuminosityBlock(id, rp, c, mcc);
239  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T>
virtual std::vector<ConsumesInfo> edm::WorkerT< T >::consumesInfo ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 120 of file WorkerT.h.

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

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

Implements edm::Worker.

Definition at line 116 of file WorkerT.h.

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

116  {
117  module_->convertCurrentProcessAlias(processName);
118  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
modifiedElectrons_cfi.processName
processName
Definition: modifiedElectrons_cfi.py:5
template<typename T >
void edm::WorkerT< T >::implBeginJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 286 of file WorkerT.cc.

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

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

286  {
287  module_->doBeginJob();
288  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
void edm::WorkerT< T >::implBeginStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 306 of file WorkerT.cc.

References relativeConstraints::value.

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

306  {
307  std::conditional_t<workerimpl::has_stream_functions<T>::value,
308  workerimpl::DoBeginStream<T>,
309  workerimpl::DoNothing> might_call;
310  might_call(this,id);
311  }
template<typename T >
bool edm::WorkerT< T >::implDo ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 113 of file WorkerT.cc.

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

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

113  {
114  std::shared_ptr<Worker> sentry(this,[&ep](Worker* obj) {obj->postDoEvent(ep);});
115  return module_->doEvent(ep, c, activityRegistry(), mcc);
116  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:214
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:72
MuonAssociatorByHits_cfi.obj
obj
Definition: MuonAssociatorByHits_cfi.py:101
template<typename T >
bool edm::WorkerT< T >::implDoBegin ( RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 157 of file WorkerT.cc.

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

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

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

Implements edm::Worker.

Definition at line 217 of file WorkerT.cc.

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

218  {
219  module_->doBeginLuminosityBlock(lbp, c, mcc);
220  return true;
221  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
bool edm::WorkerT< T >::implDoEnd ( RunPrincipal const &  rp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 208 of file WorkerT.cc.

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

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

209  {
210  module_->doEndRun(rp, c, mcc);
211  return true;
212  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
bool edm::WorkerT< T >::implDoEnd ( LuminosityBlockPrincipal const &  lbp,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 270 of file WorkerT.cc.

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

271  {
272  module_->doEndLuminosityBlock(lbp, c, mcc);
273  return true;
274  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
bool edm::WorkerT< T >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 121 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 130 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 139 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 148 of file WorkerT.cc.

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

150  {
151  return module_->prePrefetchSelection(id,ep,mcc);
152  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 184 of file WorkerT.cc.

References relativeConstraints::value.

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

185  {
186  std::conditional_t<workerimpl::has_stream_functions<T>::value,
187  workerimpl::DoStreamBeginTrans<T,RunPrincipal const>,
188  workerimpl::DoNothing> might_call;
189  might_call(this,id,rp,c, mcc);
190  return true;
191  }
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 245 of file WorkerT.cc.

References relativeConstraints::value.

246  {
247  std::conditional_t<workerimpl::has_stream_functions<T>::value,
248  workerimpl::DoStreamBeginTrans<T,LuminosityBlockPrincipal>,
249  workerimpl::DoNothing> might_call;
250  might_call(this,id,lbp,c, mcc);
251  return true;
252  }
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 196 of file WorkerT.cc.

References relativeConstraints::value.

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

197  {
198  std::conditional_t<workerimpl::has_stream_functions<T>::value,
199  workerimpl::DoStreamEndTrans<T,RunPrincipal const>,
200  workerimpl::DoNothing> might_call;
201  might_call(this,id,rp,c, mcc);
202  return true;
203  }
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 257 of file WorkerT.cc.

References relativeConstraints::value.

258  {
259  std::conditional_t<workerimpl::has_stream_functions<T>::value,
260  workerimpl::DoStreamEndTrans<T,LuminosityBlockPrincipal>,
261  workerimpl::DoNothing> might_call;
262  might_call(this,id,lbp,c,mcc);
263 
264  return true;
265  }
template<typename T >
void edm::WorkerT< T >::implEndJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 293 of file WorkerT.cc.

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

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

293  {
294  module_->doEndJob();
295  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
void edm::WorkerT< T >::implEndStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 322 of file WorkerT.cc.

References relativeConstraints::value.

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

322  {
323  std::conditional_t<workerimpl::has_stream_functions<T>::value,
324  workerimpl::DoEndStream<T>,
325  workerimpl::DoNothing> might_call;
326  might_call(this,id);
327  }
template<typename T >
void edm::WorkerT< T >::implRegisterThinnedAssociations ( ProductRegistry const &  registry,
ThinnedAssociationsHelper &  helper 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 346 of file WorkerT.cc.

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

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

347  {
348  module_->doRegisterThinnedAssociations(registry, helper);
349  }
helper
Definition: helper.py:1
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 339 of file WorkerT.cc.

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

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

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

Implements edm::Worker.

Definition at line 332 of file WorkerT.cc.

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

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

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

Implements edm::Worker.

Definition at line 128 of file WorkerT.h.

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

128  {
129  module_->itemsMayGet(branchType, indexes);
130  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
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 470 of file WorkerT.cc.

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

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

470  {
471  return itemsShouldPutInEventImpl(&module());
472  }
edm::WorkerT::module
T & module()
Definition: WorkerT.h:74
template<typename T>
virtual void edm::WorkerT< T >::itemsToGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 124 of file WorkerT.h.

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

124  {
125  module_->itemsToGet(branchType, indexes);
126  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
revisionDML.branchType
def branchType(schema, name)
Definition: revisionDML.py:112
template<typename T>
virtual std::vector<ProductResolverIndexAndSkipBit> const& edm::WorkerT< T >::itemsToGetFrom ( BranchType  iType) const
inlinefinaloverrideprivatevirtual

Implements edm::Worker.

Definition at line 132 of file WorkerT.h.

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

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

Definition at line 74 of file WorkerT.h.

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

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

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

Definition at line 75 of file WorkerT.h.

References benchmark_cfg::fb, edm::WorkerT< T >::implBeginJob(), edm::WorkerT< T >::implBeginStream(), edm::WorkerT< T >::implDo(), 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 >::implRegisterThinnedAssociations(), edm::WorkerT< T >::implRespondToCloseInputFile(), edm::WorkerT< T >::implRespondToOpenInputFile(), edm::WorkerT< T >::module_, edm::WorkerT< T >::serializeRunModule(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::WorkerT< T >::workerType().

75 {return *module_;}
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T>
virtual 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 110 of file WorkerT.h.

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

112  {
113  module_->modulesWhoseProductsAreConsumed(modules, preg, labelsToDesc, module_->moduleDescription().processName());
114  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T>
virtual 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 476 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 478 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 480 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 482 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 484 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 486 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 488 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 490 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 493 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 495 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 497 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 499 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 503 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 505 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 507 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 136 of file WorkerT.h.

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

136  {
137  module_->preActionBeforeRunEventAsync(iTask,iModuleCallingContext,iPrincipal);
138  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
void edm::WorkerT< T >::resolvePutIndicies ( BranchType  iBranchType,
std::unordered_multimap< std::string, edm::ProductResolverIndex > const &  iIndicies 
)
overridevirtual

Implements edm::Worker.

Definition at line 462 of file WorkerT.cc.

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

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

463  {
464  resolvePutIndiciesImpl(&module(), iBranchType,iIndicies, description().moduleLabel());
465  }
edm::Worker::description
ModuleDescription const & description() const
Definition: Worker.h:138
edm::WorkerT::module
T & module()
Definition: WorkerT.h:74
template<typename T >
SerialTaskQueueChain * edm::WorkerT< T >::serializeRunModule ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 353 of file WorkerT.cc.

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

353  {
354  return nullptr;
355  }
template<>
SerialTaskQueueChain * edm::WorkerT< EDAnalyzer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 356 of file WorkerT.cc.

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

356  {
357  return &(module_->sharedResourcesAcquirer().serialQueueChain());
358  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< EDFilter >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 359 of file WorkerT.cc.

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

359  {
360  return &(module_->sharedResourcesAcquirer().serialQueueChain());
361  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< EDProducer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 362 of file WorkerT.cc.

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

362  {
363  return &(module_->sharedResourcesAcquirer().serialQueueChain());
364  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< OutputModule >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 365 of file WorkerT.cc.

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

365  {
366  return &(module_->sharedResourcesAcquirer().serialQueueChain());
367  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< one::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 368 of file WorkerT.cc.

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

368  {
369  return &(module_->sharedResourcesAcquirer().serialQueueChain());
370  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< one::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 371 of file WorkerT.cc.

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

371  {
372  return &(module_->sharedResourcesAcquirer().serialQueueChain());
373  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< one::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 374 of file WorkerT.cc.

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

374  {
375  return &(module_->sharedResourcesAcquirer().serialQueueChain());
376  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
SerialTaskQueueChain * edm::WorkerT< one::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 377 of file WorkerT.cc.

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

377  {
378  return &(module_->sharedResourcesAcquirer().serialQueueChain());
379  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T>
void edm::WorkerT< T >::setModule ( std::shared_ptr< T >  iModule)
inline

Definition at line 40 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(), and edm::WorkerT< T >::updateLookup().

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

Implements edm::Worker.

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

409  {
410  module_->updateLookup(iBranchType,iHelper,mustPrefetchMayGet<T>());
411  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T >
std::string edm::WorkerT< T >::workerType ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 279 of file WorkerT.cc.

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

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

279  {
280  return module_->workerType();
281  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141

Member Data Documentation

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

Definition at line 141 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 >::implBeginJob(), edm::WorkerT< T >::implDo(), 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 >::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 >::WorkerT(), and edm::WorkerT< T >::workerType().

Generated for CMSSW Reference Manual by doxygen 1.8.11