#include "EDAnalyzerAdaptor.h"

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

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

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

	~EDAnalyzerAdaptor () override

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

const ModuleDescription &	moduleDescription () const

void	registerProductsAndCallbacks (EDAnalyzerAdaptorBase const , ProductRegistry reg)

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

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 const &lbp, EventSetupImpl const &ci, ModuleCallingContext const *mcc) final

void	doBeginRun (RunPrincipal const &rp, EventSetupImpl const &ci, ModuleCallingContext const *mcc) final

void	doEndJob () final

void	doEndLuminosityBlock (LuminosityBlockPrincipal const &lbp, EventSetupImpl const &ci, ModuleCallingContext const *mcc) final

void	doEndRun (RunPrincipal const &rp, EventSetupImpl const &ci, ModuleCallingContext const *mcc) final

	EDAnalyzerAdaptor (const EDAnalyzerAdaptor &)=delete

const EDAnalyzerAdaptor &	operator= (const EDAnalyzerAdaptor &)=delete

void	preallocLumis (unsigned int iNLumis) final

void	setupLuminosityBlock (EDAnalyzerBase *iProd, LuminosityBlockIndex iIndex) final

void	setupRun (EDAnalyzerBase *iProd, RunIndex iIndex) final

void	setupStreamModules () final

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

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

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

impl::choose_mutex< typename T::LuminosityBlockSummaryCache >::type	m_lumiSummaryLock

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

impl::choose_mutex< typename T::RunSummaryCache >::type	m_runSummaryLock

Additional Inherited Members
Protected Member Functions inherited from edm::stream::EDAnalyzerAdaptorBase
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 &)

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 44 of file EDAnalyzerAdaptor.h.

Member Typedef Documentation

template<typename T >

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

private

Definition at line 72 of file EDAnalyzerAdaptor.h.

template<typename T >

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

private

Definition at line 75 of file EDAnalyzerAdaptor.h.

template<typename T >

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

private

Definition at line 76 of file EDAnalyzerAdaptor.h.

template<typename T >

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

private

Definition at line 73 of file EDAnalyzerAdaptor.h.

template<typename T >

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

private

Definition at line 74 of file EDAnalyzerAdaptor.h.

Constructor & Destructor Documentation

template<typename T >

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

inline

Definition at line 53 of file EDAnalyzerAdaptor.h.

                                                       : 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 = impl::makeGlobal<T>(iPSet, dummy);
       }

template<typename T >

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

inlineoverride

Definition at line 61 of file EDAnalyzerAdaptor.h.

61 {}

template<typename T >

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

privatedelete

Member Function Documentation

template<typename T >

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

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 140 of file EDAnalyzerAdaptor.h.

References edm::BeginLuminosityBlock, EnergyCorrector::c, constexpr, edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, or, and edm::LuminosityBlock::setConsumer().

                                                                          {
         if constexpr (T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache) {
           LuminosityBlock lb(lbp, moduleDescription(), mcc, false);
           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());
           const EventSetup c{ci,
                              static_cast<unsigned int>(Transition::BeginLuminosityBlock),
                              this->consumer()->esGetTokenIndices(Transition::BeginLuminosityBlock)};
           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 const &	rp,
		EventSetupImpl const &	ci,
		ModuleCallingContext const *	mcc
	)

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 111 of file EDAnalyzerAdaptor.h.

