CMS 3D CMS Logo

List of all members | Public Types | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Friends
edm::limited::EDProducerBase Class Referenceabstract

#include <EDProducerBase.h>

Inheritance diagram for edm::limited::EDProducerBase:
edm::ProducerBase edm::EDConsumerBase edm::ProductRegistryHelper edm::limited::EDProducer< T >

Public Types

typedef EDProducerBase ModuleType
 
- Public Types inherited from edm::ProducerBase
using ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex > >
 
typedef ProductRegistryHelper::TypeLabelList TypeLabelList
 
- Public Types inherited from edm::EDConsumerBase
typedef ProductLabels Labels
 

Public Member Functions

unsigned int concurrencyLimit () const
 
 EDProducerBase (ParameterSet const &pset)
 
ModuleDescription const & moduleDescription () const
 
LimitedTaskQueuequeue ()
 
virtual bool wantsGlobalLuminosityBlocks () const =0
 
virtual bool wantsGlobalRuns () const =0
 
virtual bool wantsInputProcessBlocks () const =0
 
virtual bool wantsProcessBlocks () const =0
 
virtual bool wantsStreamLuminosityBlocks () const =0
 
virtual bool wantsStreamRuns () const =0
 
 ~EDProducerBase () override
 
- Public Member Functions inherited from edm::ProducerBase
void callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
 
std::vector< edm::ProductResolverIndex > const & indiciesForPutProducts (BranchType iBranchType) const
 
 ProducerBase ()
 
std::vector< edm::ProductResolverIndex > const & putTokenIndexToProductResolverIndex () const
 
std::vector< bool > const & recordProvenanceList () const
 
void registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
 
std::function< void(BranchDescription const &)> registrationCallback () const
 used by the fwk to register list of products More...
 
void resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)
 
TypeLabelList const & typeLabelList () const
 used by the fwk to register the list of products of this module More...
 
 ~ProducerBase () noexcept(false) override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () const
 
void convertCurrentProcessAlias (std::string const &processName)
 Convert "@currentProcess" in InputTag process names to the actual current process name. More...
 
 EDConsumerBase ()
 
 EDConsumerBase (EDConsumerBase &&)=default
 
 EDConsumerBase (EDConsumerBase const &)=delete
 
ESProxyIndex const * esGetTokenIndices (edm::Transition iTrans) const
 
std::vector< ESProxyIndex > const & esGetTokenIndicesVector (edm::Transition iTrans) const
 
std::vector< ESRecordIndex > const & esGetTokenRecordIndicesVector (edm::Transition iTrans) const
 
ProductResolverIndexAndSkipBit indexFrom (EDGetToken, BranchType, TypeID const &) const
 
void itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
void itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
 
std::vector< ProductResolverIndexAndSkipBit > const & itemsToGetFrom (BranchType iType) const
 
void labelsForToken (EDGetToken iToken, Labels &oLabels) const
 
void modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > *, NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
bool registeredToConsume (ProductResolverIndex, bool, BranchType) const
 
bool registeredToConsumeMany (TypeID const &, BranchType) const
 
void selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)
 
ProductResolverIndexAndSkipBit uncheckedIndexFrom (EDGetToken) const
 
void updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
 
void updateLookup (eventsetup::ESRecordsToProxyIndices const &)
 
virtual ~EDConsumerBase () noexcept(false)
 

Static Public Member Functions

static const std::string & baseType ()
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &descriptions)
 

Private Member Functions

virtual void beginJob ()
 
virtual void clearInputProcessBlockCaches ()
 
void doAccessInputProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
virtual void doAccessInputProcessBlock_ (ProcessBlock const &)
 
void doBeginJob ()
 
void doBeginLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doBeginLuminosityBlock_ (LuminosityBlock const &lbp, EventSetup const &c)
 
virtual void doBeginLuminosityBlockProduce_ (LuminosityBlock &lbp, EventSetup const &c)
 
virtual void doBeginLuminosityBlockSummary_ (LuminosityBlock const &rp, EventSetup const &c)
 
void doBeginProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
virtual void doBeginProcessBlock_ (ProcessBlock const &)
 
virtual void doBeginProcessBlockProduce_ (ProcessBlock &)
 
