#include "FWCore/Framework/interface/stream/EDAnalyzerAdaptorBase.h"

Inheritance diagram for edm::stream::EDAnalyzerAdaptorBase:

Public Member Functions
	EDAnalyzerAdaptorBase ()

const ModuleDescription &	moduleDescription () const

void	registerProductsAndCallbacks (EDAnalyzerAdaptorBase const , ProductRegistry reg)

virtual bool	wantsGlobalLuminosityBlocks () const =0

virtual bool	wantsGlobalRuns () const =0

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

std::string	workerType () const

virtual	~EDAnalyzerAdaptorBase ()

Protected Member Functions
const EDConsumerBase *	consumer () const

std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)

template<typename T >
void	createStreamModules (T iFunc)

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

Private Member Functions
void	doBeginJob ()

virtual void	doBeginLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *)=0

virtual void	doBeginRun (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *)=0

void	doBeginStream (StreamID id)

virtual void	doEndJob ()=0

virtual void	doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &c, ModuleCallingContext const *)=0

virtual void	doEndRun (RunPrincipal const &rp, EventSetupImpl const &c, ModuleCallingContext const *)=0

void	doEndStream (StreamID id)

bool	doEvent (EventPrincipal const &ep, EventSetupImpl const &c, ActivityRegistry , ModuleCallingContext const )

void	doPreallocate (PreallocationConfiguration const &)

void	doRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &)

void	doRespondToCloseInputFile (FileBlock const &fb)

void	doRespondToOpenInputFile (FileBlock const &fb)

void	doStreamBeginLuminosityBlock (StreamID id, LuminosityBlockPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *)

void	doStreamBeginRun (StreamID id, RunPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *)

void	doStreamEndLuminosityBlock (StreamID id, LuminosityBlockPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *)

void	doStreamEndRun (StreamID id, RunPrincipal const &ep, EventSetupImpl const &c, ModuleCallingContext const *)

	EDAnalyzerAdaptorBase (const EDAnalyzerAdaptorBase &)=delete

bool	hasAccumulator () const

bool	hasAcquire () const

const EDAnalyzerAdaptorBase &	operator= (const EDAnalyzerAdaptorBase &)=delete

void	preActionBeforeRunEventAsync (WaitingTask *iTask, ModuleCallingContext const &iModuleCallingContext, Principal const &iPrincipal) const

virtual void	preallocLumis (unsigned int)

void	setModuleDescription (ModuleDescription const &md)

void	setModuleDescriptionPtr (EDAnalyzerBase *m)

virtual void	setupLuminosityBlock (EDAnalyzerBase *, LuminosityBlockIndex)=0

virtual void	setupRun (EDAnalyzerBase *, RunIndex)=0

virtual void	setupStreamModules ()=0

virtual void	streamEndLuminosityBlockSummary (EDAnalyzerBase *, edm::LuminosityBlock const &, edm::EventSetup const &)=0

virtual void	streamEndRunSummary (EDAnalyzerBase *, edm::Run const &, edm::EventSetup const &)=0

Private Attributes
std::vector< EDAnalyzerBase * >	m_streamModules

ModuleDescription	moduleDescription_

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

template<typename T >
class	edm::WorkerT

Detailed Description

Description: [one line class summary]

Usage: <usage>

Definition at line 62 of file EDAnalyzerAdaptorBase.h.

Constructor & Destructor Documentation

EDAnalyzerAdaptorBase::EDAnalyzerAdaptorBase ( )

Definition at line 42 of file EDAnalyzerAdaptorBase.cc.

42 {}

EDAnalyzerAdaptorBase::~EDAnalyzerAdaptorBase ( )

virtual

Definition at line 49 of file EDAnalyzerAdaptorBase.cc.

References funct::m, and m_streamModules.

                                               {
   for (auto m : m_streamModules) {
     delete m;
   }
 }

edm::stream::EDAnalyzerAdaptorBase::EDAnalyzerAdaptorBase ( const EDAnalyzerAdaptorBase & )

privatedelete

Member Function Documentation

const edm::EDConsumerBase * EDAnalyzerAdaptorBase::consumer ( ) const

protected

Definition at line 110 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

110 { return m_streamModules[0]; }

