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 const &)=delete
 
 EDConsumerBase (EDConsumerBase &&)=default
 
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
 
EDConsumerBase const & operator= (EDConsumerBase const &)=delete
 
EDConsumerBaseoperator= (EDConsumerBase &&)=default
 
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<Transition Tr = Transition::Event>
auto produces (std::string instanceName) noexcept
 declare what type of product will make and with which optional label More...
 
template<Transition B>
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)
 
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 ()
 
template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType > produces ()
 
template<class ProductType >
BranchAliasSetterT< ProductType > produces (std::string instanceName)
 
template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType > produces ()
 
template<Transition Tr = Transition::Event>
auto produces () noexcept
 
ProducesCollector producesCollector ()
 
- Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > consumes (edm::InputTag const &tag)
 
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< Bconsumes (edm::InputTag tag) noexcept
 
EDGetToken consumes (const TypeToGet &id, edm::InputTag const &tag)
 
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<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
template<Transition Tr = Transition::Event>
constexpr auto esConsumes ()
 
template<Transition Tr = Transition::Event>
auto esConsumes (ESInputTag tag)
 
template<Transition Tr = Transition::Event>
ESGetTokenGeneric esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
 Used with EventSetupRecord::doGet. More...
 
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType > mayConsume (edm::InputTag const &tag)
 
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
template<BranchType B>
EDGetToken mayConsume (const TypeToGet &id, edm::InputTag const &tag)
 
void resetItemsToGetFrom (BranchType iType)
 

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")) {}
ModuleDescription moduleDescription_
std::unique_ptr< ParentageID[]> previousParentageIds_
std::unique_ptr< std::vector< BranchID >[]> previousParentages_

◆ ~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 264 of file EDProducerBase.cc.

References edm::limited::kBaseType().

264 { return kBaseType; }
static const std::string kBaseType("EDAnalyzer")

◆ beginJob()

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

Definition at line 119 of file EDProducerBase.h.

Referenced by doBeginJob().

119 {}

◆ clearInputProcessBlockCaches()

void EDProducerBase::clearInputProcessBlockCaches ( )
privatevirtual

Definition at line 252 of file EDProducerBase.cc.

Referenced by doRespondToCloseOutputFile().

252 {}

◆ concurrencyLimit()

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

Definition at line 77 of file EDProducerBase.h.

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

77 { return queue_.concurrencyLimit(); }
unsigned int concurrencyLimit() const

◆ doAccessInputProcessBlock()

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

Definition at line 94 of file EDProducerBase.cc.

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

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

◆ doAccessInputProcessBlock_()

void EDProducerBase::doAccessInputProcessBlock_ ( ProcessBlock const &  )
privatevirtual

Definition at line 233 of file EDProducerBase.cc.

Referenced by doAccessInputProcessBlock().

233 {}

◆ doBeginJob()

void EDProducerBase::doBeginJob ( )
private

Definition at line 80 of file EDProducerBase.cc.

References beginJob().

80 { this->beginJob(); }

◆ doBeginLuminosityBlock()

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

Definition at line 139 of file EDProducerBase.cc.

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

139  {
140  LuminosityBlock lb(info, moduleDescription_, mcc, false);
141  lb.setConsumer(this);
142  LuminosityBlock const& cnstLb = lb;
143  ESParentContext parentC(mcc);
144  const EventSetup c{info,
145  static_cast<unsigned int>(Transition::BeginLuminosityBlock),
147  parentC};
148  this->doBeginLuminosityBlock_(cnstLb, c);
149  this->doBeginLuminosityBlockSummary_(cnstLb, c);
150  lb.setProducer(this);
152  commit_(lb);
153  }
static const TGPicture * info(bool iBackgroundIsBlack)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
ModuleDescription moduleDescription_
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 commit_(P &iPrincipal)
Definition: ProducerBase.h:121

◆ doBeginLuminosityBlock_()

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

Definition at line 240 of file EDProducerBase.cc.

Referenced by doBeginLuminosityBlock().

240 {}

◆ doBeginLuminosityBlockProduce_()

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

Definition at line 249 of file EDProducerBase.cc.

Referenced by doBeginLuminosityBlock().

249 {}

◆ doBeginLuminosityBlockSummary_()

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

Definition at line 242 of file EDProducerBase.cc.

Referenced by doBeginLuminosityBlock().

242 {}

◆ doBeginProcessBlock()

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

Definition at line 84 of file EDProducerBase.cc.

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

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  }
ModuleDescription moduleDescription_
virtual void doBeginProcessBlockProduce_(ProcessBlock &)
virtual void doBeginProcessBlock_(ProcessBlock const &)
void commit_(P &iPrincipal)
Definition: ProducerBase.h:121

