edm::UnscheduledCallProducer Class Reference

#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

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

Definition at line 41 of file UnscheduledCallProducer.h.

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

Definition at line 40 of file UnscheduledCallProducer.h.

Constructor & Destructor Documentation

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

inline

Definition at line 43 of file UnscheduledCallProducer.h.

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

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

Member Function Documentation

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.

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

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

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

inline

Definition at line 47 of file UnscheduledCallProducer.h.

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

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

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

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

inline

Definition at line 64 of file UnscheduledCallProducer.h.

References aux_.

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

{ return aux_; }

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

inline

Definition at line 66 of file UnscheduledCallProducer.h.

References unscheduledWorkers_.

{ return unscheduledWorkers_.begin(); }

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

inline

Definition at line 67 of file UnscheduledCallProducer.h.

References unscheduledWorkers_.

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

{ return unscheduledWorkers_.end(); }

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

inline

Definition at line 55 of file UnscheduledCallProducer.h.

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

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

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

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.

References accumulatorWorkers_, visDQMUpload::context, info(), and unpackBuffers-CaloStage2::token.

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

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

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.

References info(), unpackBuffers-CaloStage2::token, and unscheduledWorkers_.

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

                                             {
      //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);
        }
      }
    }

void edm::UnscheduledCallProducer::setEventTransitionInfo ( EventTransitionInfo const &  info )

inline

Definition at line 62 of file UnscheduledCallProducer.h.

References aux_, and edm::UnscheduledAuxiliary::setEventTransitionInfo().

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

{ aux_.setEventTransitionInfo(info); }

Member Data Documentation

worker_container edm::UnscheduledCallProducer::accumulatorWorkers_

private

Definition at line 111 of file UnscheduledCallProducer.h.

Referenced by addWorker(), removeWorker(), and runAccumulatorsAsync().

UnscheduledAuxiliary edm::UnscheduledCallProducer::aux_

private

Definition at line 112 of file UnscheduledCallProducer.h.

Referenced by auxiliary(), setEventTransitionInfo(), and UnscheduledCallProducer().

worker_container edm::UnscheduledCallProducer::unscheduledWorkers_

private

Definition at line 110 of file UnscheduledCallProducer.h.

Referenced by addWorker(), begin(), end(), removeWorker(), and runNowAsync().