edm::stream::EDAnalyzerAdaptorBase::m_streamModules

std::vector< EDAnalyzerBase * > m_streamModules

Definition: EDAnalyzerAdaptorBase.h:175

std::vector< edm::ConsumesInfo > EDAnalyzerAdaptorBase::consumesInfo ( ) const

protected

Definition at line 127 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

                                                                      {
   assert(not m_streamModules.empty());
   return m_streamModules[0]->consumesInfo();
 }

void EDAnalyzerAdaptorBase::convertCurrentProcessAlias ( std::string const & processName )

protected

Definition at line 121 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

                                                                                    {
   for (auto mod : m_streamModules) {
     mod->convertCurrentProcessAlias(processName);
   }
 }

template<typename T >

void edm::stream::EDAnalyzerAdaptorBase::createStreamModules ( T iFunc )

inlineprotected

Definition at line 89 of file EDAnalyzerAdaptorBase.h.

References EnergyCorrector::c, funct::m, modifiedElectrons_cfi::processName, and AlCaHLTBitMon_QueryRunRegistry::string.

                                         {
         for (auto& m : m_streamModules) {
           m = iFunc();
           setModuleDescriptionPtr(m);
         }
       }

void EDAnalyzerAdaptorBase::doBeginJob ( )

private

Definition at line 145 of file EDAnalyzerAdaptorBase.cc.

145 {}

