edm::stream::ProducingModuleAdaptor< T, M, B > Class Template Reference

#include "ProducingModuleAdaptor.h"

Inheritance diagram for edm::stream::ProducingModuleAdaptor< T, M, B >:

Public Member Functions
	ProducingModuleAdaptor (edm::ParameterSet const &iPSet)
	~ProducingModuleAdaptor ()
Public Member Functions inherited from double_binary
	double_binary (double d)
	double_binary ()

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

Private Types
typedef CallBeginLuminosityBlockProduce < T >	MyBeginLuminosityBlockProduce
typedef CallBeginRunProduce< T >	MyBeginRunProduce
typedef CallEndLuminosityBlockProduce < T >	MyEndLuminosityBlockProduce
typedef CallEndRunProduce< T >	MyEndRunProduce
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
const ProducingModuleAdaptor &	operator= (const ProducingModuleAdaptor &)=delete
	ProducingModuleAdaptor (const ProducingModuleAdaptor &)=delete
void	setupLuminosityBlock (M *iProd, LuminosityBlockIndex iIndex) overridefinal
void	setupRun (M *iProd, RunIndex iIndex) overridefinal
void	setupStreamModules () overridefinal
void	streamEndLuminosityBlockSummary (M *iProd, edm::LuminosityBlock const &iLumi, edm::EventSetup const &iES) overridefinal
void	streamEndRunSummary (M *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
Public Attributes inherited from double_binary
double	val_

Detailed Description

template<typename T, typename M, typename B>
class edm::stream::ProducingModuleAdaptor< T, M, B >

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

Usage: <usage>

Definition at line 37 of file ProducingModuleAdaptor.h.

Member Typedef Documentation

template<typename T , typename M , typename B >

typedef CallBeginLuminosityBlockProduce<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyBeginLuminosityBlockProduce

private

Definition at line 70 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallBeginRunProduce<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyBeginRunProduce

private

Definition at line 66 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallEndLuminosityBlockProduce<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyEndLuminosityBlockProduce

private

Definition at line 71 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallEndRunProduce<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyEndRunProduce

private

Definition at line 67 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallGlobal<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyGlobal

private

Definition at line 63 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallGlobalLuminosityBlock<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyGlobalLuminosityBlock

private

Definition at line 68 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallGlobalLuminosityBlockSummary<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyGlobalLuminosityBlockSummary

private

Definition at line 69 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallGlobalRun<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyGlobalRun

private

Definition at line 64 of file ProducingModuleAdaptor.h.

template<typename T , typename M , typename B >

typedef CallGlobalRunSummary<T> edm::stream::ProducingModuleAdaptor< T, M, B >::MyGlobalRunSummary

private

Definition at line 65 of file ProducingModuleAdaptor.h.

Constructor & Destructor Documentation

template<typename T , typename M , typename B >

edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor ( edm::ParameterSet const &  iPSet )

inline

Definition at line 41 of file ProducingModuleAdaptor.h.

References edm::stream::ProducingModuleAdaptor< T, M, B >::m_global, edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumis, edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumiSummaries, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runs, edm::stream::ProducingModuleAdaptor< T, M, B >::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 , typename M , typename B >

edm::stream::ProducingModuleAdaptor< T, M, B >::~ProducingModuleAdaptor ( )

inline

Definition at line 51 of file ProducingModuleAdaptor.h.

                                {
      }

template<typename T , typename M , typename B >

edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor ( const ProducingModuleAdaptor< T, M, B > &  )

privatedelete

Member Function Documentation

template<typename T , typename M , typename B >

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

inlinefinaloverrideprivate

Definition at line 143 of file ProducingModuleAdaptor.h.

References edm::stream::CallGlobalLuminosityBlockImpl< T, bool >::beginLuminosityBlock(), edm::stream::CallGlobalLuminosityBlockSummaryImpl< T, bool >::beginLuminosityBlock(), EnergyCorrector::c, OfflineOutput_cfi::consumer, edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, edm::stream::ProducingModuleAdaptor< T, M, B >::m_global, edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumis, edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumiSummaries, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runs, or, edm::stream::CallBeginLuminosityBlockProduceImpl< T, bool >::produce(), and edm::LuminosityBlock::setConsumer().

      {
        if(T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache or T::HasAbility::kBeginLuminosityBlockProducer) {
          LuminosityBlock lb(lbp, this->moduleDescription(), mcc);
          lb.setConsumer(this->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]);
          if(T::HasAbility::kBeginLuminosityBlockProducer) {
            MyBeginLuminosityBlockProduce::produce(lb,c,&lc);
            this->commit(lb);
          }
        }
        
      }

template<typename T , typename M , typename B >

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

inlinefinaloverrideprivate

Definition at line 106 of file ProducingModuleAdaptor.h.

