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  ConcurrencyTypes {
  kGlobal, kLimited, kOne, kStream,
  kLegacy
}
 
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, RunTransitionInfo const &, ModuleCallingContext const *)
 
template<typename D >
void callWorkerStreamBegin (D, StreamID, LumiTransitionInfo const &, ModuleCallingContext const *)
 
template<typename D >
void callWorkerStreamEnd (D, StreamID, RunTransitionInfo const &, ModuleCallingContext const *)
 
template<typename D >
void callWorkerStreamEnd (D, StreamID, LumiTransitionInfo const &, ModuleCallingContext const *)
 
SerialTaskQueue * globalLuminosityBlocksQueue () final
 
template<>
SerialTaskQueue * globalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueue * globalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueue * globalLuminosityBlocksQueue ()
 
template<>
SerialTaskQueue * globalLuminosityBlocksQueue ()
 
SerialTaskQueue * globalRunsQueue () final
 
template<>
SerialTaskQueue * globalRunsQueue ()
 
template<>
SerialTaskQueue * globalRunsQueue ()
 
template<>
SerialTaskQueue * globalRunsQueue ()
 
template<>
SerialTaskQueue * globalRunsQueue ()
 
ConcurrencyTypes moduleConcurrencyType () const override
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
template<>
Worker::ConcurrencyTypes moduleConcurrencyType () const
 
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
 
void resolvePutIndicies (BranchType iBranchType, std::unordered_multimap< std::string, std::tuple< TypeID const *, const char *, edm::ProductResolverIndex >> const &iIndicies) final
 
void selectInputProcessBlocks (ProductRegistry const &, ProcessBlockHelperBase const &) final
 
void setModule (std::shared_ptr< T > iModule)
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &) final
 
void updateLookup (eventsetup::ESRecordsToProductResolverIndices const &) final
 
bool wantsGlobalLuminosityBlocks () const final
 
bool wantsGlobalRuns () const final
 
bool wantsInputProcessBlocks () const final
 
bool wantsProcessBlocks () 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 (WaitingTaskHolder task)
 
void clearCounters ()
 
void clearModule ()
 
ModuleDescription const * description () const
 
void doTransformAsync (WaitingTaskHolder, size_t iTransformIndex, EventPrincipal const &, ServiceToken const &, StreamID, ModuleCallingContext const &, StreamContext const *)
 
template<typename T >
void doWorkAsync (WaitingTaskHolder, typename T::TransitionInfoType const &, ServiceToken const &, StreamID, ParentContext const &, typename T::Context const *)
 
template<typename T >
void doWorkNoPrefetchingAsync (WaitingTaskHolder, typename T::TransitionInfoType const &, ServiceToken const &, StreamID, ParentContext const &, typename T::Context const *)
 
void endJob ()
 
void endStream (StreamID id, StreamContext &streamContext)
 
Worker & operator= (Worker const &)=delete
 
void postDoEvent (EventPrincipal const &)
 
void prePrefetchSelectionAsync (oneapi::tbb::task_group &, WaitingTask *task, ServiceToken const &, StreamID stream, EventPrincipal const *)
 
void prePrefetchSelectionAsync (oneapi::tbb::task_group &, WaitingTask *task, ServiceToken const &, StreamID stream, void const *)
 
void registerThinnedAssociations (ProductRegistry const &registry, ThinnedAssociationsHelper &helper)
 
void reset ()
 
void respondToCloseInputFile (FileBlock const &fb)
 
void respondToCloseOutputFile ()
 
void respondToOpenInputFile (FileBlock const &fb)
 
template<typename T >
std::exception_ptr runModuleDirectly (typename T::TransitionInfoType const &, StreamID, ParentContext const &, typename T::Context const *)
 
void setActivityRegistry (std::shared_ptr< ActivityRegistry > areg)
 
void setEarlyDeleteHelper (EarlyDeleteHelper *iHelper)
 
void skipOnPath (EventPrincipal const &iEvent)
 
State state () const
 
int timesExcept () const
 
int timesFailed () const
 
int timesPass () const
 
int timesPassed () const
 
int timesRun () const
 
int timesVisited () const
 
edm::WaitingTaskList & waitingTaskList ()
 
 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 doClearModule () override
 
std::vector< ESResolverIndex > const & esItemsToGetFrom (Transition iTransition) const override
 
std::vector< ESRecordIndex > const & esRecordsToGetFrom (Transition iTransition) const override
 
bool hasAccumulator () const override
 
bool hasAcquire () const override
 
void implBeginJob () override
 
void implBeginStream (StreamID) override
 
bool implDo (EventTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoAccessInputProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *) override
 
void implDoAcquire (EventTransitionInfo const &, ModuleCallingContext const *, WaitingTaskWithArenaHolder &) final
 
