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 }
 
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 noexcept final
 
bool wantsGlobalRuns () const noexcept final
 
bool wantsInputProcessBlocks () const noexcept final
 
bool wantsProcessBlocks () const noexcept final
 
bool wantsStreamLuminosityBlocks () const noexcept final
 
bool wantsStreamRuns () const noexcept final
 
 WorkerT (std::shared_ptr< T >, ModuleDescription const &, ExceptionToActionTable const *actions)
 
 ~WorkerT () override
 
- Public Member Functions inherited from edm::Worker
void addedToPath () noexcept
 
void beginJob (GlobalContext const &)
 
void beginStream (StreamID, StreamContext const &)
 
void callWhenDoneAsync (WaitingTaskHolder task)
 
void clearCounters () noexcept
 
void clearModule ()
 
ModuleDescription const * description () const noexcept
 
void doTransformAsync (WaitingTaskHolder, size_t iTransformIndex, EventPrincipal const &, ServiceToken const &, StreamID, ModuleCallingContext const &, StreamContext const *) noexcept
 
template<typename T >
void doWorkAsync (WaitingTaskHolder, typename T::TransitionInfoType const &, ServiceToken const &, StreamID, ParentContext const &, typename T::Context const *) noexcept
 
template<typename T >
void doWorkNoPrefetchingAsync (WaitingTaskHolder, typename T::TransitionInfoType const &, ServiceToken const &, StreamID, ParentContext const &, typename T::Context const *) noexcept
 
void endJob (GlobalContext const &)
 
void endStream (StreamID, StreamContext const &)
 
Worker & operator= (Worker const &)=delete
 
void postDoEvent (EventPrincipal const &)
 
void prePrefetchSelectionAsync (oneapi::tbb::task_group &, WaitingTask *task, ServiceToken const &, StreamID stream, EventPrincipal const *) noexcept
 
void prePrefetchSelectionAsync (oneapi::tbb::task_group &, WaitingTask *task, ServiceToken const &, StreamID stream, void const *) noexcept
 
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 *) noexcept
 
void setActivityRegistry (std::shared_ptr< ActivityRegistry > areg)
 
void setEarlyDeleteHelper (EarlyDeleteHelper *iHelper)
 
void skipOnPath (EventPrincipal const &iEvent)
 
State state () const noexcept
 
int timesExcept () const noexcept
 
int timesFailed () const noexcept
 
int timesPass () const noexcept
 
int timesPassed () const noexcept
 
int timesRun () const noexcept
 
int timesVisited () const noexcept
 
edm::WaitingTaskList & waitingTaskList () noexcept
 
 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 noexcept override
 
bool hasAcquire () const noexcept 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 &) noexcept final
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
template<>
void implDoTransformAsync (WaitingTaskHolder task, size_t iTransformIndex, EventPrincipal const &iEvent, ParentContext const &iParent, ServiceWeakToken const &weakToken) noexcept
 
void implEndJob () override
 
void implEndStream (StreamID) override
 
bool implNeedToRunSelection () const noexcept final
 
template<>
bool implNeedToRunSelection () const noexcept
 
template<>
bool implNeedToRunSelection () const noexcept
 
template<>
bool implNeedToRunSelection () const noexcept
 
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 noexcept final
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
template<>
ProductResolverIndex itemToGetForTransform (size_t iTransformIndex) const noexcept
 
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 noexcept 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 noexcept final
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
template<>
size_t transformIndex (edm::BranchDescription const &iBranch) const noexcept
 
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:82

◆ ~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 580 of file WorkerT.cc.

References sistrip::module_.

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

580  {
581  module_->doBeginStream(id);
582  }
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 596 of file WorkerT.cc.

References sistrip::module_.

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

596  {
597  module_->doEndStream(id);
598  }
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 470 of file WorkerT.cc.

References info(), and sistrip::module_.

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

473  {
474  module_->doStreamBeginRun(id, info, mcc);
475  }
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 519 of file WorkerT.cc.

References info(), and sistrip::module_.

522  {
523  module_->doStreamBeginLuminosityBlock(id, info, mcc);
524  }
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 479 of file WorkerT.cc.

References info(), and sistrip::module_.

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

479  {
480  module_->doStreamEndRun(id, info, mcc);
481  }
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 528 of file WorkerT.cc.

References info(), and sistrip::module_.

