edm::RunPrincipal Class Reference

#include <RunPrincipal.h>

Inheritance diagram for edm::RunPrincipal:

Public Types
typedef RunAuxiliary	Auxiliary
typedef Principal	Base
Public Types inherited from edm::Principal
typedef std::vector< BasicHandle >	BasicHandleVec
typedef unsigned long	CacheIdentifier_t
typedef boost::filter_iterator < FilledProductPtr, ProductHolderCollection::const_iterator >	const_iterator
typedef ProductHolderBase const *	ConstProductHolderPtr
typedef std::string	ProcessName
typedef ProcessHistory::const_iterator	ProcessNameConstIterator
typedef std::vector < std::shared_ptr < ProductHolderBase > >	ProductHolderCollection
typedef std::shared_ptr < ProductHolderBase >	SharedProductPtr
typedef ProductHolderCollection::size_type	size_type

Public Member Functions
RunAuxiliary const &	aux () const
Timestamp const &	beginTime () const
Timestamp const &	endTime () const
void	fillRunPrincipal (ProcessHistoryRegistry const &processHistoryRegistry, DelayedReader *reader=0)
RunID const &	id () const
RunIndex	index () const
void	mergeAuxiliary (RunAuxiliary const &aux)
void	put (BranchDescription const &bd, std::unique_ptr< WrapperBase > edp)
void	readImmediate () const
ProcessHistoryID const &	reducedProcessHistoryID () const
RunNumber_t	run () const
	RunPrincipal (std::shared_ptr< RunAuxiliary > aux, std::shared_ptr< ProductRegistry const > reg, ProcessConfiguration const &pc, HistoryAppender *historyAppender, unsigned int iRunIndex)
void	setComplete ()
void	setEndTime (Timestamp const &time)
void	setUnscheduledHandler (std::shared_ptr< UnscheduledHandler >)
	~RunPrincipal ()
