edm::SecondaryEventProvider Class Reference

#include <SecondaryEventProvider.h>

Public Member Functions
void	beginJob (ProductRegistry const &iRegistry, eventsetup::ESRecordsToProductResolverIndices const &)
void	beginLuminosityBlock (LuminosityBlockPrincipal &lumi, const edm::EventSetupImpl &setup, ModuleCallingContext const *, StreamContext &sContext)
void	beginRun (RunPrincipal &run, const edm::EventSetupImpl &setup, ModuleCallingContext const *, StreamContext &sContext)
void	beginStream (edm::StreamID iID, StreamContext &sContext)
void	endJob ()
void	endLuminosityBlock (LuminosityBlockPrincipal &lumi, const edm::EventSetupImpl &setup, ModuleCallingContext const *, StreamContext &sContext)
void	endRun (RunPrincipal &run, const edm::EventSetupImpl &setup, ModuleCallingContext const *, StreamContext &sContext)
void	endStream (edm::StreamID iID, StreamContext &sContext)
	SecondaryEventProvider (std::vector< ParameterSet > &psets, ProductRegistry &pregistry, std::shared_ptr< ProcessConfiguration > processConfiguration)
void	setupPileUpEvent (EventPrincipal &ep, const EventSetupImpl &setup, StreamContext &sContext)

Private Attributes
std::unique_ptr< ExceptionToActionTable >	exceptionToActionTable_
WorkerManager	workerManager_

Detailed Description

Definition at line 14 of file SecondaryEventProvider.h.

Constructor & Destructor Documentation

SecondaryEventProvider()

edm::SecondaryEventProvider::SecondaryEventProvider	(	std::vector< ParameterSet > &	psets,
		ProductRegistry &	pregistry,
		std::shared_ptr< ProcessConfiguration >	processConfiguration
	)

Definition at line 51 of file SecondaryEventProvider.cc.

References edm::WorkerManager::addToUnscheduledWorkers(), label, muonDTDigis_cfi::pset, edm::ProductRegistry::setUnscheduledProducts(), AlCaHLTBitMon_QueryRunRegistry::string, and workerManager_.

      : exceptionToActionTable_(new ExceptionToActionTable),
        // no type resolver for modules in SecondaryEventProvider for now
        workerManager_(std::make_shared<ActivityRegistry>(), *exceptionToActionTable_, nullptr) {
    std::vector<std::string> shouldBeUsedLabels;
    std::set<std::string> unscheduledLabels;
    const PreallocationConfiguration preallocConfig;
    for (auto& pset : psets) {
      std::string label = pset.getParameter<std::string>("@module_label");
      workerManager_.addToUnscheduledWorkers(
          pset, preg, &preallocConfig, processConfiguration, label, unscheduledLabels, shouldBeUsedLabels);
    }
    if (!unscheduledLabels.empty()) {
      preg.setUnscheduledProducts(unscheduledLabels);
    }
  }  // SecondaryEventProvider::SecondaryEventProvider

Member Function Documentation

beginJob()

void edm::SecondaryEventProvider::beginJob	(	ProductRegistry const &	iRegistry,
		eventsetup::ESRecordsToProductResolverIndices const &	iIndices
	)

Definition at line 70 of file SecondaryEventProvider.cc.

References edm::WorkerManager::beginJob(), and workerManager_.

                                                                                                     {
    ProcessBlockHelper dummyProcessBlockHelper;
    workerManager_.beginJob(iRegistry, iIndices, dummyProcessBlockHelper);
  }

beginLuminosityBlock()

void edm::SecondaryEventProvider::beginLuminosityBlock	(	LuminosityBlockPrincipal &	lumi,
		const edm::EventSetupImpl &	setup,
		ModuleCallingContext const *	mcc,
		StreamContext &	sContext
	)

Definition at line 89 of file SecondaryEventProvider.cc.

References info(), edm::StreamID::invalidStreamID(), singleTopDQM_cfi::setup, edm::StreamContext::streamID(), and workerManager_.

                                                                             {
    LumiTransitionInfo info(lumi, setup);
    processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalBegin>>(
        workerManager_, info, StreamID::invalidStreamID(), nullptr, mcc);
    processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamBegin>>(
        workerManager_, info, sContext.streamID(), &sContext, mcc);
  }

beginRun()

void edm::SecondaryEventProvider::beginRun	(	RunPrincipal &	run,
		const edm::EventSetupImpl &	setup,
		ModuleCallingContext const *	mcc,
		StreamContext &	sContext
	)

Definition at line 78 of file SecondaryEventProvider.cc.

References info(), edm::StreamID::invalidStreamID(), writedatasetfile::run, singleTopDQM_cfi::setup, edm::StreamContext::streamID(), and workerManager_.

                                                                 {
    RunTransitionInfo info(run, setup);
    processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionGlobalBegin>>(
        workerManager_, info, StreamID::invalidStreamID(), nullptr, mcc);
    processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionStreamBegin>>(
        workerManager_, info, sContext.streamID(), &sContext, mcc);
  }

beginStream()