528  {
529  module_->doStreamEndLuminosityBlock(id, info, mcc);
530  }
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
inlineoverrideprivatevirtualnoexcept

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
inlineoverrideprivatevirtualnoexcept

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

References sistrip::module_.

569  {
570  module_->doBeginJob();
571  }
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 585 of file WorkerT.cc.

References or, and relativeConstraints::value.

585  {
586  std::conditional_t<workerimpl::has_stream_functions<T>::value or
587  workerimpl::has_only_stream_transition_functions<T>::value,
588  workerimpl::DoBeginStream<T>,
589  workerimpl::DoNothing>
590  might_call;
591  might_call(this, id);
592  }
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:300
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:82

◆ implDoAccessInputProcessBlock()

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

Implements edm::Worker.

Definition at line 451 of file WorkerT.cc.

References sistrip::module_.

451  {
452  module_->doAccessInputProcessBlock(pbp, mcc);
453  return true;
454  }
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:300
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:300
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:300
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:300
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:300
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 463 of file WorkerT.cc.

References info(), and sistrip::module_.

463  {
464  module_->doBeginRun(info, mcc);
465  return true;
466  }
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 512 of file WorkerT.cc.

References info(), and sistrip::module_.

512  {
513  module_->doBeginLuminosityBlock(info, mcc);
514  return true;
515  }
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 445 of file WorkerT.cc.

References sistrip::module_.

445  {
446  module_->doBeginProcessBlock(pbp, mcc);
447  return true;
448  }
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 506 of file WorkerT.cc.

References info(), and sistrip::module_.

506  {
507  module_->doEndRun(info, mcc);
508  return true;
509  }
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 558 of file WorkerT.cc.

References info(), and sistrip::module_.

558  {
559  module_->doEndLuminosityBlock(info, mcc);
560  return true;
561  }
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 457 of file WorkerT.cc.

References sistrip::module_.

457  {
458  module_->doEndProcessBlock(pbp, mcc);
459  return true;
460  }
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 387 of file WorkerT.cc.

389  {
390  return true;
391  }

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

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

403  {
404  return module_->prePrefetchSelection(id, ep, mcc);
405  }
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 417 of file WorkerT.cc.

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

419  {
420  return module_->prePrefetchSelection(id, ep, mcc);
421  }
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 433 of file WorkerT.cc.

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

435  {
436  return module_->prePrefetchSelection(id, ep, mcc);
437  }
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 484 of file WorkerT.cc.

References info(), and relativeConstraints::value.

486  {
487  std::conditional_t<workerimpl::has_stream_functions<T>::value,
488  workerimpl::DoStreamBeginTrans<T, RunTransitionInfo const>,
489  workerimpl::DoNothing>
490  might_call;
491  might_call(this, id, info, mcc);
492  return true;
493  }
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 533 of file WorkerT.cc.

References info(), and relativeConstraints::value.

535  {
536  std::conditional_t<workerimpl::has_stream_functions<T>::value,
537  workerimpl::DoStreamBeginTrans<T, LumiTransitionInfo>,
538  workerimpl::DoNothing>
539  might_call;
540  might_call(this, id, info, mcc);
541  return true;
542  }
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 496 of file WorkerT.cc.

References info(), and relativeConstraints::value.

496  {
497  std::conditional_t<workerimpl::has_stream_functions<T>::value,
498  workerimpl::DoStreamEndTrans<T, RunTransitionInfo const>,
499  workerimpl::DoNothing>
500  might_call;
501  might_call(this, id, info, mcc);
502  return true;
503  }
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 545 of file WorkerT.cc.

References info(), and relativeConstraints::value.

547  {
548  std::conditional_t<workerimpl::has_stream_functions<T>::value,
549  workerimpl::DoStreamEndTrans<T, LumiTransitionInfo>,
550  workerimpl::DoNothing>
551  might_call;
552  might_call(this, id, info, mcc);
553 
554  return true;
555  }
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 
)
inlinefinalprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 246 of file WorkerT.cc.

References CMS_SA_ALLOW, iEvent, edm::ModuleCallingContext::kRunning, 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:300
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 
)
inlineprivatevirtualnoexcept

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 
)
inlineprivatevirtualnoexcept

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 
)
inlineprivatevirtualnoexcept

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 
)
inlineprivatevirtualnoexcept

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 
)
inlineprivatevirtualnoexcept

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 
)
inlineprivatevirtualnoexcept

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 
)
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 301 of file WorkerT.cc.