Public Member Functions inherited from edm::Principal
void	addAliasedProduct (std::shared_ptr< BranchDescription const > bd)
void	addInputProduct (std::shared_ptr< BranchDescription const > bd)
void	addScheduledProduct (std::shared_ptr< BranchDescription const > bd)
void	addSourceProduct (std::shared_ptr< BranchDescription const > bd)
void	addUnscheduledProduct (std::shared_ptr< BranchDescription const > bd)
void	adjustIndexesAfterProductRegistryAddition ()
bool	adjustToNewProductRegistry (ProductRegistry const &reg)
const_iterator	begin () const
BranchType const &	branchType () const
CacheIdentifier_t	cacheIdentifier () const
void	clearPrincipal ()
void	deleteProduct (BranchID const &id)
const_iterator	end () const
void	fillPrincipal (ProcessHistoryID const &hist, ProcessHistoryRegistry const &phr, DelayedReader *reader)
ProductData const *	findProductByTag (TypeID const &typeID, InputTag const &tag, ModuleCallingContext const *mcc) const
void	getAllProvenance (std::vector< Provenance const * > &provenances) const
BasicHandle	getByLabel (KindOfType kindOfType, TypeID const &typeID, InputTag const &inputTag, EDConsumerBase const *consumes, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
BasicHandle	getByLabel (KindOfType kindOfType, TypeID const &typeID, std::string const &label, std::string const &instance, std::string const &process, EDConsumerBase const *consumes, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
BasicHandle	getByToken (KindOfType kindOfType, TypeID const &typeID, ProductHolderIndex index, bool skipCurrentProcess, bool &ambiguous, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
OutputHandle	getForOutput (BranchID const &bid, bool getProd, ModuleCallingContext const *mcc) const
void	getManyByType (TypeID const &typeID, BasicHandleVec &results, EDConsumerBase const *consumes, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
ConstProductHolderPtr	getProductHolder (BranchID const &oid) const
ConstProductHolderPtr	getProductHolderByIndex (ProductHolderIndex const &oid) const
Provenance	getProvenance (BranchID const &bid, ModuleCallingContext const *mcc) const
bool	isComplete () const
std::vector< unsigned int > const &	lookupProcessOrder () const
void	prefetch (ProductHolderIndex index, bool skipCurrentProcess, ModuleCallingContext const *mcc) const
	Principal (std::shared_ptr< ProductRegistry const > reg, std::shared_ptr< ProductHolderIndexHelper const > productLookup, ProcessConfiguration const &pc, BranchType bt, HistoryAppender *historyAppender)
ProcessConfiguration const &	processConfiguration () const
ProcessHistory const &	processHistory () const
ProcessHistoryID const &	processHistoryID () const
EDProductGetter const *	prodGetter () const
ProductHolderIndexHelper const &	productLookup () const
ProductRegistry const &	productRegistry () const
DelayedReader *	reader () const
void	readFromSource (ProductHolderBase const &phb, ModuleCallingContext const *mcc) const
void	recombine (Principal &other, std::vector< BranchID > const &bids)
size_t	size () const
virtual	~Principal ()
Public Member Functions inherited from edm::EDProductGetter
	EDProductGetter ()
	EDProductGetter (EDProductGetter const &)=delete
EDProductGetter const &	operator= (EDProductGetter const &)=delete
unsigned int	transitionIndex () const
virtual	~EDProductGetter ()

Private Member Functions
virtual bool	isComplete_ () const override
void	resolveProductImmediate (ProductHolderBase const &phb) const
virtual unsigned int	transitionIndex_ () const override
virtual bool	unscheduledFill (std::string const &, SharedResourcesAcquirer *sra, ModuleCallingContext const *) const override

Private Attributes
std::shared_ptr< RunAuxiliary >	aux_
bool	complete_
RunIndex	index_
ProcessHistoryID	m_reducedHistoryID

Additional Inherited Members
Static Public Member Functions inherited from edm::EDProductGetter
static void	assignEDProductGetter (EDProductGetter const *&)
static EDProductGetter const *	switchProductGetter (EDProductGetter const *)
	These can only be used internally by the framework. More...
Protected Member Functions inherited from edm::Principal
void	addProduct_ (std::auto_ptr< ProductHolderBase > phb)
void	addProductOrThrow (std::auto_ptr< ProductHolderBase > phb)
void	checkUniquenessAndType (WrapperBase const *prod, ProductHolderBase const *productHolder) const
ProductHolderBase *	getExistingProduct (BranchID const &branchID)
ProductHolderBase *	getExistingProduct (ProductHolderBase const &phb)
void	putOrMerge (std::unique_ptr< WrapperBase > prod, ProductHolderBase const *productHolder) const
void	putOrMerge (std::unique_ptr< WrapperBase > prod, ProductProvenance &prov, ProductHolderBase *productHolder)

Detailed Description

Definition at line 31 of file RunPrincipal.h.

Member Typedef Documentation

typedef RunAuxiliary edm::RunPrincipal::Auxiliary

Definition at line 33 of file RunPrincipal.h.

typedef Principal edm::RunPrincipal::Base

Definition at line 34 of file RunPrincipal.h.

Constructor & Destructor Documentation

edm::RunPrincipal::RunPrincipal	(	std::shared_ptr< RunAuxiliary >	aux,
		std::shared_ptr< ProductRegistry const >	reg,
		ProcessConfiguration const &	pc,
		HistoryAppender *	historyAppender,
		unsigned int	iRunIndex
	)

Definition at line 10 of file RunPrincipal.cc.

                            :
    Base(reg, reg->productLookup(InRun), pc, InRun, historyAppender),
      aux_(aux), index_(iRunIndex), complete_(false) {
  }

edm::RunPrincipal::~RunPrincipal ( )

inline

Definition at line 42 of file RunPrincipal.h.

{}

Member Function Documentation

RunAuxiliary const& edm::RunPrincipal::aux ( ) const

inline

Definition at line 57 of file RunPrincipal.h.

References aux_.

Referenced by edm::SubProcess::beginRun(), beginTime(), endTime(), id(), edm::PoolSource::readRun_(), run(), and edm::RootOutputFile::writeRun().

                                    {
      return *aux_;
    }

Timestamp const& edm::RunPrincipal::beginTime ( ) const

inline

Definition at line 73 of file RunPrincipal.h.

References aux(), and edm::RunAuxiliary::beginTime().

Referenced by edm::EventProcessor::beginRun(), edm::EDLooperBase::doBeginRun(), edm::OccurrenceTraits< RunPrincipal, BranchActionGlobalBegin >::makeGlobalContext(), edm::OccurrenceTraits< RunPrincipal, BranchActionStreamBegin >::setStreamContext(), and DQMRootOutputModule::writeRun().

                                       {
      return aux().beginTime();
    }

Timestamp const& edm::RunPrincipal::endTime ( ) const

inline

Definition at line 77 of file RunPrincipal.h.

References aux(), and edm::RunAuxiliary::endTime().

Referenced by edm::EDLooperBase::doEndRun(), edm::EventProcessor::endRun(), edm::OccurrenceTraits< RunPrincipal, BranchActionGlobalEnd >::makeGlobalContext(), edm::OccurrenceTraits< RunPrincipal, BranchActionStreamEnd >::setStreamContext(), edm::OutputModuleCommunicatorT< T >::writeRun(), and DQMRootOutputModule::writeRun().

                                     {
      return aux().endTime();
    }

void edm::RunPrincipal::fillRunPrincipal	(	ProcessHistoryRegistry const &	processHistoryRegistry,
		DelayedReader *	reader = 0
	)

Definition at line 21 of file RunPrincipal.cc.

References aux_, complete_, edm::Principal::fillPrincipal(), m_reducedHistoryID, edm::Principal::processHistory(), parseEventContent::prod, edm::Principal::reader(), and edm::ProcessHistoryRegistry::reducedProcessHistoryID().

Referenced by dqmservices::DQMProtobufReader::readRun_(), LHESource::readRun_(), edm::RootFile::readRun_(), DQMRootSource::readRun_(), and edm::InputSource::readRun_().

                                                                                                            {
    complete_ = false;

    m_reducedHistoryID = processHistoryRegistry.reducedProcessHistoryID(aux_->processHistoryID());
    fillPrincipal(aux_->processHistoryID(), processHistoryRegistry, reader);

    for(auto const& prod : *this) {
      prod->setProcessHistory(processHistory());
    }
  }

RunID const& edm::RunPrincipal::id ( void  ) const

inline

Definition at line 69 of file RunPrincipal.h.

References aux(), and edm::RunAuxiliary::id().

Referenced by DQMRootSource::readRun_(), edm::GetProductCheckerOutputModule::writeRun(), and DQMRootOutputModule::writeRun().

                            {
      return aux().id();
    }

RunIndex edm::RunPrincipal::index ( ) const

inline

Multiple Runs may be processed simultaneously. The return value can be used to identify a particular Run. The value will range from 0 to one less than the maximum number of allowed simultaneous Runs. A particular value will be reused once the processing of the previous Run using that index has been completed.

Definition at line 53 of file RunPrincipal.h.

References index_.

Referenced by BeautifulSoup.PageElement::_invert(), edm::SubProcess::beginRun(), edm::EDLooperBase::doBeginLuminosityBlock(), edm::EDLooperBase::doBeginRun(), edm::EDLooperBase::doDuringLoop(), edm::EDLooperBase::doEndLuminosityBlock(), edm::EDLooperBase::doEndRun(), edm::stream::EDAnalyzerAdaptorBase::doStreamBeginRun(), edm::stream::ProducingModuleAdaptorBase< T >::doStreamBeginRun(), edm::Run::index(), edm::OccurrenceTraits< RunPrincipal, BranchActionGlobalBegin >::makeGlobalContext(), edm::OccurrenceTraits< RunPrincipal, BranchActionGlobalEnd >::makeGlobalContext(), edm::OccurrenceTraits< LuminosityBlockPrincipal, BranchActionGlobalBegin >::makeGlobalContext(), edm::OccurrenceTraits< LuminosityBlockPrincipal, BranchActionGlobalEnd >::makeGlobalContext(), edm::PoolSource::readRun_(), edm::OccurrenceTraits< RunPrincipal, BranchActionStreamBegin >::setStreamContext(), edm::OccurrenceTraits< RunPrincipal, BranchActionStreamEnd >::setStreamContext(), edm::OccurrenceTraits< LuminosityBlockPrincipal, BranchActionStreamBegin >::setStreamContext(), edm::OccurrenceTraits< LuminosityBlockPrincipal, BranchActionStreamEnd >::setStreamContext(), transitionIndex_(), edm::OutputModuleCommunicatorT< T >::writeLumi(), and edm::OutputModuleCommunicatorT< T >::writeRun().

                           {
      return index_;
    }

virtual bool edm::RunPrincipal::isComplete_ ( ) const

inlineoverrideprivatevirtual

Reimplemented from edm::Principal.

Definition at line 103 of file RunPrincipal.h.

References complete_.

{return complete_;}

void edm::RunPrincipal::mergeAuxiliary ( RunAuxiliary const &  aux )

inline

Definition at line 85 of file RunPrincipal.h.

References aux_.

                                                 {
      return aux_->mergeAuxiliary(aux);
    }

void edm::RunPrincipal::put	(	BranchDescription const &	bd,
		std::unique_ptr< WrapperBase >	edp
	)

Definition at line 33 of file RunPrincipal.cc.

References assert(), edm::BranchDescription::branchID(), Exception, edm::Principal::getExistingProduct(), edm::errors::InsertFailure, and edm::Principal::putOrMerge().

Referenced by LHESource::beginRun(), edm::Run::commit_(), and LHESource::endRun().

                                         {

    // Assert commented out for LHESource.
    // assert(bd.produced());
    if(edp.get() == nullptr) {
      throw edm::Exception(edm::errors::InsertFailure,"Null Pointer")
        << "put: Cannot put because unique_ptr to product is null."
        << "\n";
    }
    ProductHolderBase* phb = getExistingProduct(bd.branchID());
    assert(phb);
    // ProductHolder assumes ownership
    putOrMerge(std::move(edp), phb);
  }

void edm::RunPrincipal::readImmediate

(

)

const

Definition at line 51 of file RunPrincipal.cc.

References edm::ProductHolderBase::branchDescription(), parseEventContent::prod, edm::BranchDescription::produced(), edm::ProductHolderBase::productUnavailable(), resolveProductImmediate(), and edm::ProductHolderBase::singleProduct().

Referenced by edm::RootFile::readRun_().

                                    {
    for(auto const& prod : *this) {
      ProductHolderBase const& phb = *prod;
      if(phb.singleProduct() && !phb.branchDescription().produced()) {
        if(!phb.productUnavailable()) {
          resolveProductImmediate(phb);
        }
      }
    }
  }

ProcessHistoryID const& edm::RunPrincipal::reducedProcessHistoryID ( ) const

inline

Definition at line 65 of file RunPrincipal.h.

References m_reducedHistoryID.

Referenced by edm::SubProcess::beginRun().

                                                            {
      return m_reducedHistoryID;
    }

void edm::RunPrincipal::resolveProductImmediate ( ProductHolderBase const &  phb ) const

private

Definition at line 63 of file RunPrincipal.cc.

References edm::ProductHolderBase::branchDescription(), edm::getProduct(), edm::BranchDescription::produced(), edm::Principal::putOrMerge(), and edm::Principal::reader().

Referenced by readImmediate().

                                                                          {
    if(phb.branchDescription().produced()) return; // nothing to do.
    if(!reader()) return; // nothing to do.

    // must attempt to load from persistent store
    BranchKey const bk = BranchKey(phb.branchDescription());
    std::unique_ptr<WrapperBase> edp(reader()->getProduct(bk, this));

    // Now fix up the ProductHolder
    if(edp.get() != nullptr) {
      putOrMerge(std::move(edp), &phb);
    }
  }

RunNumber_t edm::RunPrincipal::run ( void  ) const

inline

Definition at line 61 of file RunPrincipal.h.

References aux(), and edm::RunAuxiliary::run().

Referenced by edm::EventProcessor::beginRun(), Types.EventID::cppID(), Types.LuminosityBlockID::cppID(), edm::EDLooperBase::doBeginRun(), edm::EDLooperBase::doEndRun(), edm::EventProcessor::endRun(), edm::OccurrenceTraits< RunPrincipal, BranchActionGlobalBegin >::makeGlobalContext(), edm::OccurrenceTraits< RunPrincipal, BranchActionGlobalEnd >::makeGlobalContext(), edm::PoolSource::readRun_(), edm::OccurrenceTraits< RunPrincipal, BranchActionStreamBegin >::setStreamContext(), edm::OccurrenceTraits< RunPrincipal, BranchActionStreamEnd >::setStreamContext(), edm::OutputModuleCommunicatorT< T >::writeRun(), and edm::RootOutputFile::writeRun().

                            {
      return aux().run();
    }

void edm::RunPrincipal::setComplete ( )

inline

Definition at line 97 of file RunPrincipal.h.

References complete_.

Referenced by edm::InputSource::doEndRun().

                       {
      complete_ = true;
    }

void edm::RunPrincipal::setEndTime ( Timestamp const &  time )

inline

Definition at line 81 of file RunPrincipal.h.

References aux_.

Referenced by edm::InputSource::doEndRun().

                                           {
      aux_->setEndTime(time);
    }

void edm::RunPrincipal::setUnscheduledHandler ( std::shared_ptr< UnscheduledHandler >  )

inline

Definition at line 89 of file RunPrincipal.h.

{}

unsigned int edm::RunPrincipal::transitionIndex_ ( ) const

overrideprivatevirtual

Implements edm::EDProductGetter.

Definition at line 78 of file RunPrincipal.cc.

References index(), and edm::RunIndex::value().

                                       {
    return index().value();
  }

virtual bool edm::RunPrincipal::unscheduledFill ( std::string const &  , SharedResourcesAcquirer *  sra, ModuleCallingContext const *    ) const

inlineoverrideprivatevirtual

Implements edm::Principal.

Definition at line 105 of file RunPrincipal.h.

                                                                             {return false;}

Member Data Documentation

std::shared_ptr<RunAuxiliary> edm::RunPrincipal::aux_

private

Definition at line 113 of file RunPrincipal.h.

Referenced by aux(), fillRunPrincipal(), mergeAuxiliary(), and setEndTime().

bool edm::RunPrincipal::complete_

private

Definition at line 117 of file RunPrincipal.h.

Referenced by fillRunPrincipal(), isComplete_(), and setComplete().

RunIndex edm::RunPrincipal::index_

private

Definition at line 115 of file RunPrincipal.h.

Referenced by index().

ProcessHistoryID edm::RunPrincipal::m_reducedHistoryID

private

Definition at line 114 of file RunPrincipal.h.

Referenced by fillRunPrincipal(), and reducedProcessHistoryID().