#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

void	removeWorker (Worker const *worker)

template<typename T >
void	runAccumulatorsAsync (WaitingTaskHolder task, typename T::TransitionInfoType const &info, ServiceToken const &token, StreamID streamID, ParentContext const &parentContext, typename T::Context const *context)

template<typename T , typename U >
void	runNowAsync (WaitingTaskHolder task, typename T::TransitionInfoType const &info, ServiceToken const &token, StreamID streamID, typename T::Context const topContext, U const context) const

void	setEventTransitionInfo (EventTransitionInfo const &info)

	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 38 of file UnscheduledCallProducer.h.

Member Typedef Documentation

◆ const_iterator

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

Definition at line 41 of file UnscheduledCallProducer.h.

◆ worker_container

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

Definition at line 40 of file UnscheduledCallProducer.h.

Constructor & Destructor Documentation

◆ UnscheduledCallProducer()

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

inline

Definition at line 43 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 105 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 47 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 64 of file UnscheduledCallProducer.h.

64 { return aux_; }

References aux_.

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

◆ begin()

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

inline

Definition at line 66 of file UnscheduledCallProducer.h.

66 { return unscheduledWorkers_.begin(); }

References unscheduledWorkers_.

◆ end()

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

inline

Definition at line 67 of file UnscheduledCallProducer.h.

67 { return unscheduledWorkers_.end(); }

References unscheduledWorkers_.

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

◆ removeWorker()

void edm::UnscheduledCallProducer::removeWorker ( Worker const * worker )

inline

Definition at line 55 of file UnscheduledCallProducer.h.

                                             {
       unscheduledWorkers_.erase(std::remove(unscheduledWorkers_.begin(), unscheduledWorkers_.end(), worker),
                                 unscheduledWorkers_.end());
       accumulatorWorkers_.erase(std::remove(accumulatorWorkers_.begin(), accumulatorWorkers_.end(), worker),
                                 accumulatorWorkers_.end());
     }

References accumulatorWorkers_, MatrixUtil::remove(), and unscheduledWorkers_.

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

◆ runAccumulatorsAsync()

template<typename T >

void edm::UnscheduledCallProducer::runAccumulatorsAsync	(	WaitingTaskHolder	task,
		typename T::TransitionInfoType const &	info,
		ServiceToken const &	token,
		StreamID	streamID,
		ParentContext const &	parentContext,
		typename T::Context const *	context
	)

inline

Definition at line 92 of file UnscheduledCallProducer.h.

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

References accumulatorWorkers_, info(), TrackValidation_cff::task, and unpackBuffers-CaloStage2::token.

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

◆ runNowAsync()

template<typename T , typename U >

void edm::UnscheduledCallProducer::runNowAsync	(	WaitingTaskHolder	task,
		typename T::TransitionInfoType const &	info,
		ServiceToken const &	token,
		StreamID	streamID,
		typename T::Context const *	topContext,
		U const *	context
	)		const

inline

Definition at line 70 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, info, token, streamID, parentContext, topContext);
         }
       }
     }