305  {
306  }

◆ implEndJob()

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

Implements edm::Worker.

Definition at line 574 of file WorkerT.cc.

References sistrip::module_.

574  {
575  module_->doEndJob();
576  }
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 601 of file WorkerT.cc.

References or, and relativeConstraints::value.

601  {
602  std::conditional_t<workerimpl::has_stream_functions<T>::value or
603  workerimpl::has_only_stream_transition_functions<T>::value,
604  workerimpl::DoEndStream<T>,
605  workerimpl::DoNothing>
606  might_call;
607  might_call(this, id);
608  }
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
inlinefinalprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 382 of file WorkerT.cc.

382  {
383  return false;
384  }

◆ implNeedToRunSelection() [2/4]

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

Implements edm::Worker.

Definition at line 396 of file WorkerT.cc.

396  {
397  return true;
398  }

◆ implNeedToRunSelection() [3/4]

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

Implements edm::Worker.

Definition at line 413 of file WorkerT.cc.

413  {
414  return true;
415  }

◆ implNeedToRunSelection() [4/4]

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

Implements edm::Worker.

Definition at line 429 of file WorkerT.cc.

429  {
430  return true;
431  }

◆ implRegisterThinnedAssociations()

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

Implements edm::Worker.

Definition at line 626 of file WorkerT.cc.

References sistrip::module_.

627  {
628  module_->doRegisterThinnedAssociations(registry, helper);
629  }
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 616 of file WorkerT.cc.

References sistrip::module_.

616  {
617  module_->doRespondToCloseInputFile(fb);
618  }
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 621 of file WorkerT.cc.

References sistrip::module_.

621  {
622  module_->doRespondToCloseOutputFile();
623  }
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 611 of file WorkerT.cc.

References sistrip::module_.

611  {
612  module_->doRespondToOpenInputFile(fb);
613  }
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 393 of file WorkerT.cc.

393 {}

◆ itemsToGetForSelection() [2/4]

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

Implements edm::Worker.

Definition at line 407 of file WorkerT.cc.

References sistrip::module_.

408  {
409  iItems = module_->productsUsedBySelection();
410  }
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 423 of file WorkerT.cc.

References sistrip::module_.

424  {
425  iItems = module_->productsUsedBySelection();
426  }
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 439 of file WorkerT.cc.

References sistrip::module_.

440  {
441  iItems = module_->productsUsedBySelection();
442  }
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
inlinefinalprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 343 of file WorkerT.cc.

343  {
344  return -1;
345  }

◆ itemToGetForTransform() [2/8]

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

Implements edm::Worker.

Definition at line 347 of file WorkerT.cc.

References sistrip::module_.