◆ doBeginProcessBlock_()

void EDProducerBase::doBeginProcessBlock_ ( ProcessBlock const &  )
privatevirtual

Definition at line 232 of file EDProducerBase.cc.

Referenced by doBeginProcessBlock().

232 {}

◆ doBeginProcessBlockProduce_()

void EDProducerBase::doBeginProcessBlockProduce_ ( ProcessBlock )
privatevirtual

Definition at line 245 of file EDProducerBase.cc.

Referenced by doBeginProcessBlock().

245 {}

◆ doBeginRun()

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

Definition at line 111 of file EDProducerBase.cc.

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

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{
117  info, static_cast<unsigned int>(Transition::BeginRun), esGetTokenIndices(Transition::BeginRun), parentC};
118  this->doBeginRun_(cnstR, c);
119  this->doBeginRunSummary_(cnstR, c);
120  r.setProducer(this);
121  this->doBeginRunProduce_(r, c);
122  commit_(r);
123  }
static const TGPicture * info(bool iBackgroundIsBlack)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
virtual void doBeginRun_(Run const &rp, EventSetup const &c)
ModuleDescription moduleDescription_
virtual void doBeginRunSummary_(Run const &rp, EventSetup const &c)
virtual void doBeginRunProduce_(Run &rp, EventSetup const &c)
void commit_(P &iPrincipal)
Definition: ProducerBase.h:121

◆ doBeginRun_()

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

Definition at line 235 of file EDProducerBase.cc.

Referenced by doBeginRun().

235 {}

◆ doBeginRunProduce_()

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

Definition at line 247 of file EDProducerBase.cc.

Referenced by doBeginRun().

247 {}

◆ doBeginRunSummary_()

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

Definition at line 237 of file EDProducerBase.cc.

Referenced by doBeginRun().

237 {}

◆ doBeginStream()

void EDProducerBase::doBeginStream ( StreamID  id)
private

Definition at line 171 of file EDProducerBase.cc.

References doBeginStream_().

171 { doBeginStream_(id); }
virtual void doBeginStream_(StreamID id)

◆ doBeginStream_()

void EDProducerBase::doBeginStream_ ( StreamID  id)
privatevirtual

Definition at line 221 of file EDProducerBase.cc.

Referenced by doBeginStream().

221 {}

◆ doEndJob()

void EDProducerBase::doEndJob ( )
private

Definition at line 82 of file EDProducerBase.cc.

References endJob().

82 { this->endJob(); }

◆ doEndLuminosityBlock()

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

Definition at line 155 of file EDProducerBase.cc.

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

155  {
156  LuminosityBlock lb(info, moduleDescription_, mcc, true);
157  lb.setConsumer(this);
158  lb.setProducer(this);
159  LuminosityBlock const& cnstLb = lb;
160  ESParentContext parentC(mcc);
161  const EventSetup c{info,
162  static_cast<unsigned int>(Transition::EndLuminosityBlock),
164  parentC};
165  this->doEndLuminosityBlockSummary_(cnstLb, c);
166  this->doEndLuminosityBlockProduce_(lb, c);
167  this->doEndLuminosityBlock_(cnstLb, c);
168  commit_(lb);
169  }
static const TGPicture * info(bool iBackgroundIsBlack)
virtual void doEndLuminosityBlock_(LuminosityBlock const &lb, EventSetup const &c)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
ModuleDescription moduleDescription_
virtual void doEndLuminosityBlockSummary_(LuminosityBlock const &lb, EventSetup const &c)
virtual void doEndLuminosityBlockProduce_(LuminosityBlock &lbp, EventSetup const &c)
void commit_(P &iPrincipal)
Definition: ProducerBase.h:121

◆ doEndLuminosityBlock_()

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

Definition at line 241 of file EDProducerBase.cc.

Referenced by doEndLuminosityBlock().

241 {}

◆ doEndLuminosityBlockProduce_()

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

Definition at line 250 of file EDProducerBase.cc.

Referenced by doEndLuminosityBlock().

250 {}

◆ doEndLuminosityBlockSummary_()

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

Definition at line 243 of file EDProducerBase.cc.

Referenced by doEndLuminosityBlock().

243 {}

◆ doEndProcessBlock()

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

Definition at line 101 of file EDProducerBase.cc.

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

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  }
ModuleDescription moduleDescription_
virtual void doEndProcessBlockProduce_(ProcessBlock &)
void commit_(P &iPrincipal)
Definition: ProducerBase.h:121
virtual void doEndProcessBlock_(ProcessBlock const &)

