edm::stream::EDAnalyzerAdaptorBase Class Reference

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

Inheritance diagram for edm::stream::EDAnalyzerAdaptorBase:

Public Member Functions
	EDAnalyzerAdaptorBase ()
const ModuleDescription &	moduleDescription ()
void	registerProductsAndCallbacks (EDAnalyzerAdaptorBase const *, ProductRegistry *reg)
std::string	workerType () const
virtual	~EDAnalyzerAdaptorBase ()

Protected Member Functions
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 &)

Private Member Functions
void	doBeginJob ()
virtual void	doBeginLuminosityBlock (LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *)=0
virtual void	doBeginRun (RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *)=0
void	doBeginStream (StreamID id)
virtual void	doEndJob ()=0
virtual void	doEndLuminosityBlock (LuminosityBlockPrincipal &lbp, EventSetup const &c, ModuleCallingContext const *)=0
virtual void	doEndRun (RunPrincipal &rp, EventSetup const &c, ModuleCallingContext const *)=0
void	doEndStream (StreamID id)
bool	doEvent (EventPrincipal &ep, EventSetup const &c, ActivityRegistry *, ModuleCallingContext const *)
void	doPostForkReacquireResources (unsigned int iChildIndex, unsigned int iNumberOfChildren)
void	doPreallocate (PreallocationConfiguration const &)
void	doPreForkReleaseResources ()
void	doRegisterThinnedAssociations (ProductRegistry const &, ThinnedAssociationsHelper &)
void	doRespondToCloseInputFile (FileBlock const &fb)
void	doRespondToOpenInputFile (FileBlock const &fb)
void	doStreamBeginLuminosityBlock (StreamID id, LuminosityBlockPrincipal &ep, EventSetup const &c, ModuleCallingContext const *)
void	doStreamBeginRun (StreamID id, RunPrincipal &ep, EventSetup const &c, ModuleCallingContext const *)
void	doStreamEndLuminosityBlock (StreamID id, LuminosityBlockPrincipal &ep, EventSetup const &c, ModuleCallingContext const *)
void	doStreamEndRun (StreamID id, RunPrincipal &ep, EventSetup const &c, ModuleCallingContext const *)
	EDAnalyzerAdaptorBase (const EDAnalyzerAdaptorBase &)
const EDAnalyzerAdaptorBase &	operator= (const EDAnalyzerAdaptorBase &)
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 57 of file EDAnalyzerAdaptorBase.h.

Constructor & Destructor Documentation

EDAnalyzerAdaptorBase::EDAnalyzerAdaptorBase

(

)

Definition at line 41 of file EDAnalyzerAdaptorBase.cc.

{
}

EDAnalyzerAdaptorBase::~EDAnalyzerAdaptorBase ( )

virtual

Definition at line 50 of file EDAnalyzerAdaptorBase.cc.

References visualization-live-secondInstance_cfg::m, and m_streamModules.

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

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

private

Member Function Documentation

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

protected

Definition at line 112 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

Referenced by edm::stream::EDAnalyzerAdaptor< T >::doBeginLuminosityBlock(), edm::stream::EDAnalyzerAdaptor< T >::doBeginRun(), edm::stream::EDAnalyzerAdaptor< T >::doEndLuminosityBlock(), and edm::stream::EDAnalyzerAdaptor< T >::doEndRun().

                                      {
  return m_streamModules[0];
}

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

protected

Definition at line 133 of file EDAnalyzerAdaptorBase.cc.

References assert(), and m_streamModules.

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

template<typename T >

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

inlineprotected

Definition at line 78 of file EDAnalyzerAdaptorBase.h.

References visualization-live-secondInstance_cfg::m, m_streamModules, and setModuleDescriptionPtr().

Referenced by edm::stream::EDAnalyzerAdaptor< T >::setupStreamModules().

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

void EDAnalyzerAdaptorBase::doBeginJob ( )

private

Definition at line 151 of file EDAnalyzerAdaptorBase.cc.

                                  {
  
}

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

privatepure virtual

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

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

privatepure virtual

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

void EDAnalyzerAdaptorBase::doBeginStream ( StreamID  id )

private

Definition at line 156 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

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

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

privatepure virtual

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

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

privatepure virtual

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

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

privatepure virtual

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

void EDAnalyzerAdaptorBase::doEndStream ( StreamID  id )

private

Definition at line 160 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules.

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

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

private

Definition at line 139 of file EDAnalyzerAdaptorBase.cc.

References assert(), alignCSCRings::e, 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);
  EventSignalsSentry sentry(act,mcc);
  mod->analyze(e, c);
  return true;
}

void EDAnalyzerAdaptorBase::doPostForkReacquireResources ( unsigned int  iChildIndex, unsigned int  iNumberOfChildren  )

private

Definition at line 230 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

{
  for(auto mod: m_streamModules) {
    mod->postForkReacquireResources(iChildIndex,iNumberOfChildren);
  }
}

void EDAnalyzerAdaptorBase::doPreallocate ( PreallocationConfiguration const &  iPrealloc )

private

Definition at line 73 of file EDAnalyzerAdaptorBase.cc.

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

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

void EDAnalyzerAdaptorBase::doPreForkReleaseResources ( )

private

Definition at line 223 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

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

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

inlineprivate

Definition at line 158 of file EDAnalyzerAdaptorBase.h.

                                                                     { }