template<>
void implDoAcquire (EventTransitionInfo const &info, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventTransitionInfo const &info, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventTransitionInfo const &info, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventTransitionInfo const &info, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
template<>
void implDoAcquire (EventTransitionInfo const &info, ModuleCallingContext const *mcc, WaitingTaskWithArenaHolder &holder)
 
bool implDoBegin (RunTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoBegin (LumiTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoBeginProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *) override
 
bool implDoEnd (RunTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoEnd (LumiTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *) override
 
bool implDoPrePrefetchSelection (StreamID, EventPrincipal const &, ModuleCallingContext const *) 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)
 
bool implDoStreamBegin (StreamID, RunTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoStreamBegin (StreamID, LumiTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoStreamEnd (StreamID, RunTransitionInfo const &, ModuleCallingContext const *) override
 
bool implDoStreamEnd (StreamID, LumiTransitionInfo const &, ModuleCallingContext const *) override
 
void implDoTransformAsync (WaitingTaskHolder, size_t iTransformIndex, EventPrincipal const &, ParentContext const &, ServiceWeakToken const &) final
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken)
 
void implEndJob () override
 
void implEndStream (StreamID) override
 
bool implNeedToRunSelection () const final
 
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 implRespondToCloseOutputFile () override
 
void implRespondToOpenInputFile (FileBlock const &fb) override
 
void itemsMayGet (BranchType branchType, std::vector< ProductResolverIndexAndSkipBit > &indexes) 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
 
std::vector< ProductResolverIndexAndSkipBit > const & itemsToGetFrom (BranchType iType) const final
 
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const final
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const
 
void modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const *> *, NumBranchTypes > &modules, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const *> const &labelsToDesc) const override
 
void preActionBeforeRunEventAsync (WaitingTaskHolder 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 ()
 
size_t transformIndex (edm::BranchDescription const &) const final
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const
 
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 60 of file Frameworkfwd.h.

Member Typedef Documentation

◆ ModuleType

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

Definition at line 35 of file WorkerT.h.

◆ WorkerType

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

Definition at line 36 of file WorkerT.h.

Constructor & Destructor Documentation

◆ WorkerT()

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

Definition at line 117 of file WorkerT.cc.

References cms::cuda::assert(), and edm::WorkerT< T >::module_.

118  : Worker(md, actions), module_(ed) {
119  assert(module_ != nullptr);
120  }
actions
roAction_t actions[nactions]
Definition: GenABIO.cc:181
cms::cuda::assert
assert(be >=bs)
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:90

◆ ~WorkerT()

template<typename T >
edm::WorkerT< T >::~WorkerT ( )
override

Definition at line 123 of file WorkerT.cc.

123 {}

Member Function Documentation

◆ callWorkerBeginStream()

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

Definition at line 573 of file WorkerT.cc.

References sistrip::module_.

Referenced by edm::workerimpl::DoBeginStream< T >::operator()().

573  {
574  module_->doBeginStream(id);
575  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ callWorkerEndStream()

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

Definition at line 589 of file WorkerT.cc.

References sistrip::module_.

Referenced by edm::workerimpl::DoEndStream< T >::operator()().

589  {
590  module_->doEndStream(id);
591  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ callWorkerStreamBegin() [1/2]

template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamBegin ( D  ,
StreamID  id,
RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)

Definition at line 463 of file WorkerT.cc.

References info(), and sistrip::module_.

Referenced by edm::workerimpl::DoStreamBeginTrans< T, INFOTYPE >::operator()().

466  {
467  module_->doStreamBeginRun(id, info, mcc);
468  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ callWorkerStreamBegin() [2/2]

template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamBegin ( D  ,
StreamID  id,
LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)

Definition at line 512 of file WorkerT.cc.

References info(), and sistrip::module_.

515  {
516  module_->doStreamBeginLuminosityBlock(id, info, mcc);
517  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ callWorkerStreamEnd() [1/2]

template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamEnd ( D  ,
StreamID  id,
RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)

Definition at line 472 of file WorkerT.cc.

References info(), and sistrip::module_.

Referenced by edm::workerimpl::DoStreamEndTrans< T, INFOTYPE >::operator()().

472  {
473  module_->doStreamEndRun(id, info, mcc);
474  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ callWorkerStreamEnd() [2/2]

template<typename T >
template<typename D >
void edm::WorkerT< T >::callWorkerStreamEnd ( D  ,
StreamID  id,
LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)

Definition at line 521 of file WorkerT.cc.

References info(), and sistrip::module_.

521  {
522  module_->doStreamEndLuminosityBlock(id, info, mcc);
523  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ consumesInfo()

template<typename T>
std::vector<ConsumesInfo> edm::WorkerT< T >::consumesInfo ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 139 of file WorkerT.h.

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

139 { return module_->consumesInfo(); }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ convertCurrentProcessAlias()

template<typename T>
void edm::WorkerT< T >::convertCurrentProcessAlias ( std::string const &  processName)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 135 of file WorkerT.h.

References edm::WorkerT< T >::module_, and SimL1EmulatorRepack_CalouGT_cff::processName.

135  {
136  module_->convertCurrentProcessAlias(processName);
137  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170
SimL1EmulatorRepack_CalouGT_cff.processName
processName
Definition: SimL1EmulatorRepack_CalouGT_cff.py:16

◆ doClearModule()

template<typename T>
void edm::WorkerT< T >::doClearModule ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 86 of file WorkerT.h.

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

86 { get_underlying_safe(module_).reset(); }
edm::get_underlying_safe
constexpr std::shared_ptr< T > & get_underlying_safe(propagate_const< std::shared_ptr< T >> &iP)
Definition: get_underlying_safe.h:41
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ esItemsToGetFrom()

template<typename T>
std::vector<ESResolverIndex> const& edm::WorkerT< T >::esItemsToGetFrom ( Transition  iTransition) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 153 of file WorkerT.h.

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

153  {
154  return module_->esGetTokenIndicesVector(iTransition);
155  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ esRecordsToGetFrom()

template<typename T>
std::vector<ESRecordIndex> const& edm::WorkerT< T >::esRecordsToGetFrom ( Transition  iTransition) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 156 of file WorkerT.h.

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

156  {
157  return module_->esGetTokenRecordIndicesVector(iTransition);
158  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalLuminosityBlocksQueue() [1/5]

template<typename T >
SerialTaskQueue * edm::WorkerT< T >::globalLuminosityBlocksQueue ( )
finalvirtual

Implements edm::Worker.

Definition at line 160 of file WorkerT.cc.

160  {
161  return nullptr;
162  }

◆ globalLuminosityBlocksQueue() [2/5]

template<>
SerialTaskQueue * edm::WorkerT< one::EDProducerBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 170 of file WorkerT.cc.

References sistrip::module_.

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

◆ globalLuminosityBlocksQueue() [3/5]

template<>
SerialTaskQueue * edm::WorkerT< one::EDFilterBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 178 of file WorkerT.cc.

References sistrip::module_.

178  {
179  return module_->globalLuminosityBlocksQueue();
180  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalLuminosityBlocksQueue() [4/5]

template<>
SerialTaskQueue * edm::WorkerT< one::EDAnalyzerBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 186 of file WorkerT.cc.

References sistrip::module_.

186  {
187  return module_->globalLuminosityBlocksQueue();
188  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalLuminosityBlocksQueue() [5/5]

template<>
SerialTaskQueue * edm::WorkerT< one::OutputModuleBase >::globalLuminosityBlocksQueue ( )
virtual

Implements edm::Worker.

Definition at line 194 of file WorkerT.cc.

References sistrip::module_.

194  {
195  return module_->globalLuminosityBlocksQueue();
196  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalRunsQueue() [1/5]

template<typename T >
SerialTaskQueue * edm::WorkerT< T >::globalRunsQueue ( )
finalvirtual

Implements edm::Worker.

Definition at line 156 of file WorkerT.cc.

156  {
157  return nullptr;
158  }

◆ globalRunsQueue() [2/5]

template<>
SerialTaskQueue * edm::WorkerT< one::EDProducerBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 166 of file WorkerT.cc.

References sistrip::module_.

166  {
167  return module_->globalRunsQueue();
168  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalRunsQueue() [3/5]

template<>
SerialTaskQueue * edm::WorkerT< one::EDFilterBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 174 of file WorkerT.cc.

References sistrip::module_.

174  {
175  return module_->globalRunsQueue();
176  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalRunsQueue() [4/5]

template<>
SerialTaskQueue * edm::WorkerT< one::EDAnalyzerBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 182 of file WorkerT.cc.

References sistrip::module_.

182  {
183  return module_->globalRunsQueue();
184  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ globalRunsQueue() [5/5]

template<>
SerialTaskQueue * edm::WorkerT< one::OutputModuleBase >::globalRunsQueue ( )
virtual

Implements edm::Worker.

Definition at line 190 of file WorkerT.cc.

References sistrip::module_.

190  {
191  return module_->globalRunsQueue();
192  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ hasAccumulator()

template<typename T>
bool edm::WorkerT< T >::hasAccumulator ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 168 of file WorkerT.h.

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

168 { return module_->hasAccumulator(); }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ hasAcquire()

template<typename T>
bool edm::WorkerT< T >::hasAcquire ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 166 of file WorkerT.h.

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

166 { return module_->hasAcquire(); }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implBeginJob()

template<typename T >
void edm::WorkerT< T >::implBeginJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 562 of file WorkerT.cc.

References sistrip::module_.

562  {
563  module_->doBeginJob();
564  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implBeginStream()

template<typename T >
void edm::WorkerT< T >::implBeginStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 578 of file WorkerT.cc.

References or, and relativeConstraints::value.

578  {
579  std::conditional_t<workerimpl::has_stream_functions<T>::value or
580  workerimpl::has_only_stream_transition_functions<T>::value,
581  workerimpl::DoBeginStream<T>,
582  workerimpl::DoNothing>
583  might_call;
584  might_call(this, id);
585  }
or
The Signals That Services Can Subscribe To This is based on ActivityRegistry and is current per Services can connect to the signals distributed by the ActivityRegistry in order to monitor the activity of the application Each possible callback has some defined which we here list in angle e< void, edm::EventID const &, edm::Timestamp const & > We also list in braces which AR_WATCH_USING_METHOD_ is used for those or
Definition: Activities.doc:12
edm::workerimpl::has_only_stream_transition_functions::value
static bool constexpr value
Definition: WorkerT.cc:78

◆ implDo()

template<typename T >
bool edm::WorkerT< T >::implDo ( EventTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 199 of file WorkerT.cc.

References SiStripBadComponentsDQMServiceTemplate_cfg::ep, info(), sistrip::module_, and getGTfromDQMFile::obj.

199  {
200  EventPrincipal const& ep = info.principal();
201  std::shared_ptr<Worker> sentry(this, [&ep](Worker* obj) { obj->postDoEvent(ep); });
202  return module_->doEvent(info, activityRegistry(), mcc);
203  }
SiStripBadComponentsDQMServiceTemplate_cfg.ep
ep
Definition: SiStripBadComponentsDQMServiceTemplate_cfg.py:86
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170
edm::Worker::Worker
Worker(ModuleDescription const &iMD, ExceptionToActionTable const *iActions)
Definition: Worker.cc:90

◆ implDoAccessInputProcessBlock()

template<typename T >
bool edm::WorkerT< T >::implDoAccessInputProcessBlock ( ProcessBlockPrincipal const &  pbp,
ModuleCallingContext const *  mcc 
)
overrideprivatevirtual

Implements edm::Worker.

Definition at line 444 of file WorkerT.cc.

References sistrip::module_.

444  {
445  module_->doAccessInputProcessBlock(pbp, mcc);
446  return true;
447  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoAcquire() [1/6]

template<typename T >
void edm::WorkerT< T >::implDoAcquire ( EventTransitionInfo const &  ,
ModuleCallingContext const *  ,
WaitingTaskWithArenaHolder &   
)
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 206 of file WorkerT.cc.

208  {}

◆ implDoAcquire() [2/6]

template<>
void edm::WorkerT< global::EDProducerBase >::implDoAcquire ( EventTransitionInfo const &  info,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 211 of file WorkerT.cc.

References info(), and sistrip::module_.

213  {
214  module_->doAcquire(info, activityRegistry(), mcc, holder);
215  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoAcquire() [3/6]

template<>
void edm::WorkerT< global::EDFilterBase >::implDoAcquire ( EventTransitionInfo const &  info,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 218 of file WorkerT.cc.

References info(), and sistrip::module_.

220  {
221  module_->doAcquire(info, activityRegistry(), mcc, holder);
222  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoAcquire() [4/6]

template<>
void edm::WorkerT< global::OutputModuleBase >::implDoAcquire ( EventTransitionInfo const &  info,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 225 of file WorkerT.cc.

References info(), and sistrip::module_.

227  {
228  module_->doAcquire(info, activityRegistry(), mcc, holder);
229  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoAcquire() [5/6]

template<>
void edm::WorkerT< stream::EDProducerAdaptorBase >::implDoAcquire ( EventTransitionInfo const &  info,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 232 of file WorkerT.cc.

References info(), and sistrip::module_.

234  {
235  module_->doAcquire(info, activityRegistry(), mcc, holder);
236  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoAcquire() [6/6]

template<>
void edm::WorkerT< stream::EDFilterAdaptorBase >::implDoAcquire ( EventTransitionInfo const &  info,
ModuleCallingContext const *  mcc,
WaitingTaskWithArenaHolder &  holder 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 239 of file WorkerT.cc.

References info(), and sistrip::module_.

241  {
242  module_->doAcquire(info, activityRegistry(), mcc, holder);
243  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoBegin() [1/2]

template<typename T >
bool edm::WorkerT< T >::implDoBegin ( RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 456 of file WorkerT.cc.

References info(), and sistrip::module_.

456  {
457  module_->doBeginRun(info, mcc);
458  return true;
459  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoBegin() [2/2]

template<typename T >
bool edm::WorkerT< T >::implDoBegin ( LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 505 of file WorkerT.cc.

References info(), and sistrip::module_.

505  {
506  module_->doBeginLuminosityBlock(info, mcc);
507  return true;
508  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoBeginProcessBlock()

template<typename T >
bool edm::WorkerT< T >::implDoBeginProcessBlock ( ProcessBlockPrincipal const &  pbp,
ModuleCallingContext const *  mcc 
)
overrideprivatevirtual

Implements edm::Worker.

Definition at line 438 of file WorkerT.cc.

References sistrip::module_.

438  {
439  module_->doBeginProcessBlock(pbp, mcc);
440  return true;
441  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoEnd() [1/2]

template<typename T >
bool edm::WorkerT< T >::implDoEnd ( RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 499 of file WorkerT.cc.

References info(), and sistrip::module_.

499  {
500  module_->doEndRun(info, mcc);
501  return true;
502  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoEnd() [2/2]

template<typename T >
bool edm::WorkerT< T >::implDoEnd ( LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 551 of file WorkerT.cc.

References info(), and sistrip::module_.

551  {
552  module_->doEndLuminosityBlock(info, mcc);
553  return true;
554  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoEndProcessBlock()

template<typename T >
bool edm::WorkerT< T >::implDoEndProcessBlock ( ProcessBlockPrincipal const &  pbp,
ModuleCallingContext const *  mcc 
)
overrideprivatevirtual

Implements edm::Worker.

Definition at line 450 of file WorkerT.cc.

References sistrip::module_.

450  {
451  module_->doEndProcessBlock(pbp, mcc);
452  return true;
453  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoPrePrefetchSelection() [1/4]

template<typename T >
bool edm::WorkerT< T >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 380 of file WorkerT.cc.

382  {
383  return true;
384  }

◆ implDoPrePrefetchSelection() [2/4]

template<>
bool edm::WorkerT< edm::one::OutputModuleBase >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 394 of file WorkerT.cc.

References SiStripBadComponentsDQMServiceTemplate_cfg::ep, and sistrip::module_.

396  {
397  return module_->prePrefetchSelection(id, ep, mcc);
398  }
SiStripBadComponentsDQMServiceTemplate_cfg.ep
ep
Definition: SiStripBadComponentsDQMServiceTemplate_cfg.py:86
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoPrePrefetchSelection() [3/4]

template<>
bool edm::WorkerT< edm::global::OutputModuleBase >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 410 of file WorkerT.cc.

References SiStripBadComponentsDQMServiceTemplate_cfg::ep, and sistrip::module_.

412  {
413  return module_->prePrefetchSelection(id, ep, mcc);
414  }
SiStripBadComponentsDQMServiceTemplate_cfg.ep
ep
Definition: SiStripBadComponentsDQMServiceTemplate_cfg.py:86
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoPrePrefetchSelection() [4/4]

template<>
bool edm::WorkerT< edm::limited::OutputModuleBase >::implDoPrePrefetchSelection ( StreamID  id,
EventPrincipal const &  ep,
ModuleCallingContext const *  mcc 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 426 of file WorkerT.cc.

References SiStripBadComponentsDQMServiceTemplate_cfg::ep, and sistrip::module_.

428  {
429  return module_->prePrefetchSelection(id, ep, mcc);
430  }
SiStripBadComponentsDQMServiceTemplate_cfg.ep
ep
Definition: SiStripBadComponentsDQMServiceTemplate_cfg.py:86
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implDoStreamBegin() [1/2]

template<typename T >
bool edm::WorkerT< T >::implDoStreamBegin ( StreamID  id,
RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 477 of file WorkerT.cc.

References info(), and relativeConstraints::value.

479  {
480  std::conditional_t<workerimpl::has_stream_functions<T>::value,
481  workerimpl::DoStreamBeginTrans<T, RunTransitionInfo const>,
482  workerimpl::DoNothing>
483  might_call;
484  might_call(this, id, info, mcc);
485  return true;
486  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153

◆ implDoStreamBegin() [2/2]

template<typename T >
bool edm::WorkerT< T >::implDoStreamBegin ( StreamID  id,
LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 526 of file WorkerT.cc.

References info(), and relativeConstraints::value.

528  {
529  std::conditional_t<workerimpl::has_stream_functions<T>::value,
530  workerimpl::DoStreamBeginTrans<T, LumiTransitionInfo>,
531  workerimpl::DoNothing>
532  might_call;
533  might_call(this, id, info, mcc);
534  return true;
535  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153

◆ implDoStreamEnd() [1/2]

template<typename T >
bool edm::WorkerT< T >::implDoStreamEnd ( StreamID  id,
RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 489 of file WorkerT.cc.

References info(), and relativeConstraints::value.

489  {
490  std::conditional_t<workerimpl::has_stream_functions<T>::value,
491  workerimpl::DoStreamEndTrans<T, RunTransitionInfo const>,
492  workerimpl::DoNothing>
493  might_call;
494  might_call(this, id, info, mcc);
495  return true;
496  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153

◆ implDoStreamEnd() [2/2]

template<typename T >
bool edm::WorkerT< T >::implDoStreamEnd ( StreamID  id,
LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 538 of file WorkerT.cc.

References info(), and relativeConstraints::value.

540  {
541  std::conditional_t<workerimpl::has_stream_functions<T>::value,
542  workerimpl::DoStreamEndTrans<T, LumiTransitionInfo>,
543  workerimpl::DoNothing>
544  might_call;
545  might_call(this, id, info, mcc);
546 
547  return true;
548  }
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153

◆ implDoTransformAsync() [1/8]

template<typename T >
void edm::WorkerT< T >::implDoTransformAsync ( WaitingTaskHolder  iTask,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 246 of file WorkerT.cc.

References CMS_SA_ALLOW, edm::WaitingTaskHolder::doneWaiting(), iEvent, edm::ModuleCallingContext::kRunning, edm::ServiceWeakToken::lock(), and sistrip::module_.

250  {
251  CMS_SA_ALLOW try {
252  ServiceRegistry::Operate guard(weakToken.lock());
253 
254  ModuleCallingContext mcc(
255  &module_->moduleDescription(), iTransformIndex + 1, ModuleCallingContext::State::kRunning, iParent, nullptr);
256  module_->doTransformAsync(iTask, iTransformIndex, iEvent, activityRegistry(), mcc, weakToken);
257  } catch (...) {
258  iTask.doneWaiting(std::current_exception());
259  return;
260  }
261  iTask.doneWaiting(std::exception_ptr());
262  }
CMS_SA_ALLOW
#define CMS_SA_ALLOW
edm::Worker::activityRegistry
ActivityRegistry * activityRegistry()
Definition: Worker.h:298
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170
iEvent
int iEvent
Definition: GenABIO.cc:224

◆ implDoTransformAsync() [2/8]

template<>
void edm::WorkerT< global::EDAnalyzerBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 265 of file WorkerT.cc.

269  {}

◆ implDoTransformAsync() [3/8]

template<>
void edm::WorkerT< global::OutputModuleBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 271 of file WorkerT.cc.

275  {}

◆ implDoTransformAsync() [4/8]

template<>
void edm::WorkerT< limited::EDAnalyzerBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 277 of file WorkerT.cc.

281  {}

◆ implDoTransformAsync() [5/8]

template<>
void edm::WorkerT< limited::OutputModuleBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 283 of file WorkerT.cc.

287  {}

◆ implDoTransformAsync() [6/8]

template<>
void edm::WorkerT< one::EDAnalyzerBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 289 of file WorkerT.cc.

293  {}

◆ implDoTransformAsync() [7/8]

template<>
void edm::WorkerT< one::OutputModuleBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 295 of file WorkerT.cc.

299  {}

◆ implDoTransformAsync() [8/8]

template<>
void edm::WorkerT< stream::EDAnalyzerAdaptorBase >::implDoTransformAsync ( WaitingTaskHolder  task,
size_t  iTransformIndex,
EventPrincipal const &  iEvent,
ParentContext const &  iParent,
ServiceWeakToken const &  weakToken 
)
inlineprivatevirtual

Implements edm::Worker.

Definition at line 301 of file WorkerT.cc.

305  {}

◆ implEndJob()

template<typename T >
void edm::WorkerT< T >::implEndJob ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 567 of file WorkerT.cc.

References sistrip::module_.

567  {
568  module_->doEndJob();
569  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implEndStream()

template<typename T >
void edm::WorkerT< T >::implEndStream ( StreamID  id)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 594 of file WorkerT.cc.

References or, and relativeConstraints::value.

594  {
595  std::conditional_t<workerimpl::has_stream_functions<T>::value or
596  workerimpl::has_only_stream_transition_functions<T>::value,
597  workerimpl::DoEndStream<T>,
598  workerimpl::DoNothing>
599  might_call;
600  might_call(this, id);
601  }
or
The Signals That Services Can Subscribe To This is based on ActivityRegistry and is current per Services can connect to the signals distributed by the ActivityRegistry in order to monitor the activity of the application Each possible callback has some defined which we here list in angle e< void, edm::EventID const &, edm::Timestamp const & > We also list in braces which AR_WATCH_USING_METHOD_ is used for those or
Definition: Activities.doc:12
edm::workerimpl::has_only_stream_transition_functions::value
static bool constexpr value
Definition: WorkerT.cc:78

◆ implNeedToRunSelection() [1/4]

template<typename T >
bool edm::WorkerT< T >::implNeedToRunSelection ( ) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 375 of file WorkerT.cc.

375  {
376  return false;
377  }

◆ implNeedToRunSelection() [2/4]

template<>
bool edm::WorkerT< edm::one::OutputModuleBase >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 389 of file WorkerT.cc.

389  {
390  return true;
391  }

◆ implNeedToRunSelection() [3/4]

template<>
bool edm::WorkerT< edm::global::OutputModuleBase >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 406 of file WorkerT.cc.

406  {
407  return true;
408  }

◆ implNeedToRunSelection() [4/4]

template<>
bool edm::WorkerT< edm::limited::OutputModuleBase >::implNeedToRunSelection ( ) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 422 of file WorkerT.cc.

422  {
423  return true;
424  }

◆ implRegisterThinnedAssociations()

template<typename T >
void edm::WorkerT< T >::implRegisterThinnedAssociations ( ProductRegistry const &  registry,
ThinnedAssociationsHelper &  helper 
)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 619 of file WorkerT.cc.

References sistrip::module_.

620  {
621  module_->doRegisterThinnedAssociations(registry, helper);
622  }
helper
Definition: helper.py:1
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implRespondToCloseInputFile()

template<typename T >
void edm::WorkerT< T >::implRespondToCloseInputFile ( FileBlock const &  fb)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 609 of file WorkerT.cc.

References sistrip::module_.

609  {
610  module_->doRespondToCloseInputFile(fb);
611  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implRespondToCloseOutputFile()

template<typename T >
void edm::WorkerT< T >::implRespondToCloseOutputFile ( )
overrideprivatevirtual

Implements edm::Worker.

Definition at line 614 of file WorkerT.cc.

References sistrip::module_.

614  {
615  module_->doRespondToCloseOutputFile();
616  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ implRespondToOpenInputFile()

template<typename T >
void edm::WorkerT< T >::implRespondToOpenInputFile ( FileBlock const &  fb)
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 604 of file WorkerT.cc.

References sistrip::module_.

604  {
605  module_->doRespondToOpenInputFile(fb);
606  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemsMayGet()

template<typename T>
void edm::WorkerT< T >::itemsMayGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 145 of file WorkerT.h.

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

145  {
146  module_->itemsMayGet(branchType, indexes);
147  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemsToGet()

template<typename T>
void edm::WorkerT< T >::itemsToGet ( BranchType  branchType,
std::vector< ProductResolverIndexAndSkipBit > &  indexes 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 141 of file WorkerT.h.

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

141  {
142  module_->itemsToGet(branchType, indexes);
143  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemsToGetForSelection() [1/4]

template<typename T >
void edm::WorkerT< T >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  ) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 386 of file WorkerT.cc.

386 {}

◆ itemsToGetForSelection() [2/4]

template<>
void edm::WorkerT< edm::one::OutputModuleBase >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 400 of file WorkerT.cc.

References sistrip::module_.

401  {
402  iItems = module_->productsUsedBySelection();
403  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemsToGetForSelection() [3/4]

template<>
void edm::WorkerT< edm::global::OutputModuleBase >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 416 of file WorkerT.cc.

References sistrip::module_.

417  {
418  iItems = module_->productsUsedBySelection();
419  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemsToGetForSelection() [4/4]

template<>
void edm::WorkerT< edm::limited::OutputModuleBase >::itemsToGetForSelection ( std::vector< ProductResolverIndexAndSkipBit > &  iItems) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 432 of file WorkerT.cc.

References sistrip::module_.

433  {
434  iItems = module_->productsUsedBySelection();
435  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemsToGetFrom()

template<typename T>
std::vector<ProductResolverIndexAndSkipBit> const& edm::WorkerT< T >::itemsToGetFrom ( BranchType  iType) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 149 of file WorkerT.h.

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

149  {
150  return module_->itemsToGetFrom(iType);
151  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [1/8]

template<typename T >
ProductResolverIndex edm::WorkerT< T >::itemToGetForTransform ( size_t  iTransformIndex) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 341 of file WorkerT.cc.

341  {
342  return -1;
343  }

◆ itemToGetForTransform() [2/8]

template<>
ProductResolverIndex edm::WorkerT< global::EDFilterBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 345 of file WorkerT.cc.

References sistrip::module_.

345  {
346  return module_->transformPrefetch_(iTransformIndex);
347  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [3/8]

template<>
ProductResolverIndex edm::WorkerT< global::EDProducerBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 349 of file WorkerT.cc.

References sistrip::module_.

349  {
350  return module_->transformPrefetch_(iTransformIndex);
351  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [4/8]

template<>
ProductResolverIndex edm::WorkerT< stream::EDProducerAdaptorBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 353 of file WorkerT.cc.

References sistrip::module_.

354  {
355  return module_->transformPrefetch_(iTransformIndex);
356  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [5/8]

template<>
ProductResolverIndex edm::WorkerT< limited::EDFilterBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 358 of file WorkerT.cc.

References sistrip::module_.

358  {
359  return module_->transformPrefetch_(iTransformIndex);
360  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [6/8]

template<>
ProductResolverIndex edm::WorkerT< limited::EDProducerBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 362 of file WorkerT.cc.

References sistrip::module_.

362  {
363  return module_->transformPrefetch_(iTransformIndex);
364  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [7/8]

template<>
ProductResolverIndex edm::WorkerT< one::EDFilterBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 366 of file WorkerT.cc.

References sistrip::module_.

366  {
367  return module_->transformPrefetch_(iTransformIndex);
368  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ itemToGetForTransform() [8/8]

template<>
ProductResolverIndex edm::WorkerT< one::EDProducerBase >::itemToGetForTransform ( size_t  iTransformIndex) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 370 of file WorkerT.cc.

References sistrip::module_.

370  {
371  return module_->transformPrefetch_(iTransformIndex);
372  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ module() [1/2]

template<typename T>
T& edm::WorkerT< T >::module ( )
inlineprotected

Definition at line 82 of file WorkerT.h.

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

82 { return *module_; }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ module() [2/2]

template<typename T>
T const& edm::WorkerT< T >::module ( ) const
inlineprotected

Definition at line 83 of file WorkerT.h.

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

83 { return *module_; }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ moduleConcurrencyType() [1/16]

template<typename T>
ConcurrencyTypes edm::WorkerT< T >::moduleConcurrencyType ( ) const
overridevirtual

Implements edm::Worker.

◆ moduleConcurrencyType() [2/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::one::EDProducerBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 852 of file WorkerT.cc.

References edm::Worker::kOne.

852  {
853  return Worker::kOne;
854  }

◆ moduleConcurrencyType() [3/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::one::EDFilterBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 856 of file WorkerT.cc.

References edm::Worker::kOne.

856  {
857  return Worker::kOne;
858  }

◆ moduleConcurrencyType() [4/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::one::EDAnalyzerBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 860 of file WorkerT.cc.

References edm::Worker::kOne.

860  {
861  return Worker::kOne;
862  }

◆ moduleConcurrencyType() [5/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::one::OutputModuleBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 864 of file WorkerT.cc.

References edm::Worker::kOne.

864  {
865  return Worker::kOne;
866  }

◆ moduleConcurrencyType() [6/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::global::EDProducerBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 869 of file WorkerT.cc.

References edm::Worker::kGlobal.

869  {
870  return Worker::kGlobal;
871  }

◆ moduleConcurrencyType() [7/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::global::EDFilterBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 873 of file WorkerT.cc.

References edm::Worker::kGlobal.

873  {
874  return Worker::kGlobal;
875  }

◆ moduleConcurrencyType() [8/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::global::EDAnalyzerBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 877 of file WorkerT.cc.

References edm::Worker::kGlobal.

877  {
878  return Worker::kGlobal;
879  }

◆ moduleConcurrencyType() [9/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::global::OutputModuleBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 881 of file WorkerT.cc.

References edm::Worker::kGlobal.

881  {
882  return Worker::kGlobal;
883  }

◆ moduleConcurrencyType() [10/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::limited::EDProducerBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 886 of file WorkerT.cc.

References edm::Worker::kLimited.

886  {
887  return Worker::kLimited;
888  }

◆ moduleConcurrencyType() [11/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::limited::EDFilterBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 890 of file WorkerT.cc.

References edm::Worker::kLimited.

890  {
891  return Worker::kLimited;
892  }

◆ moduleConcurrencyType() [12/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::limited::EDAnalyzerBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 894 of file WorkerT.cc.

References edm::Worker::kLimited.

894  {
895  return Worker::kLimited;
896  }

◆ moduleConcurrencyType() [13/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::limited::OutputModuleBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 898 of file WorkerT.cc.

References edm::Worker::kLimited.

898  {
899  return Worker::kLimited;
900  }

◆ moduleConcurrencyType() [14/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::stream::EDProducerAdaptorBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 903 of file WorkerT.cc.

References edm::Worker::kStream.

903  {
904  return Worker::kStream;
905  }

◆ moduleConcurrencyType() [15/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::stream::EDFilterAdaptorBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 907 of file WorkerT.cc.

References edm::Worker::kStream.

907  {
908  return Worker::kStream;
909  }

◆ moduleConcurrencyType() [16/16]

template<>
Worker::ConcurrencyTypes edm::WorkerT< edm::stream::EDAnalyzerAdaptorBase >::moduleConcurrencyType ( ) const
virtual

Implements edm::Worker.

Definition at line 911 of file WorkerT.cc.

References edm::Worker::kStream.

911  {
912  return Worker::kStream;
913  }

◆ modulesWhoseProductsAreConsumed()

template<typename T>
void edm::WorkerT< T >::modulesWhoseProductsAreConsumed ( std::array< std::vector< ModuleDescription const *> *, NumBranchTypes > &  modules,
std::vector< ModuleProcessName > &  modulesInPreviousProcesses,
ProductRegistry const &  preg,
std::map< std::string, ModuleDescription const *> const &  labelsToDesc 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 126 of file WorkerT.h.

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

130  {
131  module_->modulesWhoseProductsAreConsumed(
132  modules, modulesInPreviousProcesses, preg, labelsToDesc, module_->moduleDescription().processName());
133  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ moduleType() [1/16]

template<typename T>
Types edm::WorkerT< T >::moduleType ( ) const
overridevirtual

Implements edm::Worker.

◆ moduleType() [2/16]

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

Implements edm::Worker.

Definition at line 788 of file WorkerT.cc.

References edm::Worker::kProducer.

788  {
789  return Worker::kProducer;
790  }

◆ moduleType() [3/16]

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

Implements edm::Worker.

Definition at line 792 of file WorkerT.cc.

References edm::Worker::kFilter.

792  {
793  return Worker::kFilter;
794  }

◆ moduleType() [4/16]

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

Implements edm::Worker.

Definition at line 796 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

796  {
797  return Worker::kAnalyzer;
798  }

◆ moduleType() [5/16]

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

Implements edm::Worker.

Definition at line 800 of file WorkerT.cc.

References edm::Worker::kOutputModule.

800  {
801  return Worker::kOutputModule;
802  }

◆ moduleType() [6/16]

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

Implements edm::Worker.

Definition at line 805 of file WorkerT.cc.

References edm::Worker::kProducer.

805  {
806  return Worker::kProducer;
807  }

◆ moduleType() [7/16]

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

Implements edm::Worker.

Definition at line 809 of file WorkerT.cc.

References edm::Worker::kFilter.

809  {
810  return Worker::kFilter;
811  }

◆ moduleType() [8/16]

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

Implements edm::Worker.

Definition at line 813 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

813  {
814  return Worker::kAnalyzer;
815  }

◆ moduleType() [9/16]

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

Implements edm::Worker.

Definition at line 817 of file WorkerT.cc.

References edm::Worker::kOutputModule.

817  {
818  return Worker::kOutputModule;
819  }

◆ moduleType() [10/16]

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

Implements edm::Worker.

Definition at line 822 of file WorkerT.cc.

References edm::Worker::kProducer.

822  {
823  return Worker::kProducer;
824  }

◆ moduleType() [11/16]

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

Implements edm::Worker.

Definition at line 826 of file WorkerT.cc.

References edm::Worker::kFilter.

826  {
827  return Worker::kFilter;
828  }

◆ moduleType() [12/16]

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

Implements edm::Worker.

Definition at line 830 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

830  {
831  return Worker::kAnalyzer;
832  }

◆ moduleType() [13/16]

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

Implements edm::Worker.

Definition at line 834 of file WorkerT.cc.

References edm::Worker::kOutputModule.

834  {
835  return Worker::kOutputModule;
836  }

◆ moduleType() [14/16]

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

Implements edm::Worker.

Definition at line 839 of file WorkerT.cc.

References edm::Worker::kProducer.

839  {
840  return Worker::kProducer;
841  }

◆ moduleType() [15/16]

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

Implements edm::Worker.

Definition at line 843 of file WorkerT.cc.

References edm::Worker::kFilter.

843  {
844  return Worker::kFilter;
845  }

◆ moduleType() [16/16]

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

Implements edm::Worker.

Definition at line 847 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

847  {
848  return Worker::kAnalyzer;
849  }

◆ preActionBeforeRunEventAsync()

template<typename T>
void edm::WorkerT< T >::preActionBeforeRunEventAsync ( WaitingTaskHolder  iTask,
ModuleCallingContext const &  iModuleCallingContext,
Principal const &  iPrincipal 
) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 160 of file WorkerT.h.

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

162  {
163  module_->preActionBeforeRunEventAsync(iTask, iModuleCallingContext, iPrincipal);
164  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ resolvePutIndicies()

template<typename T >
void edm::WorkerT< T >::resolvePutIndicies ( BranchType  iBranchType,
std::unordered_multimap< std::string, std::tuple< TypeID const *, const char *, edm::ProductResolverIndex >> const &  iIndicies 
)
finalvirtual

Implements edm::Worker.

Definition at line 780 of file WorkerT.cc.

References makeListRunsInFiles::description, callgraph::module, and HerwigMaxPtPartonFilter_cfi::moduleLabel.

783  {
784  resolvePutIndiciesImpl(&module(), iBranchType, iIndicies, description()->moduleLabel());
785  }
HerwigMaxPtPartonFilter_cfi.moduleLabel
moduleLabel
Definition: HerwigMaxPtPartonFilter_cfi.py:4
edm::WorkerT::module
T & module()
Definition: WorkerT.h:82
edm::Worker::description
ModuleDescription const * description() const
Definition: Worker.h:198

◆ selectInputProcessBlocks()

template<typename T >
void edm::WorkerT< T >::selectInputProcessBlocks ( ProductRegistry const &  productRegistry,
ProcessBlockHelperBase const &  processBlockHelperBase 
)
finalvirtual

Implements edm::Worker.

Definition at line 742 of file WorkerT.cc.

References sistrip::module_.

743  {
744  module_->selectInputProcessBlocks(productRegistry, processBlockHelperBase);
745  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [1/9]

template<typename T >
Worker::TaskQueueAdaptor edm::WorkerT< T >::serializeRunModule ( )
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 625 of file WorkerT.cc.

625  {
626  return Worker::TaskQueueAdaptor{};
627  }

◆ serializeRunModule() [2/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 629 of file WorkerT.cc.

References sistrip::module_.

629  {
630  return &(module_->sharedResourcesAcquirer().serialQueueChain());
631  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [3/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 633 of file WorkerT.cc.

References sistrip::module_.

633  {
634  return &(module_->sharedResourcesAcquirer().serialQueueChain());
635  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [4/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 637 of file WorkerT.cc.

References sistrip::module_.

637  {
638  return &(module_->sharedResourcesAcquirer().serialQueueChain());
639  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [5/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< one::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 641 of file WorkerT.cc.

References sistrip::module_.

641  {
642  return &(module_->sharedResourcesAcquirer().serialQueueChain());
643  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [6/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDAnalyzerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 645 of file WorkerT.cc.

References sistrip::module_.

645  {
646  return &(module_->queue());
647  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [7/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDFilterBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 649 of file WorkerT.cc.

References sistrip::module_.

649  {
650  return &(module_->queue());
651  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [8/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::EDProducerBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 653 of file WorkerT.cc.

References sistrip::module_.

653  {
654  return &(module_->queue());
655  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ serializeRunModule() [9/9]

template<>
Worker::TaskQueueAdaptor edm::WorkerT< limited::OutputModuleBase >::serializeRunModule ( )
privatevirtual

Implements edm::Worker.

Definition at line 657 of file WorkerT.cc.

References sistrip::module_.

657  {
658  return &(module_->queue());
659  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ setModule()

template<typename T>
void edm::WorkerT< T >::setModule ( std::shared_ptr< T >  iModule)
inline

Definition at line 41 of file WorkerT.h.

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

41  {
42  module_ = iModule;
43  resetModuleDescription(&(module_->moduleDescription()));
44  }
edm::Worker::resetModuleDescription
void resetModuleDescription(ModuleDescription const *)
Definition: Worker.cc:272
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [1/8]

template<typename T >
size_t edm::WorkerT< T >::transformIndex ( edm::BranchDescription const &  ) const
inlinefinalprivatevirtual

Implements edm::Worker.

Definition at line 308 of file WorkerT.cc.

308  {
309  return -1;
310  }

◆ transformIndex() [2/8]

template<>
size_t edm::WorkerT< global::EDFilterBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 312 of file WorkerT.cc.

References sistrip::module_.

312  {
313  return module_->transformIndex_(iBranch);
314  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [3/8]

template<>
size_t edm::WorkerT< global::EDProducerBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 316 of file WorkerT.cc.

References sistrip::module_.

316  {
317  return module_->transformIndex_(iBranch);
318  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [4/8]

template<>
size_t edm::WorkerT< stream::EDProducerAdaptorBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 320 of file WorkerT.cc.

References sistrip::module_.

320  {
321  return module_->transformIndex_(iBranch);
322  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [5/8]

template<>
size_t edm::WorkerT< limited::EDFilterBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 324 of file WorkerT.cc.

References sistrip::module_.

324  {
325  return module_->transformIndex_(iBranch);
326  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [6/8]

template<>
size_t edm::WorkerT< limited::EDProducerBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 328 of file WorkerT.cc.

References sistrip::module_.

328  {
329  return module_->transformIndex_(iBranch);
330  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [7/8]

template<>
size_t edm::WorkerT< one::EDFilterBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 332 of file WorkerT.cc.

References sistrip::module_.

332  {
333  return module_->transformIndex_(iBranch);
334  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ transformIndex() [8/8]

template<>
size_t edm::WorkerT< one::EDProducerBase >::transformIndex ( edm::BranchDescription const &  iBranch) const
inlineprivatevirtual

Implements edm::Worker.

Definition at line 336 of file WorkerT.cc.

References sistrip::module_.

336  {
337  return module_->transformIndex_(iBranch);
338  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ updateLookup() [1/2]

template<typename T >
void edm::WorkerT< T >::updateLookup ( BranchType  iBranchType,
ProductResolverIndexHelper const &  iHelper 
)
finalvirtual

Implements edm::Worker.

Definition at line 732 of file WorkerT.cc.

References sistrip::module_.

732  {
733  module_->updateLookup(iBranchType, iHelper, mustPrefetchMayGet<T>());
734  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ updateLookup() [2/2]

template<typename T >
void edm::WorkerT< T >::updateLookup ( eventsetup::ESRecordsToProductResolverIndices const &  iPI)
finalvirtual

Implements edm::Worker.

Definition at line 737 of file WorkerT.cc.

References sistrip::module_.

737  {
738  module_->updateLookup(iPI);
739  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ wantsGlobalLuminosityBlocks()

template<typename T >
bool edm::WorkerT< T >::wantsGlobalLuminosityBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 141 of file WorkerT.cc.

References sistrip::module_.

141  {
142  return module_->wantsGlobalLuminosityBlocks();
143  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ wantsGlobalRuns()

template<typename T >
bool edm::WorkerT< T >::wantsGlobalRuns ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 136 of file WorkerT.cc.

References sistrip::module_.

136  {
137  return module_->wantsGlobalRuns();
138  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ wantsInputProcessBlocks()

template<typename T >
bool edm::WorkerT< T >::wantsInputProcessBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 131 of file WorkerT.cc.

References sistrip::module_.

131  {
132  return module_->wantsInputProcessBlocks();
133  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ wantsProcessBlocks()

template<typename T >
bool edm::WorkerT< T >::wantsProcessBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 126 of file WorkerT.cc.

References sistrip::module_.

126  {
127  return module_->wantsProcessBlocks();
128  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ wantsStreamLuminosityBlocks()

template<typename T >
bool edm::WorkerT< T >::wantsStreamLuminosityBlocks ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 151 of file WorkerT.cc.

References sistrip::module_.

151  {
152  return module_->wantsStreamLuminosityBlocks();
153  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ wantsStreamRuns()

template<typename T >
bool edm::WorkerT< T >::wantsStreamRuns ( ) const
finalvirtual

Implements edm::Worker.

Definition at line 146 of file WorkerT.cc.

References sistrip::module_.

146  {
147  return module_->wantsStreamRuns();
148  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

◆ workerType()

template<typename T >
std::string edm::WorkerT< T >::workerType ( ) const
inlineoverrideprivatevirtual

Implements edm::Worker.

Definition at line 557 of file WorkerT.cc.

References sistrip::module_.

557  {
558  return module_->workerType();
559  }
edm::WorkerT::module_
edm::propagate_const< std::shared_ptr< T > > module_
Definition: WorkerT.h:170

Member Data Documentation

◆ module_

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

Definition at line 170 of file WorkerT.h.

Referenced by edm::WorkerT< T >::consumesInfo(), edm::WorkerT< T >::convertCurrentProcessAlias(), edm::WorkerT< T >::doClearModule(), edm::WorkerT< T >::esItemsToGetFrom(), edm::WorkerT< T >::esRecordsToGetFrom(), edm::WorkerT< T >::hasAccumulator(), edm::WorkerT< T >::hasAcquire(), 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 >::setModule(), and edm::WorkerT< T >::WorkerT().

Generated for CMSSW Reference Manual by doxygen 1.8.14