◆ doEndProcessBlock_()

void EDProducerBase::doEndProcessBlock_ ( ProcessBlock const &  )
privatevirtual

Definition at line 234 of file EDProducerBase.cc.

Referenced by doEndProcessBlock().

234 {}

◆ doEndProcessBlockProduce_()

void EDProducerBase::doEndProcessBlockProduce_ ( ProcessBlock )
privatevirtual

Definition at line 246 of file EDProducerBase.cc.

Referenced by doEndProcessBlock().

246 {}

◆ doEndRun()

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

Definition at line 125 of file EDProducerBase.cc.

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

125  {
126  Run r(info, moduleDescription_, mcc, true);
127  r.setConsumer(this);
128  r.setProducer(this);
129  Run const& cnstR = r;
130  ESParentContext parentC(mcc);
131  const EventSetup c{
132  info, static_cast<unsigned int>(Transition::EndRun), esGetTokenIndices(Transition::EndRun), parentC};
133  this->doEndRunSummary_(r, c);
134  this->doEndRunProduce_(r, c);
135  this->doEndRun_(cnstR, c);
136  commit_(r);
137  }
static const TGPicture * info(bool iBackgroundIsBlack)
virtual void doEndRunSummary_(Run const &rp, EventSetup const &c)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
ModuleDescription moduleDescription_
void commit_(P &iPrincipal)
Definition: ProducerBase.h:121
virtual void doEndRunProduce_(Run &rp, EventSetup const &c)
virtual void doEndRun_(Run const &rp, EventSetup const &c)

◆ doEndRun_()

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

Definition at line 236 of file EDProducerBase.cc.

Referenced by doEndRun().

236 {}

◆ doEndRunProduce_()

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

Definition at line 248 of file EDProducerBase.cc.

Referenced by doEndRun().

248 {}

◆ doEndRunSummary_()

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

Definition at line 238 of file EDProducerBase.cc.

Referenced by doEndRun().

238 {}

◆ doEndStream()

void EDProducerBase::doEndStream ( StreamID  id)
private

Definition at line 172 of file EDProducerBase.cc.

References doEndStream_().

172 { doEndStream_(id); }
virtual void doEndStream_(StreamID id)

◆ doEndStream_()

void EDProducerBase::doEndStream_ ( StreamID  id)
privatevirtual

Definition at line 222 of file EDProducerBase.cc.

Referenced by doEndStream().

222 {}

◆ doEvent()

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

Definition at line 54 of file EDProducerBase.cc.

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

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};
65  this->produce(e.streamID(), e, c);
66  commit_(e, &previousParentageIds_[streamIndex]);
67  return true;
68  }
static const TGPicture * info(bool iBackgroundIsBlack)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
ModuleDescription moduleDescription_
std::unique_ptr< ParentageID[]> previousParentageIds_
virtual void produce(StreamID, Event &, EventSetup const &) const =0
void commit_(P &iPrincipal)
Definition: ProducerBase.h:121
std::unique_ptr< std::vector< BranchID >[]> previousParentages_

◆ doPreallocate()

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

Definition at line 70 of file EDProducerBase.cc.

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

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

◆ 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 190 of file EDProducerBase.cc.

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

192  {
193  LuminosityBlock lb(info, moduleDescription_, mcc, false);
194  lb.setConsumer(this);
195  ESParentContext parentC(mcc);
196  const EventSetup c{info,
197  static_cast<unsigned int>(Transition::BeginLuminosityBlock),
199  parentC};
200  this->doStreamBeginLuminosityBlock_(id, lb, c);
201  }
static const TGPicture * info(bool iBackgroundIsBlack)
virtual void doStreamBeginLuminosityBlock_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
ModuleDescription moduleDescription_

◆ doStreamBeginLuminosityBlock_()

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

Definition at line 226 of file EDProducerBase.cc.

Referenced by doStreamBeginLuminosityBlock().

226 {}

◆ doStreamBeginRun()

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

Definition at line 173 of file EDProducerBase.cc.

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

173  {
174  Run r(info, moduleDescription_, mcc, false);
175  r.setConsumer(this);
176  ESParentContext parentC(mcc);
177  const EventSetup c{
178  info, static_cast<unsigned int>(Transition::BeginRun), esGetTokenIndices(Transition::BeginRun), parentC};
179  this->doStreamBeginRun_(id, r, c);
180  }
static const TGPicture * info(bool iBackgroundIsBlack)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
virtual void doStreamBeginRun_(StreamID id, Run const &rp, EventSetup const &c)
ModuleDescription moduleDescription_

◆ doStreamBeginRun_()

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

