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
template<typename T , typename U >
void	runNowAsync (WaitingTask *task, typename T::MyPrincipal &p, EventSetup const &es, StreamID streamID, typename T::Context const *topContext, U const *context) const
void	setEventSetup (EventSetup 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
UnscheduledAuxiliary	aux_
worker_container	unscheduledWorkers_

Detailed Description

Definition at line 35 of file UnscheduledCallProducer.h.

Member Typedef Documentation

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

Definition at line 39 of file UnscheduledCallProducer.h.

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

Definition at line 38 of file UnscheduledCallProducer.h.

Constructor & Destructor Documentation

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

inline

Definition at line 41 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 75 of file UnscheduledCallProducer.h.

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

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

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

inline

Definition at line 45 of file UnscheduledCallProducer.h.

References unscheduledWorkers_.

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

                                    {
      assert(nullptr != aWorker);
      unscheduledWorkers_.push_back(aWorker);
    }

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

inline

Definition at line 54 of file UnscheduledCallProducer.h.

References aux_.

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

{ return aux_; }

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

inline

Definition at line 56 of file UnscheduledCallProducer.h.

References unscheduledWorkers_.

{ return unscheduledWorkers_.begin(); }

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

inline

Definition at line 57 of file UnscheduledCallProducer.h.

References unscheduledWorkers_.

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

{ return unscheduledWorkers_.end(); }

template<typename T , typename U >

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

inline

Definition at line 60 of file UnscheduledCallProducer.h.

References AlCaHLTBitMon_ParallelJobs::p, 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);
          worker->doWorkNoPrefetchingAsync<T>(task, p, es, streamID, parentContext, topContext);
        }
      }
    }

void edm::UnscheduledCallProducer::setEventSetup ( EventSetup const &  iSetup )

inline

Definition at line 50 of file UnscheduledCallProducer.h.

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

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

                                                 {
      aux_.setEventSetup(&iSetup);
    }

Member Data Documentation

UnscheduledAuxiliary edm::UnscheduledCallProducer::aux_

private

Definition at line 81 of file UnscheduledCallProducer.h.

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

worker_container edm::UnscheduledCallProducer::unscheduledWorkers_

private

Definition at line 80 of file UnscheduledCallProducer.h.

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