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
 
 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 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
 
void implBeginJob () override
 
void implBeginStream (StreamID) override
 
bool implDo (EventPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *mcc) override
 
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
 
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
 
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 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 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:141
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:72
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 328 of file WorkerT.cc.

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

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

328  {
329  module_->doBeginStream(id);
330  }
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 344 of file WorkerT.cc.

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

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

344  {
345  module_->doEndStream(id);
346  }
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 194 of file WorkerT.cc.

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

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

196  {
197  module_->doStreamBeginRun(id, rp, c, mcc);
198  }
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 255 of file WorkerT.cc.

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

257  {
258  module_->doStreamBeginLuminosityBlock(id, rp, c, mcc);
259  }
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 203 of file WorkerT.cc.

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

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

205  {
206  module_->doStreamEndRun(id, rp, c, mcc);
207  }
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 264 of file WorkerT.cc.

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

266  {
267  module_->doStreamEndLuminosityBlock(id, rp, c, mcc);
268  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<typename T>
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>
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 315 of file WorkerT.cc.

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

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

315  {
316  module_->doBeginJob();
317  }
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 335 of file WorkerT.cc.

References relativeConstraints::value.

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

335  {
336  std::conditional_t<workerimpl::has_stream_functions<T>::value,
337  workerimpl::DoBeginStream<T>,
338  workerimpl::DoNothing> might_call;
339  might_call(this,id);
340  }
template<typename T >
bool edm::WorkerT< T >::implDo ( EventPrincipal const &  ep,
EventSetup const &  c,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

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

133  {
134  std::shared_ptr<Worker> sentry(this,[&ep](Worker* obj) {obj->postDoEvent(ep);});
135  return module_->doEvent(ep, c, activityRegistry(), mcc);
136  }
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:243
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 186 of file WorkerT.cc.

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

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

186  {
187  module_->doBeginRun(rp, c, mcc);
188  return true;
189  }
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 246 of file WorkerT.cc.

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

247  {
248  module_->doBeginLuminosityBlock(lbp, c, mcc);
249  return true;
250  }
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 237 of file WorkerT.cc.

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

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

238  {
239  module_->doEndRun(rp, c, mcc);
240  return true;
241  }
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 299 of file WorkerT.cc.

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

300  {
301  module_->doEndLuminosityBlock(lbp, c, mcc);
302  return true;
303  }
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 141 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 150 of file WorkerT.cc.

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

152  {
153  return module_->prePrefetchSelection(id,ep,mcc);
154  }
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 159 of file WorkerT.cc.

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

161  {
162  return module_->prePrefetchSelection(id,ep,mcc);
163  }
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 168 of file WorkerT.cc.

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

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

Implements edm::Worker.

Definition at line 177 of file WorkerT.cc.

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

179  {
180  return module_->prePrefetchSelection(id,ep,mcc);
181  }
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 213 of file WorkerT.cc.

References relativeConstraints::value.

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

214  {
215  std::conditional_t<workerimpl::has_stream_functions<T>::value,
216  workerimpl::DoStreamBeginTrans<T,RunPrincipal const>,
217  workerimpl::DoNothing> might_call;
218  might_call(this,id,rp,c, mcc);
219  return true;
220  }
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 274 of file WorkerT.cc.

References relativeConstraints::value.

275  {
276  std::conditional_t<workerimpl::has_stream_functions<T>::value,
277  workerimpl::DoStreamBeginTrans<T,LuminosityBlockPrincipal>,
278  workerimpl::DoNothing> might_call;
279  might_call(this,id,lbp,c, mcc);
280  return true;
281  }
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 225 of file WorkerT.cc.

References relativeConstraints::value.

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

226  {
227  std::conditional_t<workerimpl::has_stream_functions<T>::value,
228  workerimpl::DoStreamEndTrans<T,RunPrincipal const>,
229  workerimpl::DoNothing> might_call;
230  might_call(this,id,rp,c, mcc);
231  return true;
232  }
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 286 of file WorkerT.cc.

References relativeConstraints::value.

287  {
288  std::conditional_t<workerimpl::has_stream_functions<T>::value,
289  workerimpl::DoStreamEndTrans<T,LuminosityBlockPrincipal>,
290  workerimpl::DoNothing> might_call;
291  might_call(this,id,lbp,c,mcc);
292 
293  return true;
294  }
template<typename T >
void edm::WorkerT< T >::implEndJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 322 of file WorkerT.cc.

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

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

322  {
323  module_->doEndJob();
324  }
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 351 of file WorkerT.cc.

References relativeConstraints::value.

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

351  {
352  std::conditional_t<workerimpl::has_stream_functions<T>::value,
353  workerimpl::DoEndStream<T>,
354  workerimpl::DoNothing> might_call;
355  might_call(this,id);
356  }
template<typename T >
void edm::WorkerT< T >::implRegisterThinnedAssociations ( ProductRegistry const &  registry,
ThinnedAssociationsHelper &  helper 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 375 of file WorkerT.cc.

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

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

376  {
377  module_->doRegisterThinnedAssociations(registry, helper);
378  }
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 368 of file WorkerT.cc.

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

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

368  {
369  module_->doRespondToCloseInputFile(fb);
370  }
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 361 of file WorkerT.cc.

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

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

361  {
362  module_->doRespondToOpenInputFile(fb);
363  }
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 >::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 519 of file WorkerT.cc.

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

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

519  {
520  return itemsShouldPutInEventImpl(&module());
521  }
edm::WorkerT::module
T & module()
Definition: WorkerT.h:74
template<typename T>
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>
std::vector<ProductResolverIndexAndSkipBit> const& edm::WorkerT< T >::itemsToGetFrom ( BranchType  iType) const
inlinefinalprivatevirtual

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>
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>
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 525 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 527 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 529 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 531 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 533 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 535 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 537 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 539 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 542 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 544 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 546 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 548 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 551 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 553 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 555 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

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

Implements edm::Worker.

Definition at line 557 of file WorkerT.cc.

References edm::Worker::kOutputModule.

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

Implements edm::Worker.

Definition at line 561 of file WorkerT.cc.

References edm::Worker::kProducer.

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

Implements edm::Worker.

Definition at line 563 of file WorkerT.cc.

References edm::Worker::kFilter.

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

Implements edm::Worker.

Definition at line 565 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

565 { 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 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, std::tuple< TypeID const *, const char *, edm::ProductResolverIndex >> const &  iIndicies 
)
overridevirtual

Implements edm::Worker.

Definition at line 510 of file WorkerT.cc.

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

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

512  {
513  resolvePutIndiciesImpl(&module(), iBranchType,iIndicies, description().moduleLabel());
514  }
edm::Worker::description
ModuleDescription const & description() const
Definition: Worker.h:167
edm::WorkerT::module
T & module()
Definition: WorkerT.h:74
template<typename T >
Worker::TaskQueueAdaptor edm::WorkerT< T >::serializeRunModule ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 382 of file WorkerT.cc.

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

382  {
383  return Worker::TaskQueueAdaptor{};
384  }
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDAnalyzer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 385 of file WorkerT.cc.

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

385  {
386  return &(module_->sharedResourcesAcquirer().serialQueueChain());
387  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDFilter >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 388 of file WorkerT.cc.

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

388  {
389  return &(module_->sharedResourcesAcquirer().serialQueueChain());
390  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< EDProducer >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 391 of file WorkerT.cc.

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

391  {
392  return &(module_->sharedResourcesAcquirer().serialQueueChain());
393  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< OutputModule >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 394 of file WorkerT.cc.

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

394  {
395  return &(module_->sharedResourcesAcquirer().serialQueueChain());
396  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 397 of file WorkerT.cc.

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

397  {
398  return &(module_->sharedResourcesAcquirer().serialQueueChain());
399  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 400 of file WorkerT.cc.

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

400  {
401  return &(module_->sharedResourcesAcquirer().serialQueueChain());
402  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 403 of file WorkerT.cc.

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

403  {
404  return &(module_->sharedResourcesAcquirer().serialQueueChain());
405  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 406 of file WorkerT.cc.

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

406  {
407  return &(module_->sharedResourcesAcquirer().serialQueueChain());
408  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 409 of file WorkerT.cc.

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

409  {
410  return &(module_->queue());
411  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 412 of file WorkerT.cc.

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

412  {
413  return &(module_->queue());
414  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 415 of file WorkerT.cc.

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

415  {
416  return &(module_->queue());
417  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:141
template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 418 of file WorkerT.cc.

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

418  {
419  return &(module_->queue());
420  }
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(), AlCaHLTBitMon_QueryRunRegistry::string, 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 454 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().

455  {
456  module_->updateLookup(iBranchType,iHelper,mustPrefetchMayGet<T>());
457  }
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 308 of file WorkerT.cc.

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

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

308  {
309  return module_->workerType();
310  }
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