References edm::stream::CallGlobalRunImpl< T, bool >::beginRun(), edm::stream::CallGlobalRunSummaryImpl< T, bool >::beginRun(), EnergyCorrector::c, OfflineOutput_cfi::consumer, edm::module::AbilityBits::kBeginRunProducer, edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, edm::stream::ProducingModuleAdaptor< T, M, B >::m_global, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runs, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runSummaries, or, edm::stream::CallBeginRunProduceImpl< T, bool >::produce(), alignCSCRings::r, and edm::Run::setConsumer().

                                                                      {
        if(T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache or T::HasAbility::kBeginRunProducer) {
          Run r(rp, this->moduleDescription(), mcc);
          r.setConsumer(this->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]);
          if(T::HasAbility::kBeginRunProducer) {
            MyBeginRunProduce::produce(r,c,&rc);
            this->commit(r);
          }
        }
      }

template<typename T , typename M , typename B >

void edm::stream::ProducingModuleAdaptor< T, M, B >::doEndJob ( )

inlinefinaloverrideprivate

Definition at line 82 of file ProducingModuleAdaptor.h.

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

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

template<typename T , typename M , typename B >

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

inlinefinaloverrideprivate

Definition at line 163 of file ProducingModuleAdaptor.h.

References EnergyCorrector::c, OfflineOutput_cfi::consumer, edm::stream::CallGlobalLuminosityBlockImpl< T, bool >::endLuminosityBlock(), edm::stream::CallGlobalLuminosityBlockSummaryImpl< T, bool >::globalEndLuminosityBlock(), edm::module::AbilityBits::kLuminosityBlockCache, edm::module::AbilityBits::kLuminosityBlockSummaryCache, edm::stream::ProducingModuleAdaptor< T, M, B >::m_global, edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumis, edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumiSummaries, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runs, or, edm::stream::CallEndLuminosityBlockProduceImpl< T, bProduce, bSummary >::produce(), and edm::LuminosityBlock::setConsumer().

                                                                                {
        if(T::HasAbility::kLuminosityBlockCache or T::HasAbility::kLuminosityBlockSummaryCache or T::HasAbility::kEndLuminosityBlockProducer) {
          
          LuminosityBlock lb(lbp, this->moduleDescription(), mcc);
          lb.setConsumer(this->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());
          if(T::HasAbility::kEndLuminosityBlockProducer) {
            MyEndLuminosityBlockProduce::produce(lb,c,&lc,m_lumiSummaries[li].get());
            this->commit(lb);
          }
          MyGlobalLuminosityBlockSummary::globalEndLuminosityBlock(lb,c,&lc,m_lumiSummaries[li].get());
          MyGlobalLuminosityBlock::endLuminosityBlock(lb,c,&lc);
        }
      }

template<typename T , typename M , typename B >

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

inlinefinaloverrideprivate

Definition at line 123 of file ProducingModuleAdaptor.h.

References EnergyCorrector::c, OfflineOutput_cfi::consumer, edm::stream::CallGlobalRunImpl< T, bool >::endRun(), edm::stream::CallGlobalRunSummaryImpl< T, bool >::globalEndRun(), edm::module::AbilityBits::kEndRunProducer, edm::module::AbilityBits::kRunCache, edm::module::AbilityBits::kRunSummaryCache, edm::stream::ProducingModuleAdaptor< T, M, B >::m_global, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runs, edm::stream::ProducingModuleAdaptor< T, M, B >::m_runSummaries, or, edm::stream::CallEndRunProduceImpl< T, bProduce, bSummary >::produce(), alignCSCRings::r, and edm::Run::setConsumer().

      {
        if(T::HasAbility::kRunCache or T::HasAbility::kRunSummaryCache or T::HasAbility::kEndRunProducer) {
          
          Run r(rp, this->moduleDescription(), mcc);
          r.setConsumer(this->consumer());

          RunIndex ri = rp.index();
          typename T::RunContext rc(m_runs[ri].get(),m_global.get());
          if(T::HasAbility::kEndRunProducer) {
            MyEndRunProduce::produce(r,c,&rc,m_runSummaries[ri].get());
            this->commit(r);
          }
          MyGlobalRunSummary::globalEndRun(r,c,&rc,m_runSummaries[ri].get());
          MyGlobalRun::endRun(r,c,&rc);
        }
      }

template<typename T , typename M , typename B >

static void edm::stream::ProducingModuleAdaptor< T, M, B >::fillDescriptions ( ConfigurationDescriptions &  descriptions )

inlinestatic

Definition at line 54 of file ProducingModuleAdaptor.h.

                                                                            {
        T::fillDescriptions(descriptions);
      }

template<typename T , typename M , typename B >

