#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

◆ SecondaryEventProvider()

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

Definition at line 9 of file SecondaryEventProvider.cc.

       : 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

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

Member Function Documentation

◆ beginJob()

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

Definition at line 27 of file SecondaryEventProvider.cc.

                                                                                            {
     workerManager_.beginJob(iRegistry, iIndices);
   }

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

◆ beginLuminosityBlock()

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

Definition at line 44 of file SecondaryEventProvider.cc.

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

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

◆ beginRun()

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

Definition at line 34 of file SecondaryEventProvider.cc.

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

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

◆ beginStream()

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

Definition at line 79 of file SecondaryEventProvider.cc.

                                                                                    {
     workerManager_.beginStream(iID, sContext);
   }

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

◆ endJob()

void edm::SecondaryEventProvider::endJob ( void )

inline

Definition at line 41 of file SecondaryEventProvider.h.

41 { workerManager_.endJob(); }

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

◆ endLuminosityBlock()

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

Definition at line 64 of file SecondaryEventProvider.cc.

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

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

◆ endRun()

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

Definition at line 54 of file SecondaryEventProvider.cc.

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

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

◆ endStream()

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

Definition at line 83 of file SecondaryEventProvider.cc.

                                                                                  {
     workerManager_.endStream(iID, sContext);
   }

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

◆ setupPileUpEvent()

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

Definition at line 74 of file SecondaryEventProvider.cc.

                                                                          {
     workerManager_.setupOnDemandSystem(ep, setup);
   }

References SiStripBadComponentsDQMServiceTemplate_cfg::ep, singleTopDQM_cfi::setup, edm::WorkerManager::setupOnDemandSystem(), and workerManager_.

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_