void doBeginRun (RunTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doBeginRun_ (Run const &rp, EventSetup const &c)
 
virtual void doBeginRunProduce_ (Run &rp, EventSetup const &c)
 
virtual void doBeginRunSummary_ (Run const &rp, EventSetup const &c)
 
void doBeginStream (StreamID id)
 
virtual void doBeginStream_ (StreamID id)
 
void doEndJob ()
 
void doEndLuminosityBlock (LumiTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doEndLuminosityBlock_ (LuminosityBlock const &lb, EventSetup const &c)
 
virtual void doEndLuminosityBlockProduce_ (LuminosityBlock &lbp, EventSetup const &c)
 
virtual void doEndLuminosityBlockSummary_ (LuminosityBlock const &lb, EventSetup const &c)
 
void doEndProcessBlock (ProcessBlockPrincipal const &, ModuleCallingContext const *)
 
virtual void doEndProcessBlock_ (ProcessBlock const &)
 
virtual void doEndProcessBlockProduce_ (ProcessBlock &)
 
void doEndRun (RunTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doEndRun_ (Run const &rp, EventSetup const &c)
 
virtual void doEndRunProduce_ (Run &rp, EventSetup const &c)
 
virtual void doEndRunSummary_ (Run const &rp, EventSetup const &c)
 
void doEndStream (StreamID id)
 
virtual void doEndStream_ (StreamID id)
 
bool doEvent (EventTransitionInfo const &, ActivityRegistry *, ModuleCallingContext const *)
 
void doPreallocate (PreallocationConfiguration const &)
 
void doRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &)
 
void doRespondToCloseInputFile (FileBlock const &)
 
void doRespondToCloseOutputFile ()
 
void doRespondToOpenInputFile (FileBlock const &)
 
void doStreamBeginLuminosityBlock (StreamID, LumiTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doStreamBeginLuminosityBlock_ (StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
 
void doStreamBeginRun (StreamID, RunTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doStreamBeginRun_ (StreamID id, Run const &rp, EventSetup const &c)
 
void doStreamEndLuminosityBlock (StreamID, LumiTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doStreamEndLuminosityBlock_ (StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
 
virtual void doStreamEndLuminosityBlockSummary_ (StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
 
void doStreamEndRun (StreamID, RunTransitionInfo const &, ModuleCallingContext const *)
 
virtual void doStreamEndRun_ (StreamID id, Run const &rp, EventSetup const &c)
 
virtual void doStreamEndRunSummary_ (StreamID id, Run const &rp, EventSetup const &c)
 
virtual void endJob ()
 
virtual bool hasAccumulator () const
 
bool hasAcquire () const
 
void preActionBeforeRunEventAsync (WaitingTaskHolder iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const
 
virtual void preallocate (PreallocationConfiguration const &)
 
virtual void preallocLumis (unsigned int)
 
virtual void preallocLumisSummary (unsigned int)
 
virtual void preallocStreams (unsigned int)
 
virtual void produce (StreamID, Event &, EventSetup const &) const =0
 
void registerProductsAndCallbacks (EDProducerBase *module, ProductRegistry *reg)
 
void setModuleDescription (ModuleDescription const &md)
 
std::string workerType () const
 

Private Attributes

ModuleDescription moduleDescription_
 
std::unique_ptr< ParentageID[]> previousParentageIds_
 
std::unique_ptr< std::vector< BranchID >[]> previousParentages_
 
LimitedTaskQueue queue_
 

Friends

class edm::GlobalSchedule
 
template<typename T >
class edm::maker::ModuleHolderT
 
template<typename T >
class edm::WorkerT
 

Additional Inherited Members

- Protected Member Functions inherited from edm::ProducerBase
template<class ProductType >
BranchAliasSetterT< ProductType > produces ()
 declare what type of product will make and with which optional label More...
 
template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType > produces ()
 
template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType > produces ()
 
BranchAliasSetter produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
 
template<BranchType B>
BranchAliasSetter produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
 
template<Transition B>
BranchAliasSetter produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
 
template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
template<class ProductType >
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
ProducesCollector producesCollector ()
 
- Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B > consumes (edm::InputTag tag) noexcept
 
template<BranchType B>
EDGetToken consumes (TypeToGet const &id, edm::InputTag const &tag)
 
ConsumesCollector consumesCollector ()
 Use a ConsumesCollector to gather consumes information from helper functions. More...
 
template<typename ProductType , BranchType B = InEvent>
void consumesMany ()
 
void consumesMany (const TypeToGet &id)
 
template<BranchType B>
void consumesMany (const TypeToGet &id)
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes ()
 
template<Transition Tr = Transition::Event>
constexpr auto esConsumes () noexcept
 
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
template<Transition Tr = Transition::Event>
auto esConsumes (ESInputTag tag) noexcept
 
template<Transition Tr = Transition::Event>
ESGetTokenGeneric esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
 Used with EventSetupRecord::doGet. More...
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 

Detailed Description

Definition at line 50 of file EDProducerBase.h.

Member Typedef Documentation

◆ ModuleType

Definition at line 56 of file EDProducerBase.h.

Constructor & Destructor Documentation

◆ EDProducerBase()

EDProducerBase::EDProducerBase ( ParameterSet const &  pset)

Definition at line 45 of file EDProducerBase.cc.

46  : ProducerBase(),
50  queue_(pset.getUntrackedParameter<unsigned int>("concurrencyLimit")) {}

◆ ~EDProducerBase()

EDProducerBase::~EDProducerBase ( )
override

Definition at line 52 of file EDProducerBase.cc.

52 {}

Member Function Documentation

◆ baseType()

const std::string & EDProducerBase::baseType ( )
static

Definition at line 274 of file EDProducerBase.cc.

274 { return kBaseType; }

References edm::limited::kBaseType().

◆ beginJob()

virtual void edm::limited::EDProducerBase::beginJob ( void  )
inlineprivatevirtual

Definition at line 119 of file EDProducerBase.h.

119 {}

Referenced by doBeginJob().

◆ clearInputProcessBlockCaches()

void EDProducerBase::clearInputProcessBlockCaches ( )
privatevirtual

Definition at line 262 of file EDProducerBase.cc.

262 {}

Referenced by doRespondToCloseOutputFile().

◆ concurrencyLimit()

unsigned int edm::limited::EDProducerBase::concurrencyLimit ( ) const
inline

Definition at line 77 of file EDProducerBase.h.

77 { return queue_.concurrencyLimit(); }

References edm::LimitedTaskQueue::concurrencyLimit(), and queue_.

◆ doAccessInputProcessBlock()

void EDProducerBase::doAccessInputProcessBlock ( ProcessBlockPrincipal const &  pbp,
ModuleCallingContext const *  mcc 
)
private

Definition at line 94 of file EDProducerBase.cc.

94  {
95  ProcessBlock processBlock(pbp, moduleDescription_, mcc, false);
96  processBlock.setConsumer(this);
97  ProcessBlock const& constProcessBlock = processBlock;
98  this->doAccessInputProcessBlock_(constProcessBlock);
99  }

References doAccessInputProcessBlock_(), moduleDescription_, and edm::ProcessBlock::setConsumer().

◆ doAccessInputProcessBlock_()

void EDProducerBase::doAccessInputProcessBlock_ ( ProcessBlock const &  )
privatevirtual

Definition at line 243 of file EDProducerBase.cc.

243 {}

Referenced by doAccessInputProcessBlock().

◆ doBeginJob()

void EDProducerBase::doBeginJob ( )
private

Definition at line 80 of file EDProducerBase.cc.

80 { this->beginJob(); }

References beginJob().

◆ doBeginLuminosityBlock()

void EDProducerBase::doBeginLuminosityBlock ( LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 142 of file EDProducerBase.cc.

142  {
143  LuminosityBlock lb(info, moduleDescription_, mcc, false);
144  lb.setConsumer(this);
145  LuminosityBlock const& cnstLb = lb;
146  ESParentContext parentC(mcc);
147  const EventSetup c{info,
148  static_cast<unsigned int>(Transition::BeginLuminosityBlock),
150  parentC,
151  false};
152  this->doBeginLuminosityBlock_(cnstLb, c);
153  this->doBeginLuminosityBlockSummary_(cnstLb, c);
154  lb.setProducer(this);
156  commit_(lb);
157  }

References edm::BeginLuminosityBlock, c, edm::ProducerBase::commit_(), doBeginLuminosityBlock_(), doBeginLuminosityBlockProduce_(), doBeginLuminosityBlockSummary_(), edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, edm::LuminosityBlock::setConsumer(), and edm::LuminosityBlock::setProducer().

◆ doBeginLuminosityBlock_()

void EDProducerBase::doBeginLuminosityBlock_ ( LuminosityBlock const &  lbp,
EventSetup const &  c 
)
privatevirtual

Definition at line 250 of file EDProducerBase.cc.

250 {}

Referenced by doBeginLuminosityBlock().

◆ doBeginLuminosityBlockProduce_()

void EDProducerBase::doBeginLuminosityBlockProduce_ ( LuminosityBlock lbp,
EventSetup const &  c 
)
privatevirtual

Definition at line 259 of file EDProducerBase.cc.

259 {}

Referenced by doBeginLuminosityBlock().

◆ doBeginLuminosityBlockSummary_()

void EDProducerBase::doBeginLuminosityBlockSummary_ ( LuminosityBlock const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 252 of file EDProducerBase.cc.

252 {}

Referenced by doBeginLuminosityBlock().

◆ doBeginProcessBlock()

void EDProducerBase::doBeginProcessBlock ( ProcessBlockPrincipal const &  pbp,
ModuleCallingContext const *  mcc 
)
private

Definition at line 84 of file EDProducerBase.cc.

84  {
85  ProcessBlock processBlock(pbp, moduleDescription_, mcc, false);
86  processBlock.setConsumer(this);
87  ProcessBlock const& constProcessBlock = processBlock;
88  this->doBeginProcessBlock_(constProcessBlock);
89  processBlock.setProducer(this);
90  this->doBeginProcessBlockProduce_(processBlock);
91  commit_(processBlock);
92  }

References edm::ProducerBase::commit_(), doBeginProcessBlock_(), doBeginProcessBlockProduce_(), moduleDescription_, edm::ProcessBlock::setConsumer(), and edm::ProcessBlock::setProducer().

◆ doBeginProcessBlock_()

void EDProducerBase::doBeginProcessBlock_ ( ProcessBlock const &  )
privatevirtual

Definition at line 242 of file EDProducerBase.cc.

242 {}

Referenced by doBeginProcessBlock().

◆ doBeginProcessBlockProduce_()

void EDProducerBase::doBeginProcessBlockProduce_ ( ProcessBlock )
privatevirtual

Definition at line 255 of file EDProducerBase.cc.

255 {}

Referenced by doBeginProcessBlock().

◆ doBeginRun()

void EDProducerBase::doBeginRun ( RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 111 of file EDProducerBase.cc.

111  {
112  Run r(info, moduleDescription_, mcc, false);
113  r.setConsumer(this);
114  Run const& cnstR = r;
115  ESParentContext parentC(mcc);
116  const EventSetup c{info,
117  static_cast<unsigned int>(Transition::BeginRun),
119  parentC,
120  false};
121  this->doBeginRun_(cnstR, c);
122  this->doBeginRunSummary_(cnstR, c);
123  r.setProducer(this);
124  this->doBeginRunProduce_(r, c);
125  commit_(r);
126  }

References edm::BeginRun, c, edm::ProducerBase::commit_(), doBeginRun_(), doBeginRunProduce_(), doBeginRunSummary_(), edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, and alignCSCRings::r.

◆ doBeginRun_()

void EDProducerBase::doBeginRun_ ( Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 245 of file EDProducerBase.cc.

245 {}

Referenced by doBeginRun().

◆ doBeginRunProduce_()

void EDProducerBase::doBeginRunProduce_ ( Run rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 257 of file EDProducerBase.cc.

257 {}

Referenced by doBeginRun().

◆ doBeginRunSummary_()

void EDProducerBase::doBeginRunSummary_ ( Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 247 of file EDProducerBase.cc.

247 {}

Referenced by doBeginRun().

◆ doBeginStream()

void EDProducerBase::doBeginStream ( StreamID  id)
private

Definition at line 176 of file EDProducerBase.cc.

176 { doBeginStream_(id); }

References doBeginStream_().

◆ doBeginStream_()

void EDProducerBase::doBeginStream_ ( StreamID  id)
privatevirtual

Definition at line 231 of file EDProducerBase.cc.

231 {}

Referenced by doBeginStream().

◆ doEndJob()

void EDProducerBase::doEndJob ( )
private

Definition at line 82 of file EDProducerBase.cc.

82 { this->endJob(); }

References endJob().

◆ doEndLuminosityBlock()

void EDProducerBase::doEndLuminosityBlock ( LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 159 of file EDProducerBase.cc.

159  {
160  LuminosityBlock lb(info, moduleDescription_, mcc, true);
161  lb.setConsumer(this);
162  lb.setProducer(this);
163  LuminosityBlock const& cnstLb = lb;
164  ESParentContext parentC(mcc);
165  const EventSetup c{info,
166  static_cast<unsigned int>(Transition::EndLuminosityBlock),
168  parentC,
169  false};
170  this->doEndLuminosityBlockSummary_(cnstLb, c);
171  this->doEndLuminosityBlockProduce_(lb, c);
172  this->doEndLuminosityBlock_(cnstLb, c);
173  commit_(lb);
174  }

References c, edm::ProducerBase::commit_(), doEndLuminosityBlock_(), doEndLuminosityBlockProduce_(), doEndLuminosityBlockSummary_(), edm::EndLuminosityBlock, edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, edm::LuminosityBlock::setConsumer(), and edm::LuminosityBlock::setProducer().

◆ doEndLuminosityBlock_()

void EDProducerBase::doEndLuminosityBlock_ ( LuminosityBlock const &  lb,
EventSetup const &  c 
)
privatevirtual

Definition at line 251 of file EDProducerBase.cc.

251 {}

Referenced by doEndLuminosityBlock().

◆ doEndLuminosityBlockProduce_()

void EDProducerBase::doEndLuminosityBlockProduce_ ( LuminosityBlock lbp,
EventSetup const &  c 
)
privatevirtual

Definition at line 260 of file EDProducerBase.cc.

260 {}

Referenced by doEndLuminosityBlock().

◆ doEndLuminosityBlockSummary_()

void EDProducerBase::doEndLuminosityBlockSummary_ ( LuminosityBlock const &  lb,
EventSetup const &  c 
)
privatevirtual

Definition at line 253 of file EDProducerBase.cc.

253 {}

Referenced by doEndLuminosityBlock().

◆ doEndProcessBlock()

void EDProducerBase::doEndProcessBlock ( ProcessBlockPrincipal const &  pbp,
ModuleCallingContext const *  mcc 
)
private

Definition at line 101 of file EDProducerBase.cc.

101  {
102  ProcessBlock processBlock(pbp, moduleDescription_, mcc, true);
103  processBlock.setConsumer(this);
104  ProcessBlock const& constProcessBlock = processBlock;
105  this->doEndProcessBlock_(constProcessBlock);
106  processBlock.setProducer(this);
107  this->doEndProcessBlockProduce_(processBlock);
108  commit_(processBlock);
109  }

References edm::ProducerBase::commit_(), doEndProcessBlock_(), doEndProcessBlockProduce_(), moduleDescription_, edm::ProcessBlock::setConsumer(), and edm::ProcessBlock::setProducer().

◆ doEndProcessBlock_()

void EDProducerBase::doEndProcessBlock_ ( ProcessBlock const &  )
privatevirtual

Definition at line 244 of file EDProducerBase.cc.

244 {}

Referenced by doEndProcessBlock().

◆ doEndProcessBlockProduce_()

void EDProducerBase::doEndProcessBlockProduce_ ( ProcessBlock )
privatevirtual

Definition at line 256 of file EDProducerBase.cc.

256 {}

Referenced by doEndProcessBlock().

◆ doEndRun()

void EDProducerBase::doEndRun ( RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 128 of file EDProducerBase.cc.

128  {
129  Run r(info, moduleDescription_, mcc, true);
130  r.setConsumer(this);
131  r.setProducer(this);
132  Run const& cnstR = r;
133  ESParentContext parentC(mcc);
134  const EventSetup c{
135  info, static_cast<unsigned int>(Transition::EndRun), esGetTokenIndices(Transition::EndRun), parentC, false};
136  this->doEndRunSummary_(r, c);
137  this->doEndRunProduce_(r, c);
138  this->doEndRun_(cnstR, c);
139  commit_(r);
140  }

References c, edm::ProducerBase::commit_(), doEndRun_(), doEndRunProduce_(), doEndRunSummary_(), edm::EndRun, edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, and alignCSCRings::r.

◆ doEndRun_()

void EDProducerBase::doEndRun_ ( Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 246 of file EDProducerBase.cc.

246 {}

Referenced by doEndRun().

◆ doEndRunProduce_()

void EDProducerBase::doEndRunProduce_ ( Run rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 258 of file EDProducerBase.cc.

258 {}

Referenced by doEndRun().

◆ doEndRunSummary_()

void EDProducerBase::doEndRunSummary_ ( Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 248 of file EDProducerBase.cc.

248 {}

Referenced by doEndRun().

◆ doEndStream()

void EDProducerBase::doEndStream ( StreamID  id)
private

Definition at line 177 of file EDProducerBase.cc.

177 { doEndStream_(id); }

References doEndStream_().

◆ doEndStream_()

void EDProducerBase::doEndStream_ ( StreamID  id)
privatevirtual

Definition at line 232 of file EDProducerBase.cc.

232 {}

Referenced by doEndStream().

◆ doEvent()

bool EDProducerBase::doEvent ( EventTransitionInfo const &  info,
ActivityRegistry act,
ModuleCallingContext const *  mcc 
)
private

Definition at line 54 of file EDProducerBase.cc.

56  {
58  e.setConsumer(this);
59  const auto streamIndex = e.streamID().value();
60  e.setProducer(this, &previousParentages_[streamIndex]);
61  EventSignalsSentry sentry(act, mcc);
62  ESParentContext parentC(mcc);
63  const EventSetup c{
64  info, static_cast<unsigned int>(Transition::Event), esGetTokenIndices(Transition::Event), parentC, false};
65  this->produce(e.streamID(), e, c);
66  commit_(e, &previousParentageIds_[streamIndex]);
67  return true;
68  }

References c, edm::ProducerBase::commit_(), MillePedeFileConverter_cfg::e, edm::EDConsumerBase::esGetTokenIndices(), edm::Event, info(), moduleDescription_, previousParentageIds_, previousParentages_, produce(), and edm::Event::streamID().

◆ doPreallocate()

void EDProducerBase::doPreallocate ( PreallocationConfiguration const &  iPrealloc)
private

Definition at line 70 of file EDProducerBase.cc.

70  {
71  auto const nStreams = iPrealloc.numberOfStreams();
72  previousParentages_ = std::make_unique<std::vector<BranchID>[]>(nStreams);
73  previousParentageIds_ = std::make_unique<ParentageID[]>(nStreams);
75  preallocLumis(iPrealloc.numberOfLuminosityBlocks());
76  preallocLumisSummary(iPrealloc.numberOfLuminosityBlocks());
77  preallocate(iPrealloc);
78  }

References runTheMatrix::nStreams, edm::PreallocationConfiguration::numberOfLuminosityBlocks(), edm::PreallocationConfiguration::numberOfStreams(), preallocate(), preallocLumis(), preallocLumisSummary(), preallocStreams(), previousParentageIds_, and previousParentages_.

◆ doRegisterThinnedAssociations()

void edm::limited::EDProducerBase::doRegisterThinnedAssociations ( ProductRegistry const &  ,
ThinnedAssociationsHelper  
)
inlineprivate

Definition at line 106 of file EDProducerBase.h.

106 {}

◆ doRespondToCloseInputFile()

void edm::limited::EDProducerBase::doRespondToCloseInputFile ( FileBlock const &  )
inlineprivate

Definition at line 104 of file EDProducerBase.h.

104 {}

◆ doRespondToCloseOutputFile()

void edm::limited::EDProducerBase::doRespondToCloseOutputFile ( )
inlineprivate

Definition at line 105 of file EDProducerBase.h.

References clearInputProcessBlockCaches().

◆ doRespondToOpenInputFile()

void edm::limited::EDProducerBase::doRespondToOpenInputFile ( FileBlock const &  )
inlineprivate

Definition at line 103 of file EDProducerBase.h.

103 {}

◆ doStreamBeginLuminosityBlock()

void EDProducerBase::doStreamBeginLuminosityBlock ( StreamID  id,
LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 198 of file EDProducerBase.cc.

200  {
201  LuminosityBlock lb(info, moduleDescription_, mcc, false);
202  lb.setConsumer(this);
203  ESParentContext parentC(mcc);
204  const EventSetup c{info,
205  static_cast<unsigned int>(Transition::BeginLuminosityBlock),
207  parentC,
208  false};
209  this->doStreamBeginLuminosityBlock_(id, lb, c);
210  }

References edm::BeginLuminosityBlock, c, doStreamBeginLuminosityBlock_(), edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, and edm::LuminosityBlock::setConsumer().

◆ doStreamBeginLuminosityBlock_()

void EDProducerBase::doStreamBeginLuminosityBlock_ ( StreamID  id,
LuminosityBlock const &  lbp,
EventSetup const &  c 
)
privatevirtual

Definition at line 236 of file EDProducerBase.cc.

236 {}

Referenced by doStreamBeginLuminosityBlock().

◆ doStreamBeginRun()

void EDProducerBase::doStreamBeginRun ( StreamID  id,
RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 178 of file EDProducerBase.cc.

178  {
179  Run r(info, moduleDescription_, mcc, false);
180  r.setConsumer(this);
181  ESParentContext parentC(mcc);
182  const EventSetup c{info,
183  static_cast<unsigned int>(Transition::BeginRun),
185  parentC,
186  false};
187  this->doStreamBeginRun_(id, r, c);
188  }

References edm::BeginRun, c, doStreamBeginRun_(), edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, and alignCSCRings::r.

◆ doStreamBeginRun_()

void EDProducerBase::doStreamBeginRun_ ( StreamID  id,
Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 233 of file EDProducerBase.cc.

233 {}

Referenced by doStreamBeginRun().

◆ doStreamEndLuminosityBlock()

void EDProducerBase::doStreamEndLuminosityBlock ( StreamID  id,
LumiTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 212 of file EDProducerBase.cc.

214  {
215  LuminosityBlock lb(info, moduleDescription_, mcc, true);
216  lb.setConsumer(this);
217  ESParentContext parentC(mcc);
218  const EventSetup c{info,
219  static_cast<unsigned int>(Transition::EndLuminosityBlock),
221  parentC,
222  false};
223  this->doStreamEndLuminosityBlock_(id, lb, c);
224  this->doStreamEndLuminosityBlockSummary_(id, lb, c);
225  }

References c, doStreamEndLuminosityBlock_(), doStreamEndLuminosityBlockSummary_(), edm::EndLuminosityBlock, edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, and edm::LuminosityBlock::setConsumer().

◆ doStreamEndLuminosityBlock_()

void EDProducerBase::doStreamEndLuminosityBlock_ ( StreamID  id,
LuminosityBlock const &  lbp,
EventSetup const &  c 
)
privatevirtual

Definition at line 237 of file EDProducerBase.cc.

237 {}

Referenced by doStreamEndLuminosityBlock().

◆ doStreamEndLuminosityBlockSummary_()

void EDProducerBase::doStreamEndLuminosityBlockSummary_ ( StreamID  id,
LuminosityBlock const &  lbp,
EventSetup const &  c 
)
privatevirtual

Definition at line 238 of file EDProducerBase.cc.

240  {}

Referenced by doStreamEndLuminosityBlock().

◆ doStreamEndRun()

void EDProducerBase::doStreamEndRun ( StreamID  id,
RunTransitionInfo const &  info,
ModuleCallingContext const *  mcc 
)
private

Definition at line 189 of file EDProducerBase.cc.

189  {
190  Run r(info, moduleDescription_, mcc, true);
191  r.setConsumer(this);
192  ESParentContext parentC(mcc);
193  const EventSetup c{
194  info, static_cast<unsigned int>(Transition::EndRun), esGetTokenIndices(Transition::EndRun), parentC, false};
195  this->doStreamEndRun_(id, r, c);
196  this->doStreamEndRunSummary_(id, r, c);
197  }

References c, doStreamEndRun_(), doStreamEndRunSummary_(), edm::EndRun, edm::EDConsumerBase::esGetTokenIndices(), info(), moduleDescription_, and alignCSCRings::r.

◆ doStreamEndRun_()

void EDProducerBase::doStreamEndRun_ ( StreamID  id,
Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 234 of file EDProducerBase.cc.

234 {}

Referenced by doStreamEndRun().

◆ doStreamEndRunSummary_()

void EDProducerBase::doStreamEndRunSummary_ ( StreamID  id,
Run const &  rp,
EventSetup const &  c 
)
privatevirtual

Definition at line 235 of file EDProducerBase.cc.

235 {}

Referenced by doStreamEndRun().

◆ endJob()

virtual void edm::limited::EDProducerBase::endJob ( void  )
inlineprivatevirtual

Definition at line 120 of file EDProducerBase.h.

120 {}

Referenced by doEndJob().

◆ fillDescriptions()

void EDProducerBase::fillDescriptions ( ConfigurationDescriptions descriptions)
static

Definition at line 264 of file EDProducerBase.cc.

264  {
266  desc.setUnknown();
267  descriptions.addDefault(desc);
268  }

References edm::ConfigurationDescriptions::addDefault(), and submitPVResolutionJobs::desc.

◆ hasAccumulator()

virtual bool edm::limited::EDProducerBase::hasAccumulator ( ) const
inlineprivatevirtual

Definition at line 155 of file EDProducerBase.h.

155 { return false; }

◆ hasAcquire()

bool edm::limited::EDProducerBase::hasAcquire ( ) const
inlineprivate

Definition at line 157 of file EDProducerBase.h.

157 { return false; }

◆ moduleDescription()

ModuleDescription const& edm::limited::EDProducerBase::moduleDescription ( ) const
inline

Definition at line 68 of file EDProducerBase.h.

68 { return moduleDescription_; }

References moduleDescription_.

◆ preActionBeforeRunEventAsync()

void edm::limited::EDProducerBase::preActionBeforeRunEventAsync ( WaitingTaskHolder  iTask,
ModuleCallingContext const &  iModuleCallingContext,
Principal const &  iPrincipal 
) const
inlineprivate

Definition at line 115 of file EDProducerBase.h.

117  {}

◆ preallocate()

void EDProducerBase::preallocate ( PreallocationConfiguration const &  )
privatevirtual

Definition at line 230 of file EDProducerBase.cc.

230 {}

Referenced by doPreallocate().

◆ preallocLumis()

void EDProducerBase::preallocLumis ( unsigned int  )
privatevirtual

Definition at line 228 of file EDProducerBase.cc.

228 {}

Referenced by doPreallocate().

◆ preallocLumisSummary()

void EDProducerBase::preallocLumisSummary ( unsigned int  )
privatevirtual

Definition at line 229 of file EDProducerBase.cc.

229 {}

Referenced by doPreallocate().

◆ preallocStreams()

void EDProducerBase::preallocStreams ( unsigned int  )
privatevirtual

Definition at line 227 of file EDProducerBase.cc.

227 {}

Referenced by doPreallocate().

◆ prevalidate()

void EDProducerBase::prevalidate ( ConfigurationDescriptions descriptions)
static

Definition at line 270 of file EDProducerBase.cc.

270 { edmodule_mightGet_config(iConfig); }

References edm::edmodule_mightGet_config().

◆ produce()

virtual void edm::limited::EDProducerBase::produce ( StreamID  ,
Event ,
EventSetup const &   
) const
privatepure virtual

Referenced by doEvent().

◆ queue()

LimitedTaskQueue& edm::limited::EDProducerBase::queue ( )
inline

Definition at line 79 of file EDProducerBase.h.

79 { return queue_; }

References queue_.

◆ registerProductsAndCallbacks()

void edm::limited::EDProducerBase::registerProductsAndCallbacks ( EDProducerBase module,
ProductRegistry reg 
)
inlineprivate

◆ setModuleDescription()

void edm::limited::EDProducerBase::setModuleDescription ( ModuleDescription const &  md)
inlineprivate

Definition at line 159 of file EDProducerBase.h.

159 { moduleDescription_ = md; }

References moduleDescription_.

◆ wantsGlobalLuminosityBlocks()

virtual bool edm::limited::EDProducerBase::wantsGlobalLuminosityBlocks ( ) const
pure virtual

◆ wantsGlobalRuns()

virtual bool edm::limited::EDProducerBase::wantsGlobalRuns ( ) const
pure virtual

◆ wantsInputProcessBlocks()

virtual bool edm::limited::EDProducerBase::wantsInputProcessBlocks ( ) const
pure virtual

◆ wantsProcessBlocks()

virtual bool edm::limited::EDProducerBase::wantsProcessBlocks ( ) const
pure virtual

◆ wantsStreamLuminosityBlocks()

virtual bool edm::limited::EDProducerBase::wantsStreamLuminosityBlocks ( ) const
pure virtual

◆ wantsStreamRuns()

virtual bool edm::limited::EDProducerBase::wantsStreamRuns ( ) const
pure virtual

◆ workerType()

std::string edm::limited::EDProducerBase::workerType ( ) const
inlineprivate

Definition at line 111 of file EDProducerBase.h.

111 { return "WorkerT<EDProducer>"; }

Friends And Related Function Documentation

◆ edm::GlobalSchedule

friend class edm::GlobalSchedule
friend

Definition at line 58 of file EDProducerBase.h.

◆ edm::maker::ModuleHolderT

template<typename T >
friend class edm::maker::ModuleHolderT
friend

Definition at line 53 of file EDProducerBase.h.

◆ edm::WorkerT

template<typename T >
friend class edm::WorkerT
friend

Definition at line 55 of file EDProducerBase.h.

Member Data Documentation

◆ moduleDescription_

ModuleDescription edm::limited::EDProducerBase::moduleDescription_
private

◆ previousParentageIds_

std::unique_ptr<ParentageID[]> edm::limited::EDProducerBase::previousParentageIds_
private

Definition at line 162 of file EDProducerBase.h.

Referenced by doEvent(), and doPreallocate().

◆ previousParentages_

std::unique_ptr<std::vector<BranchID>[]> edm::limited::EDProducerBase::previousParentages_
private

Definition at line 161 of file EDProducerBase.h.

Referenced by doEvent(), and doPreallocate().

◆ queue_

LimitedTaskQueue edm::limited::EDProducerBase::queue_
private

Definition at line 163 of file EDProducerBase.h.

Referenced by concurrencyLimit(), and queue().

edm::limited::EDProducerBase::doStreamEndLuminosityBlock_
virtual void doStreamEndLuminosityBlock_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
Definition: EDProducerBase.cc:237
edm::limited::EDProducerBase::doStreamEndRunSummary_
virtual void doStreamEndRunSummary_(StreamID id, Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:235
edm::limited::EDProducerBase::endJob
virtual void endJob()
Definition: EDProducerBase.h:120
edm::limited::EDProducerBase::doEndRunSummary_
virtual void doEndRunSummary_(Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:248
edm::ProducerBase::ProducerBase
ProducerBase()
Definition: ProducerBase.cc:16
edm::Transition::Event
edm::ProducerBase::commit_
void commit_(P &iPrincipal)
Definition: ProducerBase.h:120
edm::limited::EDProducerBase::doAccessInputProcessBlock_
virtual void doAccessInputProcessBlock_(ProcessBlock const &)
Definition: EDProducerBase.cc:243
info
static const TGPicture * info(bool iBackgroundIsBlack)
Definition: FWCollectionSummaryWidget.cc:153
edm::limited::EDProducerBase::doEndProcessBlockProduce_
virtual void doEndProcessBlockProduce_(ProcessBlock &)
Definition: EDProducerBase.cc:256
edm::limited::EDProducerBase::previousParentageIds_
std::unique_ptr< ParentageID[]> previousParentageIds_
Definition: EDProducerBase.h:162
edm::limited::EDProducerBase::preallocLumisSummary
virtual void preallocLumisSummary(unsigned int)
Definition: EDProducerBase.cc:229
edm::limited::EDProducerBase::preallocLumis
virtual void preallocLumis(unsigned int)
Definition: EDProducerBase.cc:228
edm::limited::EDProducerBase::doEndLuminosityBlockSummary_
virtual void doEndLuminosityBlockSummary_(LuminosityBlock const &lb, EventSetup const &c)
Definition: EDProducerBase.cc:253
runTheMatrix.nStreams
nStreams
Definition: runTheMatrix.py:372
edm::limited::EDProducerBase::produce
virtual void produce(StreamID, Event &, EventSetup const &) const =0
edm::limited::EDProducerBase::doBeginLuminosityBlock_
virtual void doBeginLuminosityBlock_(LuminosityBlock const &lbp, EventSetup const &c)
Definition: EDProducerBase.cc:250
edm::limited::EDProducerBase::clearInputProcessBlockCaches
virtual void clearInputProcessBlockCaches()
Definition: EDProducerBase.cc:262
edm::limited::EDProducerBase::queue_
LimitedTaskQueue queue_
Definition: EDProducerBase.h:163
edm::limited::EDProducerBase::doEndLuminosityBlock_
virtual void doEndLuminosityBlock_(LuminosityBlock const &lb, EventSetup const &c)
Definition: EDProducerBase.cc:251
LuminosityBlock
edm::limited::EDProducerBase::moduleDescription_
ModuleDescription moduleDescription_
Definition: EDProducerBase.h:160
Event
edm::Transition::BeginLuminosityBlock
edm::limited::EDProducerBase::doBeginProcessBlockProduce_
virtual void doBeginProcessBlockProduce_(ProcessBlock &)
Definition: EDProducerBase.cc:255
edm::limited::EDProducerBase::beginJob
virtual void beginJob()
Definition: EDProducerBase.h:119
edm::LimitedTaskQueue::concurrencyLimit
unsigned int concurrencyLimit() const
Definition: LimitedTaskQueue.h:107
edm::limited::EDProducerBase::doBeginRunProduce_
virtual void doBeginRunProduce_(Run &rp, EventSetup const &c)
Definition: EDProducerBase.cc:257
edm::limited::EDProducerBase::doStreamEndLuminosityBlockSummary_
virtual void doStreamEndLuminosityBlockSummary_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
Definition: EDProducerBase.cc:238
edm::limited::EDProducerBase::doEndStream_
virtual void doEndStream_(StreamID id)
Definition: EDProducerBase.cc:232
edm::limited::EDProducerBase::preallocStreams
virtual void preallocStreams(unsigned int)
Definition: EDProducerBase.cc:227
edm::limited::kBaseType
static const std::string kBaseType("EDAnalyzer")
edm::limited::EDProducerBase::doEndRunProduce_
virtual void doEndRunProduce_(Run &rp, EventSetup const &c)
Definition: EDProducerBase.cc:258
edm::limited::EDProducerBase::previousParentages_
std::unique_ptr< std::vector< BranchID >[]> previousParentages_
Definition: EDProducerBase.h:161
edm::limited::EDProducerBase::preallocate
virtual void preallocate(PreallocationConfiguration const &)
Definition: EDProducerBase.cc:230
edm::limited::EDProducerBase::doBeginRun_
virtual void doBeginRun_(Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:245
edm::limited::EDProducerBase::doBeginLuminosityBlockProduce_
virtual void doBeginLuminosityBlockProduce_(LuminosityBlock &lbp, EventSetup const &c)
Definition: EDProducerBase.cc:259
edm::limited::EDProducerBase::doEndProcessBlock_
virtual void doEndProcessBlock_(ProcessBlock const &)
Definition: EDProducerBase.cc:244
alignCSCRings.r
r
Definition: alignCSCRings.py:93
callgraph.module
module
Definition: callgraph.py:61
submitPVResolutionJobs.desc
string desc
Definition: submitPVResolutionJobs.py:251
edm::Transition::EndLuminosityBlock
edm::limited::EDProducerBase::doBeginRunSummary_
virtual void doBeginRunSummary_(Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:247
edm::EDConsumerBase::esGetTokenIndices
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
Definition: EDConsumerBase.h:124
edm::Transition::BeginRun
ParameterSetDescription
edm::limited::EDProducerBase::doStreamEndRun_
virtual void doStreamEndRun_(StreamID id, Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:234
edm::edmodule_mightGet_config
void edmodule_mightGet_config(ConfigurationDescriptions &iDesc)
Definition: edmodule_mightGet_config.cc:36
edm::limited::EDProducerBase::doEndRun_
virtual void doEndRun_(Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:246
EventSetup
edm::limited::EDProducerBase::doBeginLuminosityBlockSummary_
virtual void doBeginLuminosityBlockSummary_(LuminosityBlock const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:252
edm::limited::EDProducerBase::doEndLuminosityBlockProduce_
virtual void doEndLuminosityBlockProduce_(LuminosityBlock &lbp, EventSetup const &c)
Definition: EDProducerBase.cc:260
c
auto & c
Definition: CAHitNtupletGeneratorKernelsImpl.h:56
edm::ProducerBase::registerProducts
void registerProducts(ProducerBase *, ProductRegistry *, ModuleDescription const &)
Definition: ProducerBase.cc:57
edm::limited::EDProducerBase::doBeginProcessBlock_
virtual void doBeginProcessBlock_(ProcessBlock const &)
Definition: EDProducerBase.cc:242
edm::Transition::EndRun
edm::limited::EDProducerBase::doBeginStream_
virtual void doBeginStream_(StreamID id)
Definition: EDProducerBase.cc:231
edm::limited::EDProducerBase::doStreamBeginLuminosityBlock_
virtual void doStreamBeginLuminosityBlock_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
Definition: EDProducerBase.cc:236
edm::limited::EDProducerBase::doStreamBeginRun_
virtual void doStreamBeginRun_(StreamID id, Run const &rp, EventSetup const &c)
Definition: EDProducerBase.cc:233
muonDTDigis_cfi.pset
pset
Definition: muonDTDigis_cfi.py:27
MillePedeFileConverter_cfg.e
e
Definition: MillePedeFileConverter_cfg.py:37
Run