Definition at line 223 of file EDProducerBase.cc.

Referenced by doStreamBeginRun().

223 {}

◆ doStreamEndLuminosityBlock()

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

Definition at line 203 of file EDProducerBase.cc.

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

205  {
206  LuminosityBlock lb(info, moduleDescription_, mcc, true);
207  lb.setConsumer(this);
208  ESParentContext parentC(mcc);
209  const EventSetup c{info,
210  static_cast<unsigned int>(Transition::EndLuminosityBlock),
212  parentC};
213  this->doStreamEndLuminosityBlock_(id, lb, c);
214  this->doStreamEndLuminosityBlockSummary_(id, lb, c);
215  }
static const TGPicture * info(bool iBackgroundIsBlack)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
ModuleDescription moduleDescription_
virtual void doStreamEndLuminosityBlockSummary_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
virtual void doStreamEndLuminosityBlock_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)

◆ doStreamEndLuminosityBlock_()

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

Definition at line 227 of file EDProducerBase.cc.

Referenced by doStreamEndLuminosityBlock().

227 {}

◆ doStreamEndLuminosityBlockSummary_()

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

Definition at line 228 of file EDProducerBase.cc.

Referenced by doStreamEndLuminosityBlock().

230  {}

◆ doStreamEndRun()

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

Definition at line 181 of file EDProducerBase.cc.

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

181  {
182  Run r(info, moduleDescription_, mcc, true);
183  r.setConsumer(this);
184  ESParentContext parentC(mcc);
185  const EventSetup c{
186  info, static_cast<unsigned int>(Transition::EndRun), esGetTokenIndices(Transition::EndRun), parentC};
187  this->doStreamEndRun_(id, r, c);
188  this->doStreamEndRunSummary_(id, r, c);
189  }
static const TGPicture * info(bool iBackgroundIsBlack)
virtual void doStreamEndRunSummary_(StreamID id, Run const &rp, EventSetup const &c)
ESProxyIndex const * esGetTokenIndices(edm::Transition iTrans) const
virtual void doStreamEndRun_(StreamID id, Run const &rp, EventSetup const &c)
ModuleDescription moduleDescription_

◆ doStreamEndRun_()

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

Definition at line 224 of file EDProducerBase.cc.

Referenced by doStreamEndRun().

224 {}

◆ doStreamEndRunSummary_()

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

Definition at line 225 of file EDProducerBase.cc.

Referenced by doStreamEndRun().

225 {}

◆ endJob()

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

Definition at line 120 of file EDProducerBase.h.

Referenced by doEndJob().

120 {}

◆ fillDescriptions()

void EDProducerBase::fillDescriptions ( ConfigurationDescriptions descriptions)
static

Definition at line 254 of file EDProducerBase.cc.

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

254  {
256  desc.setUnknown();
257  descriptions.addDefault(desc);
258  }

◆ 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.

References moduleDescription_.

68 { return moduleDescription_; }
ModuleDescription 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 220 of file EDProducerBase.cc.

Referenced by doPreallocate().

220 {}

◆ preallocLumis()

void EDProducerBase::preallocLumis ( unsigned  int)
privatevirtual

Definition at line 218 of file EDProducerBase.cc.

Referenced by doPreallocate().

218 {}

◆ preallocLumisSummary()

void EDProducerBase::preallocLumisSummary ( unsigned  int)
privatevirtual

Definition at line 219 of file EDProducerBase.cc.

Referenced by doPreallocate().

219 {}

◆ preallocStreams()

void EDProducerBase::preallocStreams ( unsigned  int)
privatevirtual

Definition at line 217 of file EDProducerBase.cc.

Referenced by doPreallocate().

217 {}

◆ prevalidate()

void EDProducerBase::prevalidate ( ConfigurationDescriptions descriptions)
static

Definition at line 260 of file EDProducerBase.cc.

References edm::edmodule_mightGet_config().

260 { edmodule_mightGet_config(iConfig); }
void edmodule_mightGet_config(ConfigurationDescriptions &iDesc)

◆ 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.

References queue_.

79 { return queue_; }

◆ registerProductsAndCallbacks()

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

Definition at line 108 of file EDProducerBase.h.

References callgraph::module, moduleDescription_, and edm::ProducerBase::registerProducts().

108  {
110  }
void registerProducts(ProducerBase *, ProductRegistry *, ModuleDescription const &)
Definition: ProducerBase.cc:57
ModuleDescription moduleDescription_

◆ setModuleDescription()

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

Definition at line 159 of file EDProducerBase.h.

References moduleDescription_.

159 { moduleDescription_ = md; }
ModuleDescription 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().