void edm::SecondaryEventProvider::beginStream	(	edm::StreamID	iID,
		StreamContext &	sContext
	)

Definition at line 158 of file SecondaryEventProvider.cc.

References edm::WorkerManager::beginStream(), and workerManager_.

                                                                                   {
    workerManager_.beginStream(iID, sContext);
  }

endJob()

void edm::SecondaryEventProvider::endJob ( void  )

inline

Definition at line 41 of file SecondaryEventProvider.h.

References edm::WorkerManager::endJob(), and workerManager_.

{ workerManager_.endJob(); }

endLuminosityBlock()

void edm::SecondaryEventProvider::endLuminosityBlock	(	LuminosityBlockPrincipal &	lumi,
		const edm::EventSetupImpl &	setup,
		ModuleCallingContext const *	mcc,
		StreamContext &	sContext
	)

Definition at line 111 of file SecondaryEventProvider.cc.

References info(), edm::StreamID::invalidStreamID(), singleTopDQM_cfi::setup, edm::StreamContext::streamID(), and workerManager_.

                                                                           {
    LumiTransitionInfo info(lumi, setup);
    processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamEnd>>(
        workerManager_, info, sContext.streamID(), &sContext, mcc);
    processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalEnd>>(
        workerManager_, info, StreamID::invalidStreamID(), nullptr, mcc);
  }

endRun()

void edm::SecondaryEventProvider::endRun	(	RunPrincipal &	run,
		const edm::EventSetupImpl &	setup,
		ModuleCallingContext const *	mcc,
		StreamContext &	sContext
	)

Definition at line 100 of file SecondaryEventProvider.cc.

References info(), edm::StreamID::invalidStreamID(), writedatasetfile::run, singleTopDQM_cfi::setup, edm::StreamContext::streamID(), and workerManager_.

                                                               {
    RunTransitionInfo info(run, setup);
    processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionStreamEnd>>(
        workerManager_, info, sContext.streamID(), &sContext, mcc);
    processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionGlobalEnd>>(
        workerManager_, info, StreamID::invalidStreamID(), nullptr, mcc);
  }

endStream()

void edm::SecondaryEventProvider::endStream	(	edm::StreamID	iID,
		StreamContext &	sContext
	)

Definition at line 162 of file SecondaryEventProvider.cc.

References edm::WorkerManager::endStream(), and workerManager_.

                                                                                 {
    workerManager_.endStream(iID, sContext);
  }

setupPileUpEvent()

void edm::SecondaryEventProvider::setupPileUpEvent	(	EventPrincipal &	ep,
		const EventSetupImpl &	setup,
		StreamContext &	sContext
	)

Definition at line 122 of file SecondaryEventProvider.cc.

References edm::addContextAndPrintException(), cms::Exception::context(), SiStripBadComponentsDQMServiceTemplate_cfg::ep, info(), edm::ServiceRegistry::instance(), edm::ServiceRegistry::presentToken(), singleTopDQM_cfi::setup, edm::WorkerManager::setupOnDemandSystem(), edm::WorkerManager::setupResolvers(), edm::StreamContext::streamID(), edm::syncWait(), unpackBuffers-CaloStage2::token, edm::WorkerManager::unscheduledWorkers(), workerManager_, and edm::convertException::wrap().

                                                                         {
    workerManager_.setupResolvers(ep);
    EventTransitionInfo info(ep, setup);
    workerManager_.setupOnDemandSystem(info);

    if (workerManager_.unscheduledWorkers().empty()) {
      return;
    }
    auto token = edm::ServiceRegistry::instance().presentToken();
    //we need the arena to guarantee that the syncWait will return to this thread
    // and not cause this callstack to possibly be moved to a new thread
    ParentContext pc(&sContext);
    std::exception_ptr exceptPtr = tbb::this_task_arena::isolate([&]() {
      return edm::syncWait([&](edm::WaitingTaskHolder&& iHolder) {
        for (auto& worker : workerManager_.unscheduledWorkers()) {
          worker->doWorkAsync<OccurrenceTraits<EventPrincipal, BranchActionStreamBegin>>(
              iHolder, info, token, sContext.streamID(), pc, &sContext);
        }
      });
    });
    if (exceptPtr) {
      try {
        edm::convertException::wrap([&]() { std::rethrow_exception(exceptPtr); });
      } catch (cms::Exception& ex) {
        if (ex.context().empty()) {
          edm::addContextAndPrintException("Calling SecondaryEventProvider", ex, false);
        } else {
          edm::addContextAndPrintException("", ex, false);
        }
        throw;
      }
    }
  }

Member Data Documentation

exceptionToActionTable_

std::unique_ptr<ExceptionToActionTable> edm::SecondaryEventProvider::exceptionToActionTable_

private

Definition at line 47 of file SecondaryEventProvider.h.

workerManager_

WorkerManager edm::SecondaryEventProvider::workerManager_

private

Definition at line 48 of file SecondaryEventProvider.h.

Referenced by beginJob(), beginLuminosityBlock(), beginRun(), beginStream(), endJob(), endLuminosityBlock(), endRun(), endStream(), SecondaryEventProvider(), and setupPileUpEvent().