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	runNow (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 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

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

inline

Definition at line 45 of file UnscheduledCallProducer.h.

References assert(), and unscheduledWorkers_.

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

                                    {
      assert(0 != 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::runNow ( 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 cms::Exception::addContext(), edm::InLumi, edm::InRun, AlCaHLTBitMon_ParallelJobs::p, and unscheduledWorkers_.

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

                                                                             {
      //do nothing for event since we will run when requested
      if(!T::isEvent_) {
        for(auto worker: unscheduledWorkers_) {
          try {
            ParentContext parentContext(context);
            worker->doWork<T>(p, es, streamID, parentContext, topContext);
          }
          catch (cms::Exception & ex) {
            std::ostringstream ost;
            if (T::isEvent_) {
              ost << "Calling event method";
            }
            else if (T::begin_ && T::branchType_ == InRun) {
              ost << "Calling beginRun";
            }
            else if (T::begin_ && T::branchType_ == InLumi) {
              ost << "Calling beginLuminosityBlock";
            }
            else if (!T::begin_ && T::branchType_ == InLumi) {
              ost << "Calling endLuminosityBlock";
            }
            else if (!T::begin_ && T::branchType_ == InRun) {
              ost << "Calling endRun";
            }
            else {
              // It should be impossible to get here ...
              ost << "Calling unknown function";
            }
            ost << " for unscheduled module " << worker->description().moduleName()
                << "/'" << worker->description().moduleLabel() << "'";
            ex.addContext(ost.str());
            ost.str("");
            ost << "Processing " << p.id();
            ex.addContext(ost.str());
            throw;
          }
        }
      }
    }

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

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

worker_container edm::UnscheduledCallProducer::unscheduledWorkers_

private

Definition at line 103 of file UnscheduledCallProducer.h.

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