#include "EDAnalyzerAdaptor.h"

Inheritance diagram for edm::stream::EDAnalyzerAdaptor< T >:

Public Member Functions
	EDAnalyzerAdaptor (edm::ParameterSet const &iPSet)

	~EDAnalyzerAdaptor ()

Public Member Functions inherited from edm::stream::EDAnalyzerAdaptorBase
	EDAnalyzerAdaptorBase ()

const ModuleDescription &	moduleDescription ()

void	registerProductsAndCallbacks (EDAnalyzerAdaptorBase const , ProductRegistry reg)

std::string	workerType () const

virtual	~EDAnalyzerAdaptorBase ()

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Types
typedef CallGlobal< T >	MyGlobal

typedef CallGlobalLuminosityBlock< T >	MyGlobalLuminosityBlock

typedef CallGlobalLuminosityBlockSummary < T >	MyGlobalLuminosityBlockSummary

typedef CallGlobalRun< T >	MyGlobalRun

typedef CallGlobalRunSummary< T >	MyGlobalRunSummary

Private Member Functions
void	doBeginLuminosityBlock (LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *mcc) overridefinal

void	doBeginRun (RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc) overridefinal

void	doEndJob () overridefinal

void	doEndLuminosityBlock (LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *mcc) overridefinal

void	doEndRun (RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *mcc) overridefinal

	EDAnalyzerAdaptor (const EDAnalyzerAdaptor &)

const EDAnalyzerAdaptor &	operator= (const EDAnalyzerAdaptor &)

void	setupLuminosityBlock (EDAnalyzerBase *iProd, LuminosityBlockIndex iIndex) overridefinal

void	setupRun (EDAnalyzerBase *iProd, RunIndex iIndex) overridefinal

void	setupStreamModules () overridefinal

void	streamEndLuminosityBlockSummary (EDAnalyzerBase *iProd, edm::LuminosityBlock const &iLumi, edm::EventSetup const &iES) overridefinal

void	streamEndRunSummary (EDAnalyzerBase *iProd, edm::Run const &iRun, edm::EventSetup const &iES) overridefinal

Private Attributes
impl::choose_unique_ptr < typename T::GlobalCache > ::type	m_global

impl::choose_shared_vec < typename T::LuminosityBlockCache const > ::type	m_lumis

impl::choose_shared_vec < typename T::LuminosityBlockSummaryCache > ::type	m_lumiSummaries

ParameterSet const *	m_pset

impl::choose_shared_vec < typename T::RunCache const > ::type	m_runs

impl::choose_shared_vec < typename T::RunSummaryCache > ::type	m_runSummaries

Additional Inherited Members
Protected Member Functions inherited from edm::stream::EDAnalyzerAdaptorBase
const EDConsumerBase *	consumer () const

std::vector< ConsumesInfo >	consumesInfo () const

template<typename T >
void	createStreamModules (T iFunc)

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

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

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) 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, ProductHolderIndexHelper const &)

Detailed Description

template<typename T>
class edm::stream::EDAnalyzerAdaptor< T >

Description: Adapts an edm::stream::EDAnalyzer<> to work with an edm::Worker

Usage: <usage>

Definition at line 41 of file EDAnalyzerAdaptor.h.

Member Typedef Documentation

template<typename T >

typedef CallGlobal<T> edm::stream::EDAnalyzerAdaptor< T >::MyGlobal

private

Definition at line 73 of file EDAnalyzerAdaptor.h.

template<typename T >

typedef CallGlobalLuminosityBlock<T> edm::stream::EDAnalyzerAdaptor< T >::MyGlobalLuminosityBlock

private

Definition at line 76 of file EDAnalyzerAdaptor.h.

template<typename T >

typedef CallGlobalLuminosityBlockSummary<T> edm::stream::EDAnalyzerAdaptor< T >::MyGlobalLuminosityBlockSummary

private

Definition at line 77 of file EDAnalyzerAdaptor.h.

template<typename T >

typedef CallGlobalRun<T> edm::stream::EDAnalyzerAdaptor< T >::MyGlobalRun

private

Definition at line 74 of file EDAnalyzerAdaptor.h.

template<typename T >

typedef CallGlobalRunSummary<T> edm::stream::EDAnalyzerAdaptor< T >::MyGlobalRunSummary

private

Definition at line 75 of file EDAnalyzerAdaptor.h.

Constructor & Destructor Documentation

template<typename T >

edm::stream::EDAnalyzerAdaptor< T >::EDAnalyzerAdaptor ( edm::ParameterSet const & iPSet )

inline

Definition at line 51 of file EDAnalyzerAdaptor.h.

References edm::stream::EDAnalyzerAdaptor< T >::m_global, edm::stream::EDAnalyzerAdaptor< T >::m_lumis, edm::stream::EDAnalyzerAdaptor< T >::m_lumiSummaries, edm::stream::EDAnalyzerAdaptor< T >::m_runs, edm::stream::EDAnalyzerAdaptor< T >::m_runSummaries, and fetchall_from_DQM_v2::release.

                                                       :
       m_pset(&iPSet)
       {
         m_runs.resize(1);
         m_lumis.resize(1);
         m_runSummaries.resize(1);
         m_lumiSummaries.resize(1);
         typename T::GlobalCache const* dummy=nullptr;
         m_global.reset( impl::makeGlobal<T>(iPSet,dummy).release());
       }