void EDAnalyzerAdaptorBase::doRespondToCloseInputFile ( FileBlock const &  fb )

private

Definition at line 221 of file EDAnalyzerAdaptorBase.cc.

{}

void EDAnalyzerAdaptorBase::doRespondToOpenInputFile ( FileBlock const &  fb )

private

Definition at line 219 of file EDAnalyzerAdaptorBase.cc.

{}

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

private

Definition at line 193 of file EDAnalyzerAdaptorBase.cc.

References edm::LuminosityBlockPrincipal::index(), m_streamModules, mod(), moduleDescription_, and setupLuminosityBlock().

                                                                                     {
  auto mod = m_streamModules[id];
  setupLuminosityBlock(mod,lbp.index());
  
  LuminosityBlock lb(lbp, moduleDescription_, mcc);
  lb.setConsumer(mod);
  mod->beginLuminosityBlock(lb, c);
}

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

private

Definition at line 165 of file EDAnalyzerAdaptorBase.cc.

References 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);
  r.setConsumer(mod);
  mod->beginRun(r, c);

}

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

private

Definition at line 205 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, mod(), moduleDescription_, edm::LuminosityBlock::setConsumer(), and streamEndLuminosityBlockSummary().

{
  auto mod = m_streamModules[id];
  LuminosityBlock lb(lbp, moduleDescription_, mcc);
  lb.setConsumer(mod);
  mod->endLuminosityBlock(lb, c);
  streamEndLuminosityBlockSummary(mod,lb, c);

}

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

private

Definition at line 180 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, mod(), moduleDescription_, alignCSCRings::r, edm::Run::setConsumer(), and streamEndRunSummary().

{
  auto mod = m_streamModules[id];
  Run r(rp, moduleDescription_, mcc);
  r.setConsumer(mod);
  mod->endRun(r, c);
  streamEndRunSummary(mod,r,c);
}

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

protected

Definition at line 92 of file EDAnalyzerAdaptorBase.cc.

References assert(), and m_streamModules.

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

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

protected

Definition at line 87 of file EDAnalyzerAdaptorBase.cc.

References assert(), and m_streamModules.

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

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

protected

Definition at line 98 of file EDAnalyzerAdaptorBase.cc.

References assert(), and m_streamModules.

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

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

inline

Definition at line 72 of file EDAnalyzerAdaptorBase.h.

References moduleDescription_.

Referenced by edm::stream::EDAnalyzerAdaptor< T >::doBeginLuminosityBlock(), edm::stream::EDAnalyzerAdaptor< T >::doBeginRun(), edm::stream::EDAnalyzerAdaptor< T >::doEndLuminosityBlock(), and edm::stream::EDAnalyzerAdaptor< T >::doEndRun().

{ return moduleDescription_;}

void EDAnalyzerAdaptorBase::modulesDependentUpon ( const std::string &  iProcessName, std::vector< const char * > &  oModuleLabels  ) const

protected

Definition at line 117 of file EDAnalyzerAdaptorBase.cc.

References assert(), and m_streamModules.

                                                                                         {
  assert(not m_streamModules.empty());
  return m_streamModules[0]->modulesDependentUpon(iProcessName, oModuleLabels);
}

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 124 of file EDAnalyzerAdaptorBase.cc.

References assert(), and m_streamModules.

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

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

private

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

Definition at line 80 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 163 of file EDAnalyzerAdaptorBase.h.

References popcon2dropbox_job_conf::md, and moduleDescription_.

                                                             {
        moduleDescription_ = md;
      }

void EDAnalyzerAdaptorBase::setModuleDescriptionPtr ( EDAnalyzerBase *  m )

private

Definition at line 238 of file EDAnalyzerAdaptorBase.cc.

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

Referenced by createStreamModules().

                                                                {
  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, ProductHolderIndexHelper const &  iHelper  )

protected

Definition at line 104 of file EDAnalyzerAdaptorBase.cc.

References m_streamModules, and mod().

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

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

inline

Definition at line 74 of file EDAnalyzerAdaptorBase.h.

{ return "WorkerT<EDAnalyzerAdaptorBase>";}

Friends And Related Function Documentation

template<typename T >

friend class edm::maker::ModuleHolderT

friend

Definition at line 62 of file EDAnalyzerAdaptorBase.h.

template<typename T >

friend class edm::WorkerT

friend

Definition at line 61 of file EDAnalyzerAdaptorBase.h.

Member Data Documentation

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

private

Definition at line 168 of file EDAnalyzerAdaptorBase.h.

Referenced by consumer(), consumesInfo(), createStreamModules(), doBeginStream(), doEndStream(), doEvent(), doPostForkReacquireResources(), doPreallocate(), doPreForkReleaseResources(), doStreamBeginLuminosityBlock(), doStreamBeginRun(), doStreamEndLuminosityBlock(), doStreamEndRun(), itemsMayGet(), itemsToGet(), itemsToGetFromEvent(), modulesDependentUpon(), modulesWhoseProductsAreConsumed(), registerProductsAndCallbacks(), updateLookup(), and ~EDAnalyzerAdaptorBase().

ModuleDescription edm::stream::EDAnalyzerAdaptorBase::moduleDescription_

private

Definition at line 166 of file EDAnalyzerAdaptorBase.h.

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