References edm::BeginRun, EnergyCorrector::c, constexpr, edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, or, alignCSCRings::r, and edm::Run::setConsumer().

                                                                                                                {
         if constexpr (T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache) {
           Run r(rp, moduleDescription(), mcc, false);
           r.setConsumer(consumer());
           Run const& cnstR = r;
           RunIndex ri = rp.index();
           const EventSetup c{ci,
                              static_cast<unsigned int>(Transition::BeginRun),
                              this->consumer()->esGetTokenIndices(Transition::BeginRun)};
           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 ( )

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 92 of file EDAnalyzerAdaptor.h.

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

edm::stream::EDAnalyzerAdaptor::m_global

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

Definition: EDAnalyzerAdaptor.h:181

edm::stream::CallGlobalImpl::endJob

static void endJob(typename T::GlobalCache *iCache)

Definition: callAbilities.h:41

template<typename T >

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

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 158 of file EDAnalyzerAdaptor.h.

References EnergyCorrector::c, constexpr, edm::EndLuminosityBlock, edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, or, and edm::LuminosityBlock::setConsumer().

                                                                        {
         if constexpr (T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache) {
           LuminosityBlock lb(lbp, moduleDescription(), mcc, true);
           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());
           const EventSetup c{ci,
                              static_cast<unsigned int>(Transition::EndLuminosityBlock),
                              this->consumer()->esGetTokenIndices(Transition::EndLuminosityBlock)};
           MyGlobalLuminosityBlockSummary::globalEndLuminosityBlock(lb, c, &lc, m_lumiSummaries[li].get());
           MyGlobalLuminosityBlock::endLuminosityBlock(lb, c, &lc);
         }
       }

template<typename T >

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

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 125 of file EDAnalyzerAdaptor.h.

References EnergyCorrector::c, constexpr, Ecal2004TBTDCRanges_v1_cff::endRun, edm::EndRun, edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, or, alignCSCRings::r, and edm::Run::setConsumer().

                                                                                                              {
         if constexpr (T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache) {
           Run r(rp, moduleDescription(), mcc, true);
           r.setConsumer(consumer());
 
           RunIndex ri = rp.index();
           typename T::RunContext rc(m_runs[ri].get(), m_global.get());
           const EventSetup c{ci,
                              static_cast<unsigned int>(Transition::EndRun),
                              this->consumer()->esGetTokenIndices(Transition::EndRun)};
           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 63 of file EDAnalyzerAdaptor.h.

References fillDescriptions().

63 { T::fillDescriptions(descriptions); }

fillDescriptions

static void fillDescriptions(edm::ConfigurationDescriptions &descriptions)

template<typename T >

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

privatedelete

template<typename T >

void edm::stream::EDAnalyzerAdaptor< T >::preallocLumis ( unsigned int iNLumis )

inlinefinalprivatevirtual

Reimplemented from edm::stream::EDAnalyzerAdaptorBase.

Definition at line 87 of file EDAnalyzerAdaptor.h.

                                                      {
         m_lumis.resize(iNLumis);
         m_lumiSummaries.resize(iNLumis);
       }

template<typename T >

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

inlinestatic

Definition at line 64 of file EDAnalyzerAdaptor.h.

64 { T::prevalidate(descriptions); }

template<typename T >

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

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 100 of file EDAnalyzerAdaptor.h.

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

template<typename T >

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

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 93 of file EDAnalyzerAdaptor.h.

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

edm::stream::EDAnalyzerAdaptor::m_runs

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

Definition: EDAnalyzerAdaptor.h:182

edm::stream::CallGlobalRunImpl::set

static void set(B *iProd, typename T::RunCache const *iCache)

Definition: callAbilities.h:64

template<typename T >

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

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 78 of file EDAnalyzerAdaptor.h.

References 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
	)

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 103 of file EDAnalyzerAdaptor.h.

References alignCSCRings::s.

                                                                            {
         auto s = m_lumiSummaries[iLumi.index()].get();
         std::lock_guard<decltype(m_lumiSummaryLock)> guard(m_lumiSummaryLock);
         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
	)

inlinefinalprivatevirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 94 of file EDAnalyzerAdaptor.h.

References alignCSCRings::s.

                                                                                                           {
         auto s = m_runSummaries[iRun.index()].get();
         std::lock_guard<decltype(m_runSummaryLock)> guard(m_runSummaryLock);
         MyGlobalRunSummary::streamEndRunSummary(iProd, iRun, iES, s);
       }

template<typename T >

bool edm::stream::EDAnalyzerAdaptor< T >::wantsGlobalLuminosityBlocks ( ) const

inlinefinalvirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 67 of file EDAnalyzerAdaptor.h.

References edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, and or.

                                                      {
         return T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache;
       }

template<typename T >

bool edm::stream::EDAnalyzerAdaptor< T >::wantsGlobalRuns ( ) const

inlinefinalvirtual

Implements edm::stream::EDAnalyzerAdaptorBase.

Definition at line 66 of file EDAnalyzerAdaptor.h.

References edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, and or.

66 { return T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache; }

edm::module::AbilityBits::kRunSummaryCache

Definition: moduleAbilityEnums.h:55

or

The Signals That Services Can Subscribe To This is based on ActivityRegistry and is current per Services can connect to the signals distributed by the ActivityRegistry in order to monitor the activity of the application Each possible callback has some defined which we here list in angle e< void, edm::EventID const &, edm::Timestamp const & > We also list in braces which AR_WATCH_USING_METHOD_ is used for those or

Definition: Activities.doc:12

edm::module::AbilityBits::kRunCache

Definition: moduleAbilityEnums.h:53