const ProducingModuleAdaptor& edm::stream::ProducingModuleAdaptor< T, M, B >::operator= ( const ProducingModuleAdaptor< T, M, B > &  )

privatedelete

template<typename T , typename M , typename B >

static void edm::stream::ProducingModuleAdaptor< T, M, B >::prevalidate ( ConfigurationDescriptions &  descriptions )

inlinestatic

Definition at line 57 of file ProducingModuleAdaptor.h.

                                                                       {
        T::prevalidate(descriptions);
      }

template<typename T , typename M , typename B >

void edm::stream::ProducingModuleAdaptor< T, M, B >::setupLuminosityBlock ( M *  iProd, LuminosityBlockIndex  iIndex  )

inlinefinaloverrideprivate

Definition at line 95 of file ProducingModuleAdaptor.h.

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

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

template<typename T , typename M , typename B >

void edm::stream::ProducingModuleAdaptor< T, M, B >::setupRun ( M *  iProd, RunIndex  iIndex  )

inlinefinaloverrideprivate

Definition at line 85 of file ProducingModuleAdaptor.h.

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

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

template<typename T , typename M , typename B >

void edm::stream::ProducingModuleAdaptor< T, M, B >::setupStreamModules ( )

inlinefinaloverrideprivate

Definition at line 73 of file ProducingModuleAdaptor.h.

References edm::stream::ProducingModuleAdaptor< T, M, B >::m_global, edm::stream::ProducingModuleAdaptor< T, M, B >::m_pset, edm::stream::CallGlobalImpl< T, bool >::set(), and tmp.

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

template<typename T , typename M , typename B >

void edm::stream::ProducingModuleAdaptor< T, M, B >::streamEndLuminosityBlockSummary ( M *  iProd, edm::LuminosityBlock const &  iLumi, edm::EventSetup const &  iES  )

inlinefinaloverrideprivate

Definition at line 99 of file ProducingModuleAdaptor.h.

References edm::stream::ProducingModuleAdaptor< T, M, B >::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 , typename M , typename B >

void edm::stream::ProducingModuleAdaptor< T, M, B >::streamEndRunSummary ( M *  iProd, edm::Run const &  iRun, edm::EventSetup const &  iES  )

inlinefinaloverrideprivate

Definition at line 88 of file ProducingModuleAdaptor.h.

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

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

Member Data Documentation

template<typename T , typename M , typename B >

impl::choose_unique_ptr<typename T::GlobalCache>::type edm::stream::ProducingModuleAdaptor< T, M, B >::m_global

private

Definition at line 188 of file ProducingModuleAdaptor.h.

Referenced by edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginRun(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndJob(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndRun(), edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor(), and edm::stream::ProducingModuleAdaptor< T, M, B >::setupStreamModules().

template<typename T , typename M , typename B >

impl::choose_shared_vec<typename T::LuminosityBlockCache const>::type edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumis

private

Definition at line 190 of file ProducingModuleAdaptor.h.

Referenced by edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor(), and edm::stream::ProducingModuleAdaptor< T, M, B >::setupLuminosityBlock().

template<typename T , typename M , typename B >

impl::choose_shared_vec<typename T::LuminosityBlockSummaryCache>::type edm::stream::ProducingModuleAdaptor< T, M, B >::m_lumiSummaries

private

Definition at line 192 of file ProducingModuleAdaptor.h.

Referenced by edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor(), and edm::stream::ProducingModuleAdaptor< T, M, B >::streamEndLuminosityBlockSummary().

template<typename T , typename M , typename B >

ParameterSet const* edm::stream::ProducingModuleAdaptor< T, M, B >::m_pset

private

Definition at line 193 of file ProducingModuleAdaptor.h.

Referenced by edm::stream::ProducingModuleAdaptor< T, M, B >::setupStreamModules().

template<typename T , typename M , typename B >

impl::choose_shared_vec<typename T::RunCache const>::type edm::stream::ProducingModuleAdaptor< T, M, B >::m_runs

private

Definition at line 189 of file ProducingModuleAdaptor.h.

Referenced by edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginRun(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndLuminosityBlock(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndRun(), edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor(), and edm::stream::ProducingModuleAdaptor< T, M, B >::setupRun().

template<typename T , typename M , typename B >

impl::choose_shared_vec<typename T::RunSummaryCache>::type edm::stream::ProducingModuleAdaptor< T, M, B >::m_runSummaries

private

Definition at line 191 of file ProducingModuleAdaptor.h.

Referenced by edm::stream::ProducingModuleAdaptor< T, M, B >::doBeginRun(), edm::stream::ProducingModuleAdaptor< T, M, B >::doEndRun(), edm::stream::ProducingModuleAdaptor< T, M, B >::ProducingModuleAdaptor(), and edm::stream::ProducingModuleAdaptor< T, M, B >::streamEndRunSummary().