#include <SecondaryEventProvider.h>

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

void	endJob (ExceptionCollector &exceptionCollector, GlobalContext const &globalContext)

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, StreamContext const &, ExceptionCollector &)

	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 15 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 54 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,
		GlobalContext const &	globalContext
	)

Definition at line 73 of file SecondaryEventProvider.cc.

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

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

◆ beginLuminosityBlock()

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

Definition at line 93 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 82 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 const &	sContext
	)

Definition at line 162 of file SecondaryEventProvider.cc.

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

                                                                                          {
     workerManager_.beginStream(iID, sContext);
   }

◆ endJob()

void edm::SecondaryEventProvider::endJob	(	ExceptionCollector &	exceptionCollector,
		GlobalContext const &	globalContext
	)

inline

Definition at line 44 of file SecondaryEventProvider.h.

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

                                                                                             {
       workerManager_.endJob(exceptionCollector, globalContext);
     }

◆ endLuminosityBlock()

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

Definition at line 115 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 104 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 const &	sContext,
		ExceptionCollector &	exceptionCollector
	)

Definition at line 166 of file SecondaryEventProvider.cc.

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

                                                                                  {
     // In this context the mutex is not needed because these things are not
     // executing concurrently but in general the WorkerManager needs one.
     std::mutex exceptionCollectorMutex;
     workerManager_.endStream(iID, sContext, exceptionCollector, exceptionCollectorMutex);
   }

◆ setupPileUpEvent()

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

Definition at line 126 of file SecondaryEventProvider.cc.

References edm::addContextAndPrintException(), cms::Exception::context(), ecalHexDisplay_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 52 of file SecondaryEventProvider.h.

◆ workerManager_

WorkerManager edm::SecondaryEventProvider::workerManager_