edm::UnscheduledCallProducer Class Reference

#include <UnscheduledCallProducer.h>

Inheritance diagram for edm::UnscheduledCallProducer:

Classes
class	WorkerLookup

Public Member Functions
void	addWorker (Worker *aWorker)
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
	UnscheduledCallProducer ()
Public Member Functions inherited from edm::UnscheduledHandler
UnscheduledHandler &	operator= (UnscheduledHandler const &)=delete
void	setEventSetup (EventSetup const &iSetup)
bool	tryToFill (std::string const &label, EventPrincipal const &iEvent, ModuleCallingContext const *mcc) const
	returns true if found an EDProducer and ran it More...
	UnscheduledHandler ()
	UnscheduledHandler (UnscheduledHandler const &)=delete
virtual	~UnscheduledHandler ()

Private Member Functions
virtual bool	tryToFillImpl (std::string const &moduleLabel, EventPrincipal const &event, EventSetup const &eventSetup, ModuleCallingContext const *mcc) const override

Private Attributes
WorkerLookup	workerLookup_

Detailed Description

Definition at line 21 of file UnscheduledCallProducer.h.

Constructor & Destructor Documentation

edm::UnscheduledCallProducer::UnscheduledCallProducer ( )

inline

Definition at line 59 of file UnscheduledCallProducer.h.

: UnscheduledHandler(), workerLookup_() {}

Member Function Documentation

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

inline

Definition at line 60 of file UnscheduledCallProducer.h.

References edm::UnscheduledCallProducer::WorkerLookup::add(), assert(), and workerLookup_.

                                    {
      assert(0 != aWorker);
      workerLookup_.add(aWorker);
    }

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

References cms::Exception::addContext(), edm::InLumi, edm::InRun, AlCaHLTBitMon_ParallelJobs::p, and workerLookup_.

                                                                             {
      //do nothing for event since we will run when requested
      if(!T::isEvent_) {
        for(auto worker: workerLookup_) {
          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;
          }
        }
      }
    }

virtual bool edm::UnscheduledCallProducer::tryToFillImpl ( std::string const &  moduleLabel, EventPrincipal const &  event, EventSetup const &  eventSetup, ModuleCallingContext const *  mcc  ) const

inlineoverrideprivatevirtual

Implements edm::UnscheduledHandler.

Definition at line 109 of file UnscheduledCallProducer.h.

References cms::Exception::addContext(), event(), edm::UnscheduledCallProducer::WorkerLookup::find(), edm::ModuleCallingContext::getStreamContext(), and workerLookup_.

                                                                               {
      auto worker =
        workerLookup_.find(moduleLabel);
      if(worker != nullptr) {
        try {
          ParentContext parentContext(mcc);
          worker->doWork<OccurrenceTraits<EventPrincipal, BranchActionStreamBegin> >(event,
              eventSetup, event.streamID(), parentContext, mcc->getStreamContext());
        }
        catch (cms::Exception & ex) {
          std::ostringstream ost;
          ost << "Calling produce method for unscheduled module " 
              << worker->description().moduleName() << "/'"
              << worker->description().moduleLabel() << "'";
          ex.addContext(ost.str());
          throw;
        }
        return true;
      }
      return false;
    }

Member Data Documentation

WorkerLookup edm::UnscheduledCallProducer::workerLookup_

private

Definition at line 133 of file UnscheduledCallProducer.h.

Referenced by addWorker(), runNow(), and tryToFillImpl().