edm::SecondaryEventProvider Class Reference

#include <SecondaryEventProvider.h>

Public Member Functions
void	beginJob (ProductRegistry const &iRegistry, eventsetup::ESRecordsToProxyIndices 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

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

Definition at line 9 of file SecondaryEventProvider.cc.

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

      : exceptionToActionTable_(new ExceptionToActionTable),
        workerManager_(std::make_shared<ActivityRegistry>(), *exceptionToActionTable_) {
    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

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

Definition at line 27 of file SecondaryEventProvider.cc.

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

                                                                                           {
    workerManager_.beginJob(iRegistry, iIndices);
  }

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

Definition at line 44 of file SecondaryEventProvider.cc.

References edm::StreamID::invalidStreamID(), BXlumiParameters_cfi::lumi, edm::WorkerManager::processOneOccurrence(), singleTopDQM_cfi::setup, edm::StreamContext::streamID(), and workerManager_.

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

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

Definition at line 34 of file SecondaryEventProvider.cc.

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

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

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

Definition at line 79 of file SecondaryEventProvider.cc.

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

Referenced by endJob().

                                                                                   {
    workerManager_.beginStream(iID, sContext);
  }

void edm::SecondaryEventProvider::endJob ( void  )

inline

Definition at line 41 of file SecondaryEventProvider.h.

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

{ workerManager_.endJob(); }

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

Definition at line 64 of file SecondaryEventProvider.cc.

References edm::StreamID::invalidStreamID(), BXlumiParameters_cfi::lumi, edm::WorkerManager::processOneOccurrence(), singleTopDQM_cfi::setup, edm::StreamContext::streamID(), and workerManager_.

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

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

Definition at line 54 of file SecondaryEventProvider.cc.

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

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

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

Definition at line 83 of file SecondaryEventProvider.cc.

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

Referenced by endJob().

                                                                                 {
    workerManager_.endStream(iID, sContext);
  }

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

Definition at line 74 of file SecondaryEventProvider.cc.

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

                                                                         {
    workerManager_.setupOnDemandSystem(ep, setup);
  }

Member Data Documentation

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

private

Definition at line 47 of file SecondaryEventProvider.h.

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().