CMS 3D CMS Logo

List of all members | Public Member Functions | Private Attributes
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< ExceptionToActionTableexceptionToActionTable_
 
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 50 of file SecondaryEventProvider.cc.

53  : exceptionToActionTable_(new ExceptionToActionTable),
54  workerManager_(std::make_shared<ActivityRegistry>(), *exceptionToActionTable_) {
55  std::vector<std::string> shouldBeUsedLabels;
56  std::set<std::string> unscheduledLabels;
57  const PreallocationConfiguration preallocConfig;
58  for (auto& pset : psets) {
59  std::string label = pset.getParameter<std::string>("@module_label");
61  pset, preg, &preallocConfig, processConfiguration, label, unscheduledLabels, shouldBeUsedLabels);
62  }
63  if (!unscheduledLabels.empty()) {
64  preg.setUnscheduledProducts(unscheduledLabels);
65  }
66  } // 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 68 of file SecondaryEventProvider.cc.

69  {
70  workerManager_.beginJob(iRegistry, iIndices);
71  }

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 86 of file SecondaryEventProvider.cc.

89  {
90  LumiTransitionInfo info(lumi, setup);
91  processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalBegin> >(
93  processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamBegin> >(
94  workerManager_, info, sContext.streamID(), &sContext, mcc);
95  }

References info(), edm::StreamID::invalidStreamID(), 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 75 of file SecondaryEventProvider.cc.

78  {
79  RunTransitionInfo info(run, setup);
80  processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionGlobalBegin> >(
82  processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionStreamBegin> >(
83  workerManager_, info, sContext.streamID(), &sContext, mcc);
84  }

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

◆ beginStream()

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

Definition at line 126 of file SecondaryEventProvider.cc.

126  {
127  workerManager_.beginStream(iID, sContext);
128  }

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

◆ endJob()

void edm::SecondaryEventProvider::endJob ( void  )
inline

Definition at line 41 of file SecondaryEventProvider.h.

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 108 of file SecondaryEventProvider.cc.

111  {
112  LumiTransitionInfo info(lumi, setup);
113  processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionStreamEnd> >(
114  workerManager_, info, sContext.streamID(), &sContext, mcc);
115  processOneOccurrence<OccurrenceTraits<LuminosityBlockPrincipal, BranchActionGlobalEnd> >(
116  workerManager_, info, StreamID::invalidStreamID(), nullptr, mcc);
117  }

References info(), edm::StreamID::invalidStreamID(), 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 97 of file SecondaryEventProvider.cc.

100  {
101  RunTransitionInfo info(run, setup);
102  processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionStreamEnd> >(
103  workerManager_, info, sContext.streamID(), &sContext, mcc);
104  processOneOccurrence<OccurrenceTraits<RunPrincipal, BranchActionGlobalEnd> >(
105  workerManager_, info, StreamID::invalidStreamID(), nullptr, mcc);
106  }

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

◆ endStream()

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

Definition at line 130 of file SecondaryEventProvider.cc.

130  {
131  workerManager_.endStream(iID, sContext);
132  }

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

◆ setupPileUpEvent()

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

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
edm::WorkerManager::addToUnscheduledWorkers
void addToUnscheduledWorkers(ParameterSet &pset, ProductRegistry &preg, PreallocationConfiguration const *prealloc, std::shared_ptr< ProcessConfiguration > processConfiguration, std::string label, std::set< std::string > &unscheduledLabels, std::vector< std::string > &shouldBeUsedLabels)
Definition: WorkerManager.cc:52
edm::SecondaryEventProvider::exceptionToActionTable_
std::unique_ptr< ExceptionToActionTable > exceptionToActionTable_
Definition: SecondaryEventProvider.h:47
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
singleTopDQM_cfi.setup
setup
Definition: singleTopDQM_cfi.py:37
edm::WorkerManager::beginJob
void beginJob(ProductRegistry const &iRegistry, eventsetup::ESRecordsToProxyIndices const &)
Definition: WorkerManager.cc:91
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
edm::WorkerManager::beginStream
void beginStream(StreamID iID, StreamContext &streamContext)
Definition: WorkerManager.cc:119
edm::WorkerManager::setupOnDemandSystem
void setupOnDemandSystem(EventTransitionInfo const &)
Definition: WorkerManager.cc:148
edm::StreamID::invalidStreamID
static StreamID invalidStreamID()
Definition: StreamID.h:45
edm::SecondaryEventProvider::workerManager_
WorkerManager workerManager_
Definition: SecondaryEventProvider.h:48
writedatasetfile.run
run
Definition: writedatasetfile.py:27
edm::WorkerManager::setupResolvers
void setupResolvers(Principal &principal)
Definition: WorkerManager.cc:139
edm::WorkerManager::endStream
void endStream(StreamID iID, StreamContext &streamContext)
Definition: WorkerManager.cc:125
lumi
Definition: LumiSectionData.h:20
SiStripBadComponentsDQMServiceTemplate_cfg.ep
ep
Definition: SiStripBadComponentsDQMServiceTemplate_cfg.py:86
label
const char * label
Definition: PFTauDecayModeTools.cc:11
muonDTDigis_cfi.pset
pset
Definition: muonDTDigis_cfi.py:27
edm::WorkerManager::endJob
void endJob()
Definition: WorkerManager.cc:75