template<typename T >

edm::stream::EDAnalyzerAdaptor< T >::~EDAnalyzerAdaptor ( )

inline

Definition at line 61 of file EDAnalyzerAdaptor.h.

61 {

62 }

template<typename T >

edm::stream::EDAnalyzerAdaptor< T >::EDAnalyzerAdaptor ( const EDAnalyzerAdaptor< T > & )

private

Member Function Documentation

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::doBeginLuminosityBlock	(	LuminosityBlockPrincipal &	lbp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 141 of file EDAnalyzerAdaptor.h.

References edm::stream::CallGlobalLuminosityBlockImpl< T, bool >::beginLuminosityBlock(), edm::stream::CallGlobalLuminosityBlockSummaryImpl< T, bool >::beginLuminosityBlock(), EnergyCorrector::c, edm::stream::EDAnalyzerAdaptorBase::consumer(), edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, edm::stream::EDAnalyzerAdaptor< T >::m_global, edm::stream::EDAnalyzerAdaptor< T >::m_lumis, edm::stream::EDAnalyzerAdaptor< T >::m_lumiSummaries, edm::stream::EDAnalyzerAdaptor< T >::m_runs, edm::stream::EDAnalyzerAdaptorBase::moduleDescription(), or, and edm::LuminosityBlock::setConsumer().

       {
         if(T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache) {
           LuminosityBlock lb(lbp, moduleDescription(), mcc);
           lb.setConsumer(consumer());
           LuminosityBlock const& cnstLb = lb;
           LuminosityBlockIndex li = lbp.index();
           RunIndex ri = lbp.runPrincipal().index();
           typename T::RunContext rc(m_runs[ri].get(),m_global.get());
           MyGlobalLuminosityBlock::beginLuminosityBlock(cnstLb,c,&rc,m_lumis[li]);
           typename T::LuminosityBlockContext lc(m_lumis[li].get(),m_runs[ri].get(),m_global.get());
           MyGlobalLuminosityBlockSummary::beginLuminosityBlock(cnstLb,c,&lc,m_lumiSummaries[li]);
         }
         
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::doBeginRun	(	RunPrincipal &	rp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 112 of file EDAnalyzerAdaptor.h.

References edm::stream::CallGlobalRunImpl< T, bool >::beginRun(), edm::stream::CallGlobalRunSummaryImpl< T, bool >::beginRun(), EnergyCorrector::c, edm::stream::EDAnalyzerAdaptorBase::consumer(), edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, edm::stream::EDAnalyzerAdaptor< T >::m_global, edm::stream::EDAnalyzerAdaptor< T >::m_runs, edm::stream::EDAnalyzerAdaptor< T >::m_runSummaries, edm::stream::EDAnalyzerAdaptorBase::moduleDescription(), or, alignCSCRings::r, and edm::Run::setConsumer().

                                                                       {
         if(T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache) {
           Run r(rp, moduleDescription(), mcc);
           r.setConsumer(consumer());
           Run const& cnstR = r;
           RunIndex ri = rp.index();
           MyGlobalRun::beginRun(cnstR,c,m_global.get(),m_runs[ri]);
           typename T::RunContext rc(m_runs[ri].get(),m_global.get());
           MyGlobalRunSummary::beginRun(cnstR,c,&rc,m_runSummaries[ri]);
         }
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::doEndJob ( )

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 88 of file EDAnalyzerAdaptor.h.

References edm::stream::CallGlobalImpl< T, bool >::endJob(), and edm::stream::EDAnalyzerAdaptor< T >::m_global.

                                      {
         MyGlobal::endJob(m_global.get());
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::doEndLuminosityBlock	(	LuminosityBlockPrincipal &	lbp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 158 of file EDAnalyzerAdaptor.h.

References EnergyCorrector::c, edm::stream::EDAnalyzerAdaptorBase::consumer(), edm::stream::CallGlobalLuminosityBlockImpl< T, bool >::endLuminosityBlock(), edm::stream::CallGlobalLuminosityBlockSummaryImpl< T, bool >::globalEndLuminosityBlock(), edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, edm::stream::EDAnalyzerAdaptor< T >::m_global, edm::stream::EDAnalyzerAdaptor< T >::m_lumis, edm::stream::EDAnalyzerAdaptor< T >::m_lumiSummaries, edm::stream::EDAnalyzerAdaptor< T >::m_runs, edm::stream::EDAnalyzerAdaptorBase::moduleDescription(), or, and edm::LuminosityBlock::setConsumer().

                                                                                 {
         if(T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache) {
           
           LuminosityBlock lb(lbp, moduleDescription(), mcc);
           lb.setConsumer(consumer());
           
           LuminosityBlockIndex li = lbp.index();
           RunIndex ri = lbp.runPrincipal().index();
           typename T::LuminosityBlockContext lc(m_lumis[li].get(),m_runs[ri].get(),m_global.get());
           MyGlobalLuminosityBlockSummary::globalEndLuminosityBlock(lb,c,&lc,m_lumiSummaries[li].get());
           MyGlobalLuminosityBlock::endLuminosityBlock(lb,c,&lc);
         }
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::doEndRun	(	RunPrincipal &	rp,
		EventSetup const &	c,
		ModuleCallingContext const *	mcc
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 125 of file EDAnalyzerAdaptor.h.

References EnergyCorrector::c, edm::stream::EDAnalyzerAdaptorBase::consumer(), edm::stream::CallGlobalRunImpl< T, bool >::endRun(), edm::stream::CallGlobalRunSummaryImpl< T, bool >::globalEndRun(), edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, edm::stream::EDAnalyzerAdaptor< T >::m_global, edm::stream::EDAnalyzerAdaptor< T >::m_runs, edm::stream::EDAnalyzerAdaptor< T >::m_runSummaries, edm::stream::EDAnalyzerAdaptorBase::moduleDescription(), or, alignCSCRings::r, and edm::Run::setConsumer().

       {
         if(T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache) {
           
           Run r(rp, moduleDescription(), mcc);
           r.setConsumer(consumer());
 
           RunIndex ri = rp.index();
           typename T::RunContext rc(m_runs[ri].get(),m_global.get());
           MyGlobalRunSummary::globalEndRun(r,c,&rc,m_runSummaries[ri].get());
           MyGlobalRun::endRun(r,c,&rc);
         }
       }

template<typename T >

static void edm::stream::EDAnalyzerAdaptor< T >::fillDescriptions ( ConfigurationDescriptions & descriptions )

inlinestatic

Definition at line 64 of file EDAnalyzerAdaptor.h.

                                                                             {
         T::fillDescriptions(descriptions);
       }

template<typename T >

const EDAnalyzerAdaptor& edm::stream::EDAnalyzerAdaptor< T >::operator= ( const EDAnalyzerAdaptor< T > & )

private

template<typename T >

static void edm::stream::EDAnalyzerAdaptor< T >::prevalidate ( ConfigurationDescriptions & descriptions )

inlinestatic

Definition at line 67 of file EDAnalyzerAdaptor.h.

                                                                        {
         T::prevalidate(descriptions);
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::setupLuminosityBlock	(	EDAnalyzerBase *	iProd,
		LuminosityBlockIndex	iIndex
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 101 of file EDAnalyzerAdaptor.h.

References edm::stream::EDAnalyzerAdaptor< T >::m_lumis, and edm::stream::CallGlobalLuminosityBlockImpl< T, bool >::set().

       {
         MyGlobalLuminosityBlock::set(iProd, m_lumis[iIndex].get());
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::setupRun	(	EDAnalyzerBase *	iProd,
		RunIndex	iIndex
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 91 of file EDAnalyzerAdaptor.h.

References edm::stream::EDAnalyzerAdaptor< T >::m_runs, and edm::stream::CallGlobalRunImpl< T, bool >::set().

                                                                            {
         MyGlobalRun::set(iProd, m_runs[iIndex].get());
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::setupStreamModules ( )

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 79 of file EDAnalyzerAdaptor.h.

References edm::stream::EDAnalyzerAdaptorBase::createStreamModules(), edm::stream::EDAnalyzerAdaptor< T >::m_global, edm::stream::EDAnalyzerAdaptor< T >::m_pset, edm::stream::CallGlobalImpl< T, bool >::set(), and tmp.

                                                {
         this->createStreamModules([this] () -> EDAnalyzerBase* {
           auto tmp = impl::makeStreamModule<T>(*m_pset,m_global.get());
           MyGlobal::set(tmp,m_global.get());
           return tmp;
         });
         m_pset= nullptr;
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::streamEndLuminosityBlockSummary	(	EDAnalyzerBase *	iProd,
		edm::LuminosityBlock const &	iLumi,
		edm::EventSetup const &	iES
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 105 of file EDAnalyzerAdaptor.h.

References edm::stream::EDAnalyzerAdaptor< T >::m_lumiSummaries, alignCSCRings::s, and edm::stream::CallGlobalLuminosityBlockSummaryImpl< T, bool >::streamEndLuminosityBlockSummary().

                                                                                     {
         auto s = m_lumiSummaries[iLumi.index()].get();
         MyGlobalLuminosityBlockSummary::streamEndLuminosityBlockSummary(iProd,iLumi,iES,s);
       }

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::streamEndRunSummary	(	EDAnalyzerBase *	iProd,
		edm::Run const &	iRun,
		edm::EventSetup const &	iES
	)

inlinefinaloverrideprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 94 of file EDAnalyzerAdaptor.h.

References edm::stream::EDAnalyzerAdaptor< T >::m_runSummaries, alignCSCRings::s, and edm::stream::CallGlobalRunSummaryImpl< T, bool >::streamEndRunSummary().

                                                                         {
         auto s = m_runSummaries[iRun.index()].get();
         MyGlobalRunSummary::streamEndRunSummary(iProd,iRun,iES,s);
       }