348  {
349  return module_->transformPrefetch_(iTransformIndex);
350  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 352 of file WorkerT.cc.

References sistrip::module_.

353  {
354  return module_->transformPrefetch_(iTransformIndex);
355  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 357 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() [5/8]

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

Implements edm::Worker.

Definition at line 362 of file WorkerT.cc.

References sistrip::module_.

363  {
364  return module_->transformPrefetch_(iTransformIndex);
365  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 367 of file WorkerT.cc.

References sistrip::module_.

368  {
369  return module_->transformPrefetch_(iTransformIndex);
370  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 372 of file WorkerT.cc.

References sistrip::module_.

372  {
373  return module_->transformPrefetch_(iTransformIndex);
374  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 376 of file WorkerT.cc.

References sistrip::module_.

377  {
378  return module_->transformPrefetch_(iTransformIndex);
379  }
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 859 of file WorkerT.cc.

References edm::Worker::kOne.

859  {
860  return Worker::kOne;
861  }

◆ moduleConcurrencyType() [3/16]

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

Implements edm::Worker.

Definition at line 863 of file WorkerT.cc.

References edm::Worker::kOne.

863  {
864  return Worker::kOne;
865  }

◆ moduleConcurrencyType() [4/16]

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

Implements edm::Worker.

Definition at line 867 of file WorkerT.cc.

References edm::Worker::kOne.

867  {
868  return Worker::kOne;
869  }

◆ moduleConcurrencyType() [5/16]

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

Implements edm::Worker.

Definition at line 871 of file WorkerT.cc.

References edm::Worker::kOne.

871  {
872  return Worker::kOne;
873  }

◆ moduleConcurrencyType() [6/16]

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

Implements edm::Worker.

Definition at line 876 of file WorkerT.cc.

References edm::Worker::kGlobal.

876  {
877  return Worker::kGlobal;
878  }

◆ moduleConcurrencyType() [7/16]

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

Implements edm::Worker.

Definition at line 880 of file WorkerT.cc.

References edm::Worker::kGlobal.

880  {
881  return Worker::kGlobal;
882  }

◆ moduleConcurrencyType() [8/16]

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

Implements edm::Worker.

Definition at line 884 of file WorkerT.cc.

References edm::Worker::kGlobal.

884  {
885  return Worker::kGlobal;
886  }

◆ moduleConcurrencyType() [9/16]

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

Implements edm::Worker.

Definition at line 888 of file WorkerT.cc.

References edm::Worker::kGlobal.

888  {
889  return Worker::kGlobal;
890  }

◆ moduleConcurrencyType() [10/16]

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

Implements edm::Worker.

Definition at line 893 of file WorkerT.cc.

References edm::Worker::kLimited.

893  {
894  return Worker::kLimited;
895  }

◆ moduleConcurrencyType() [11/16]

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

Implements edm::Worker.

Definition at line 897 of file WorkerT.cc.

References edm::Worker::kLimited.

897  {
898  return Worker::kLimited;
899  }

◆ moduleConcurrencyType() [12/16]

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

Implements edm::Worker.

Definition at line 901 of file WorkerT.cc.

References edm::Worker::kLimited.

901  {
902  return Worker::kLimited;
903  }

◆ moduleConcurrencyType() [13/16]

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

Implements edm::Worker.

Definition at line 905 of file WorkerT.cc.

References edm::Worker::kLimited.

905  {
906  return Worker::kLimited;
907  }

◆ moduleConcurrencyType() [14/16]

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

Implements edm::Worker.

Definition at line 910 of file WorkerT.cc.

References edm::Worker::kStream.

910  {
911  return Worker::kStream;
912  }

◆ moduleConcurrencyType() [15/16]

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

Implements edm::Worker.

Definition at line 914 of file WorkerT.cc.

References edm::Worker::kStream.

914  {
915  return Worker::kStream;
916  }

◆ moduleConcurrencyType() [16/16]

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

Implements edm::Worker.

Definition at line 918 of file WorkerT.cc.

References edm::Worker::kStream.

918  {
919  return Worker::kStream;
920  }

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

References edm::Worker::kProducer.

795  {
796  return Worker::kProducer;
797  }

◆ moduleType() [3/16]

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

Implements edm::Worker.

Definition at line 799 of file WorkerT.cc.

References edm::Worker::kFilter.

799  {
800  return Worker::kFilter;
801  }

◆ moduleType() [4/16]

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

Implements edm::Worker.

Definition at line 803 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

803  {
804  return Worker::kAnalyzer;
805  }

◆ moduleType() [5/16]

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

Implements edm::Worker.

Definition at line 807 of file WorkerT.cc.

References edm::Worker::kOutputModule.

807  {
808  return Worker::kOutputModule;
809  }

◆ moduleType() [6/16]

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

Implements edm::Worker.

Definition at line 812 of file WorkerT.cc.

References edm::Worker::kProducer.

812  {
813  return Worker::kProducer;
814  }

◆ moduleType() [7/16]

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

Implements edm::Worker.

Definition at line 816 of file WorkerT.cc.

References edm::Worker::kFilter.

816  {
817  return Worker::kFilter;
818  }

◆ moduleType() [8/16]

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

Implements edm::Worker.

Definition at line 820 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

820  {
821  return Worker::kAnalyzer;
822  }

◆ moduleType() [9/16]

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

Implements edm::Worker.

Definition at line 824 of file WorkerT.cc.

References edm::Worker::kOutputModule.

824  {
825  return Worker::kOutputModule;
826  }

◆ moduleType() [10/16]

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

Implements edm::Worker.

Definition at line 829 of file WorkerT.cc.

References edm::Worker::kProducer.

829  {
830  return Worker::kProducer;
831  }

◆ moduleType() [11/16]

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

Implements edm::Worker.

Definition at line 833 of file WorkerT.cc.

References edm::Worker::kFilter.

833  {
834  return Worker::kFilter;
835  }

◆ moduleType() [12/16]

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

Implements edm::Worker.

Definition at line 837 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

837  {
838  return Worker::kAnalyzer;
839  }

◆ moduleType() [13/16]

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

Implements edm::Worker.

Definition at line 841 of file WorkerT.cc.

References edm::Worker::kOutputModule.

841  {
842  return Worker::kOutputModule;
843  }

◆ moduleType() [14/16]

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

Implements edm::Worker.

Definition at line 846 of file WorkerT.cc.

References edm::Worker::kProducer.

846  {
847  return Worker::kProducer;
848  }

◆ moduleType() [15/16]

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

Implements edm::Worker.

Definition at line 850 of file WorkerT.cc.

References edm::Worker::kFilter.

850  {
851  return Worker::kFilter;
852  }

◆ moduleType() [16/16]

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

Implements edm::Worker.

Definition at line 854 of file WorkerT.cc.

References edm::Worker::kAnalyzer.

854  {
855  return Worker::kAnalyzer;
856  }

◆ preActionBeforeRunEventAsync()

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

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

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

790  {
791  resolvePutIndiciesImpl(&module(), iBranchType, iIndicies, description()->moduleLabel());
792  }
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 noexcept
Definition: Worker.h:200

◆ selectInputProcessBlocks()

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

Implements edm::Worker.

Definition at line 749 of file WorkerT.cc.

References sistrip::module_.

750  {
751  module_->selectInputProcessBlocks(productRegistry, processBlockHelperBase);
752  }
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 632 of file WorkerT.cc.

632  {
633  return Worker::TaskQueueAdaptor{};
634  }

◆ serializeRunModule() [2/9]

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

Implements edm::Worker.

Definition at line 636 of file WorkerT.cc.

References sistrip::module_.

636  {
637  return &(module_->sharedResourcesAcquirer().serialQueueChain());
638  }
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 640 of file WorkerT.cc.

References sistrip::module_.

640  {
641  return &(module_->sharedResourcesAcquirer().serialQueueChain());
642  }
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 644 of file WorkerT.cc.

References sistrip::module_.

644  {
645  return &(module_->sharedResourcesAcquirer().serialQueueChain());
646  }
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 648 of file WorkerT.cc.

References sistrip::module_.

648  {
649  return &(module_->sharedResourcesAcquirer().serialQueueChain());
650  }
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 652 of file WorkerT.cc.

References sistrip::module_.

652  {
653  return &(module_->queue());
654  }
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 656 of file WorkerT.cc.

References sistrip::module_.

656  {
657  return &(module_->queue());
658  }
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 660 of file WorkerT.cc.

References sistrip::module_.

660  {
661  return &(module_->queue());
662  }
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 664 of file WorkerT.cc.

References sistrip::module_.

664  {
665  return &(module_->queue());
666  }
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:281
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
inlinefinalprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 309 of file WorkerT.cc.

309  {
310  return -1;
311  }

◆ transformIndex() [2/8]

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

Implements edm::Worker.

Definition at line 313 of file WorkerT.cc.

References sistrip::module_.

313  {
314  return module_->transformIndex_(iBranch);
315  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 317 of file WorkerT.cc.

References sistrip::module_.

317  {
318  return module_->transformIndex_(iBranch);
319  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 321 of file WorkerT.cc.

References sistrip::module_.

322  {
323  return module_->transformIndex_(iBranch);
324  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 326 of file WorkerT.cc.

References sistrip::module_.

326  {
327  return module_->transformIndex_(iBranch);
328  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 330 of file WorkerT.cc.

References sistrip::module_.

330  {
331  return module_->transformIndex_(iBranch);
332  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 334 of file WorkerT.cc.

References sistrip::module_.

334  {
335  return module_->transformIndex_(iBranch);
336  }
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
inlineprivatevirtualnoexcept

Implements edm::Worker.

Definition at line 338 of file WorkerT.cc.

References sistrip::module_.

338  {
339  return module_->transformIndex_(iBranch);
340  }
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 739 of file WorkerT.cc.

References sistrip::module_.

739  {
740  module_->updateLookup(iBranchType, iHelper, mustPrefetchMayGet<T>());
741  }
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 744 of file WorkerT.cc.

References sistrip::module_.

744  {
745  module_->updateLookup(iPI);
746  }
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
finalvirtualnoexcept

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
finalvirtualnoexcept

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
finalvirtualnoexcept

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
finalvirtualnoexcept

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
finalvirtualnoexcept

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
finalvirtualnoexcept

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

References sistrip::module_.

564  {
565  return module_->workerType();
566  }
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