#include <UnscheduledCallProducer.h>

Public Types
using	const_iterator = worker_container::const_iterator

using	worker_container = std::vector< Worker * >

Public Member Functions
void	addWorker (Worker *aWorker)

UnscheduledAuxiliary const &	auxiliary () const

const_iterator	begin () const

const_iterator	end () const

template<typename T >
void	runAccumulatorsAsync (WaitingTask task, typename T::MyPrincipal const &ep, EventSetupImpl const &es, ServiceToken const &token, StreamID streamID, ParentContext const &parentContext, typename T::Context const context)

template<typename T , typename U >
void	runNowAsync (WaitingTask task, typename T::MyPrincipal &p, EventSetupImpl const &es, ServiceToken const &token, StreamID streamID, typename T::Context const topContext, U const *context) const

void	setEventSetup (EventSetupImpl const &iSetup)

	UnscheduledCallProducer (ActivityRegistry &iReg)

Private Member Functions
template<typename T , typename ID >
void	addContextToException (cms::Exception &ex, Worker const *worker, ID const &id) const

Private Attributes
worker_container	accumulatorWorkers_

UnscheduledAuxiliary	aux_

worker_container	unscheduledWorkers_

Detailed Description

Definition at line 35 of file UnscheduledCallProducer.h.

Member Typedef Documentation

◆ const_iterator

using edm::UnscheduledCallProducer::const_iterator = worker_container::const_iterator

Definition at line 38 of file UnscheduledCallProducer.h.

◆ worker_container

using edm::UnscheduledCallProducer::worker_container = std::vector<Worker*>

Definition at line 37 of file UnscheduledCallProducer.h.

Constructor & Destructor Documentation

◆ UnscheduledCallProducer()

edm::UnscheduledCallProducer::UnscheduledCallProducer ( ActivityRegistry & iReg )

inline

Definition at line 40 of file UnscheduledCallProducer.h.

                                                     : unscheduledWorkers_() {
       aux_.preModuleDelayedGetSignal_.connect(std::cref(iReg.preModuleEventDelayedGetSignal_));
       aux_.postModuleDelayedGetSignal_.connect(std::cref(iReg.postModuleEventDelayedGetSignal_));
     }

References aux_, edm::signalslot::Signal< T >::connect(), edm::UnscheduledAuxiliary::postModuleDelayedGetSignal_, edm::ActivityRegistry::postModuleEventDelayedGetSignal_, edm::UnscheduledAuxiliary::preModuleDelayedGetSignal_, and edm::ActivityRegistry::preModuleEventDelayedGetSignal_.

Member Function Documentation

◆ addContextToException()

template<typename T , typename ID >

void edm::UnscheduledCallProducer::addContextToException	(	cms::Exception &	ex,
		Worker const *	worker,
		ID const &	id
	)		const

inlineprivate

Definition at line 97 of file UnscheduledCallProducer.h.

                                                                                            {
       std::ostringstream ost;
       ost << "Processing " << T::transitionName() << " " << id;
       ex.addContext(ost.str());
     }

References cms::Exception::addContext(), and triggerObjects_cff::id.

◆ addWorker()

void edm::UnscheduledCallProducer::addWorker ( Worker * aWorker )

inline

Definition at line 44 of file UnscheduledCallProducer.h.

                                     {
       assert(nullptr != aWorker);
       unscheduledWorkers_.push_back(aWorker);
       if (aWorker->hasAccumulator()) {
         accumulatorWorkers_.push_back(aWorker);
       }
     }

References accumulatorWorkers_, cms::cuda::assert(), edm::Worker::hasAccumulator(), and unscheduledWorkers_.

Referenced by edm::WorkerManager::addToUnscheduledWorkers().

◆ auxiliary()

UnscheduledAuxiliary const& edm::UnscheduledCallProducer::auxiliary ( ) const

inline

Definition at line 54 of file UnscheduledCallProducer.h.

54 { return aux_; }

References aux_.

Referenced by edm::WorkerManager::setupOnDemandSystem().

◆ begin()

const_iterator edm::UnscheduledCallProducer::begin ( void ) const

inline

Definition at line 56 of file UnscheduledCallProducer.h.

56 { return unscheduledWorkers_.begin(); }

References unscheduledWorkers_.

◆ end()

const_iterator edm::UnscheduledCallProducer::end ( void ) const

inline

Definition at line 57 of file UnscheduledCallProducer.h.

57 { return unscheduledWorkers_.end(); }

References unscheduledWorkers_.

Referenced by Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

◆ runAccumulatorsAsync()

template<typename T >

void edm::UnscheduledCallProducer::runAccumulatorsAsync	(	WaitingTask *	task,
		typename T::MyPrincipal const &	ep,
		EventSetupImpl const &	es,
		ServiceToken const &	token,
		StreamID	streamID,
		ParentContext const &	parentContext,
		typename T::Context const *	context
	)

inline

Definition at line 83 of file UnscheduledCallProducer.h.

                                                                 {
       for (auto worker : accumulatorWorkers_) {
         worker->doWorkAsync<T>(task, ep, es, token, streamID, parentContext, context);
       }
     }

References accumulatorWorkers_, SiStripBadComponentsDQMServiceTemplate_cfg::ep, TrackValidation_cff::task, and unpackBuffers-CaloStage2::token.

Referenced by edm::WorkerManager::processAccumulatorsAsync().

◆ runNowAsync()

template<typename T , typename U >

void edm::UnscheduledCallProducer::runNowAsync	(	WaitingTask *	task,
		typename T::MyPrincipal &	p,
		EventSetupImpl const &	es,
		ServiceToken const &	token,
		StreamID	streamID,
		typename T::Context const *	topContext,
		U const *	context
	)		const

inline

Definition at line 60 of file UnscheduledCallProducer.h.

                                              {
       //do nothing for event since we will run when requested
       if (!T::isEvent_) {
         for (auto worker : unscheduledWorkers_) {
           ParentContext parentContext(context);
  
           // We do not need to run prefetching here because this only handles
           // stream transitions for runs and lumis. There are no products put
           // into the runs or lumis in stream transitions, so there can be
           // no data dependencies which require prefetching. Prefetching is
           // needed for global transitions, but they are run elsewhere.
           worker->doWorkNoPrefetchingAsync<T>(task, p, es, token, streamID, parentContext, topContext);
         }
       }
     }