virtual void edm::stream::EDAnalyzerAdaptorBase::doBeginLuminosityBlock	(	LuminosityBlockPrincipal const &	lbp,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

virtual void edm::stream::EDAnalyzerAdaptorBase::doBeginRun	(	RunPrincipal const &	rp,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

void EDAnalyzerAdaptorBase::doBeginStream ( StreamID id )

private

Definition at line 147 of file EDAnalyzerAdaptorBase.cc.

References triggerObjects_cff::id, and m_streamModules.

147 { m_streamModules[id]->beginStream(id); }

edm::stream::EDAnalyzerAdaptorBase::m_streamModules

std::vector< EDAnalyzerBase * > m_streamModules

Definition: EDAnalyzerAdaptorBase.h:175

triggerObjects_cff.id

id

Definition: triggerObjects_cff.py:29

virtual void edm::stream::EDAnalyzerAdaptorBase::doEndJob ( )

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

virtual void edm::stream::EDAnalyzerAdaptorBase::doEndLuminosityBlock	(	LuminosityBlockPrincipal const &	lbp,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

virtual void edm::stream::EDAnalyzerAdaptorBase::doEndRun	(	RunPrincipal const &	rp,
		EventSetupImpl const &	c,
		ModuleCallingContext const *
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

void EDAnalyzerAdaptorBase::doEndStream ( StreamID id )

private

Definition at line 148 of file EDAnalyzerAdaptorBase.cc.

References triggerObjects_cff::id, and m_streamModules.

148 { m_streamModules[id]->endStream(); }

edm::stream::EDAnalyzerAdaptorBase::m_streamModules

std::vector< EDAnalyzerBase * > m_streamModules

Definition: EDAnalyzerAdaptorBase.h:175

triggerObjects_cff.id

id

Definition: triggerObjects_cff.py:29

bool EDAnalyzerAdaptorBase::doEvent	(	EventPrincipal const &	ep,
		EventSetupImpl const &	c,
		ActivityRegistry *	act,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 132 of file EDAnalyzerAdaptorBase.cc.

References EnergyCorrector::c, MillePedeFileConverter_cfg::e, edm::Event, m_streamModules, mod(), moduleDescription_, edm::Event::setConsumer(), and edm::EventPrincipal::streamID().

                                                                      {
   assert(ep.streamID() < m_streamModules.size());
   auto mod = m_streamModules[ep.streamID()];
   Event e(ep, moduleDescription_, mcc);
   e.setConsumer(mod);
   const EventSetup c{ci, static_cast<unsigned int>(Transition::Event), mod->esGetTokenIndices(Transition::Event)};
   EventSignalsSentry sentry(act, mcc);
   mod->analyze(e, c);
   return true;
 }

void EDAnalyzerAdaptorBase::doPreallocate ( PreallocationConfiguration const & iPrealloc )

private

Definition at line 70 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, edm::PreallocationConfiguration::numberOfLuminosityBlocks(), edm::PreallocationConfiguration::numberOfStreams(), preallocLumis(), and setupStreamModules().

                                                                                      {
   m_streamModules.resize(iPrealloc.numberOfStreams(), static_cast<stream::EDAnalyzerBase*>(nullptr));
   setupStreamModules();
   preallocLumis(iPrealloc.numberOfLuminosityBlocks());
 }

void edm::stream::EDAnalyzerAdaptorBase::doRegisterThinnedAssociations	(	ProductRegistry const &	,
		ThinnedAssociationsHelper &
	)

inlineprivate

Definition at line 165 of file EDAnalyzerAdaptorBase.h.

165 {}

void EDAnalyzerAdaptorBase::doRespondToCloseInputFile ( FileBlock const & fb )

private

Definition at line 204 of file EDAnalyzerAdaptorBase.cc.

204 {}

void EDAnalyzerAdaptorBase::doRespondToOpenInputFile ( FileBlock const & fb )

private

Definition at line 203 of file EDAnalyzerAdaptorBase.cc.

203 {}

void EDAnalyzerAdaptorBase::doStreamBeginLuminosityBlock	(	StreamID	id,
		LuminosityBlockPrincipal const &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 175 of file EDAnalyzerAdaptorBase.cc.

References edm::BeginLuminosityBlock, EnergyCorrector::c, triggerObjects_cff::id, edm::LuminosityBlockPrincipal::index(), m_streamModules, mod(), moduleDescription_, and setupLuminosityBlock().

                                                                                           {
   auto mod = m_streamModules[id];
   setupLuminosityBlock(mod, lbp.index());
 
   LuminosityBlock lb(lbp, moduleDescription_, mcc, false);
   lb.setConsumer(mod);
   const EventSetup c{ci,
                      static_cast<unsigned int>(Transition::BeginLuminosityBlock),
                      mod->esGetTokenIndices(Transition::BeginLuminosityBlock)};
   mod->beginLuminosityBlock(lb, c);
 }

void EDAnalyzerAdaptorBase::doStreamBeginRun	(	StreamID	id,
		RunPrincipal const &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 150 of file EDAnalyzerAdaptorBase.cc.

References edm::BeginRun, EnergyCorrector::c, triggerObjects_cff::id, edm::RunPrincipal::index(), m_streamModules, mod(), moduleDescription_, alignCSCRings::r, and setupRun().

                                                                               {
   auto mod = m_streamModules[id];
   setupRun(mod, rp.index());
 
   Run r(rp, moduleDescription_, mcc, false);
   const EventSetup c{ci, static_cast<unsigned int>(Transition::BeginRun), mod->esGetTokenIndices(Transition::BeginRun)};
   r.setConsumer(mod);
   mod->beginRun(r, c);
 }

void EDAnalyzerAdaptorBase::doStreamEndLuminosityBlock	(	StreamID	id,
		LuminosityBlockPrincipal const &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 189 of file EDAnalyzerAdaptorBase.cc.

References EnergyCorrector::c, edm::EndLuminosityBlock, triggerObjects_cff::id, m_streamModules, mod(), moduleDescription_, edm::LuminosityBlock::setConsumer(), and streamEndLuminosityBlockSummary().

                                                                                         {
   auto mod = m_streamModules[id];
   LuminosityBlock lb(lbp, moduleDescription_, mcc, true);
   lb.setConsumer(mod);
   const EventSetup c{ci,
                      static_cast<unsigned int>(Transition::EndLuminosityBlock),
                      mod->esGetTokenIndices(Transition::EndLuminosityBlock)};
   mod->endLuminosityBlock(lb, c);
   streamEndLuminosityBlockSummary(mod, lb, c);
 }

void EDAnalyzerAdaptorBase::doStreamEndRun	(	StreamID	id,
		RunPrincipal const &	ep,
		EventSetupImpl const &	c,
		ModuleCallingContext const *	mcc
	)

private

Definition at line 163 of file EDAnalyzerAdaptorBase.cc.

References EnergyCorrector::c, edm::EndRun, triggerObjects_cff::id, m_streamModules, mod(), moduleDescription_, alignCSCRings::r, edm::Run::setConsumer(), and streamEndRunSummary().

                                                                             {
   auto mod = m_streamModules[id];
   Run r(rp, moduleDescription_, mcc, true);
   r.setConsumer(mod);
   const EventSetup c{ci, static_cast<unsigned int>(Transition::EndRun), mod->esGetTokenIndices(Transition::EndRun)};
   mod->endRun(r, c);
   streamEndRunSummary(mod, r, c);
 }

bool edm::stream::EDAnalyzerAdaptorBase::hasAccumulator ( ) const

inlineprivate

Definition at line 168 of file EDAnalyzerAdaptorBase.h.

References funct::m.

168 { return false; }

bool edm::stream::EDAnalyzerAdaptorBase::hasAcquire ( ) const

inlineprivate

Definition at line 167 of file EDAnalyzerAdaptorBase.h.

167 { return false; }

void EDAnalyzerAdaptorBase::itemsMayGet	(	BranchType	iType,
		std::vector< ProductResolverIndexAndSkipBit > &	iIndices
	)		const

protected

Definition at line 86 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

                                                                                                                    {
   assert(not m_streamModules.empty());
   m_streamModules[0]->itemsMayGet(iType, iIndices);
 }

void EDAnalyzerAdaptorBase::itemsToGet	(	BranchType	iType,
		std::vector< ProductResolverIndexAndSkipBit > &	iIndices
	)		const

protected

Definition at line 82 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

                                                                                                                   {
   assert(not m_streamModules.empty());
   m_streamModules[0]->itemsToGet(iType, iIndices);
 }

std::vector< edm::ProductResolverIndexAndSkipBit > const & EDAnalyzerAdaptorBase::itemsToGetFrom ( BranchType iType ) const

protected

Definition at line 91 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

                                                                                                                 {
   assert(not m_streamModules.empty());
   return m_streamModules[0]->itemsToGetFrom(iType);
 }

const ModuleDescription& edm::stream::EDAnalyzerAdaptorBase::moduleDescription ( ) const

inline

Definition at line 77 of file EDAnalyzerAdaptorBase.h.

77 { return moduleDescription_; }

edm::stream::EDAnalyzerAdaptorBase::moduleDescription_

ModuleDescription moduleDescription_

Definition: EDAnalyzerAdaptorBase.h:173

void EDAnalyzerAdaptorBase::modulesWhoseProductsAreConsumed	(	std::vector< ModuleDescription const * > &	modules,
		ProductRegistry const &	preg,
		std::map< std::string, ModuleDescription const * > const &	labelsToDesc,
		std::string const &	processName
	)		const

protected

Definition at line 112 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

                                         {
   assert(not m_streamModules.empty());
   return m_streamModules[0]->modulesWhoseProductsAreConsumed(modules, preg, labelsToDesc, processName);
 }

const EDAnalyzerAdaptorBase& edm::stream::EDAnalyzerAdaptorBase::operator= ( const EDAnalyzerAdaptorBase & )

privatedelete

void edm::stream::EDAnalyzerAdaptorBase::preActionBeforeRunEventAsync	(	WaitingTask *	iTask,
		ModuleCallingContext const &	iModuleCallingContext,
		Principal const &	iPrincipal
	)		const

inlineprivate

Definition at line 125 of file EDAnalyzerAdaptorBase.h.

References benchmark_cfg::fb.

127 {}

virtual void edm::stream::EDAnalyzerAdaptorBase::preallocLumis ( unsigned int )

inlineprivatevirtual

Reimplemented in edm::stream::EDAnalyzerAdaptor< T >.

Definition at line 122 of file EDAnalyzerAdaptorBase.h.

Referenced by doPreallocate().

122 {}

void EDAnalyzerAdaptorBase::registerProductsAndCallbacks	(	EDAnalyzerAdaptorBase const *	,
		ProductRegistry *	reg
	)

Definition at line 76 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

                                                                                                            {
   for (auto mod : m_streamModules) {
     mod->registerProductsAndCallbacks(mod, reg);
   }
 }

void edm::stream::EDAnalyzerAdaptorBase::setModuleDescription ( ModuleDescription const & md )

inlineprivate

Definition at line 172 of file EDAnalyzerAdaptorBase.h.

172 { moduleDescription_ = md; }

edm::stream::EDAnalyzerAdaptorBase::moduleDescription_

ModuleDescription moduleDescription_

Definition: EDAnalyzerAdaptorBase.h:173

void EDAnalyzerAdaptorBase::setModuleDescriptionPtr ( EDAnalyzerBase * m )

private

Definition at line 206 of file EDAnalyzerAdaptorBase.cc.

References moduleDescription_, and edm::stream::EDAnalyzerBase::setModuleDescriptionPtr().

                                                                      {
   m->setModuleDescriptionPtr(&moduleDescription_);
 }

virtual void edm::stream::EDAnalyzerAdaptorBase::setupLuminosityBlock	(	EDAnalyzerBase *	,
		LuminosityBlockIndex
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

Referenced by doStreamBeginLuminosityBlock().

virtual void edm::stream::EDAnalyzerAdaptorBase::setupRun	(	EDAnalyzerBase *	,
		RunIndex
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

Referenced by doStreamBeginRun().

virtual void edm::stream::EDAnalyzerAdaptorBase::setupStreamModules ( )

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

Referenced by doPreallocate().

virtual void edm::stream::EDAnalyzerAdaptorBase::streamEndLuminosityBlockSummary	(	EDAnalyzerBase *	,
		edm::LuminosityBlock const &	,
		edm::EventSetup const &
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

Referenced by doStreamEndLuminosityBlock().

virtual void edm::stream::EDAnalyzerAdaptorBase::streamEndRunSummary	(	EDAnalyzerBase *	,
		edm::Run const &	,
		edm::EventSetup const &
	)

privatepure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

Referenced by doStreamEndRun().

void EDAnalyzerAdaptorBase::updateLookup	(	BranchType	iBranchType,
		ProductResolverIndexHelper const &	iHelper,
		bool	iPrefetchMayGet
	)

protected

Definition at line 96 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

                                                                {
   for (auto mod : m_streamModules) {
     mod->updateLookup(iType, iHelper, iPrefetchMayGet);
   }
 }

void EDAnalyzerAdaptorBase::updateLookup ( eventsetup::ESRecordsToProxyIndices const & iPI )

protected

Definition at line 104 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

                                                                                      {
   for (auto mod : m_streamModules) {
     mod->updateLookup(iPI);
   }
 }

virtual bool edm::stream::EDAnalyzerAdaptorBase::wantsGlobalLuminosityBlocks ( ) const

pure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

virtual bool edm::stream::EDAnalyzerAdaptorBase::wantsGlobalRuns ( ) const

pure virtual

Implemented in edm::stream::EDAnalyzerAdaptor< T >.

bool edm::stream::EDAnalyzerAdaptorBase::wantsStreamLuminosityBlocks ( ) const

inline

Definition at line 82 of file EDAnalyzerAdaptorBase.h.

82 { return true; }

bool edm::stream::EDAnalyzerAdaptorBase::wantsStreamRuns ( ) const

inline

Definition at line 81 of file EDAnalyzerAdaptorBase.h.

81 { return true; }

std::string edm::stream::EDAnalyzerAdaptorBase::workerType ( ) const

inline

Definition at line 84 of file EDAnalyzerAdaptorBase.h.

References edm::maker::ModuleHolderT< T >::registerProductsAndCallbacks().

84 { return "WorkerT<EDAnalyzerAdaptorBase>"; }

Friends And Related Function Documentation

template<typename T >

friend class edm::maker::ModuleHolderT

friend

Definition at line 67 of file EDAnalyzerAdaptorBase.h.

template<typename T >

friend class edm::WorkerT

friend

Definition at line 65 of file EDAnalyzerAdaptorBase.h.

Member Data Documentation

std::vector<EDAnalyzerBase*> edm::stream::EDAnalyzerAdaptorBase::m_streamModules

private

ModuleDescription edm::stream::EDAnalyzerAdaptorBase::moduleDescription_

private

Definition at line 173 of file EDAnalyzerAdaptorBase.h.

Referenced by doEvent(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), and setModuleDescriptionPtr().

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation