#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, ProductResolverCollection::const_iterator >	const_iterator

typedef ProductResolverBase const *	ConstProductResolverPtr

typedef boost::filter_iterator< FilledProductPtr, ProductResolverCollection::iterator >	iterator

typedef std::string	ProcessName

typedef ProcessHistory::const_iterator	ProcessNameConstIterator

typedef std::vector< propagate_const< std::shared_ptr< ProductResolverBase > > >	ProductResolverCollection

typedef std::shared_ptr< ProductResolverBase >	SharedProductPtr

typedef ProductResolverCollection::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

MergeableRunProductMetadata *	mergeableRunProductMetadata ()

void	mergeAuxiliary (RunAuxiliary const &aux)

void	preReadFile ()

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

void	put (ProductResolverIndex index, std::unique_ptr< WrapperBase > edp) 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, bool isForPrimaryProcess=true, MergeableRunProductProcesses const mergeableRunProductProcesses=0)

void	setEndTime (Timestamp const &time)

	~RunPrincipal () override

Public Member Functions inherited from edm::Principal
void	adjustIndexesAfterProductRegistryAddition ()

bool	adjustToNewProductRegistry (ProductRegistry const &reg)

const_iterator	begin () const

iterator	begin ()

BranchType const &	branchType () const

CacheIdentifier_t	cacheIdentifier () const

void	clearPrincipal ()

void	deleteProduct (BranchID const &id) const

const_iterator	end () const

iterator	end ()

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

void	getAllStableProvenance (std::vector< StableProvenance 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, ProductResolverIndex index, bool skipCurrentProcess, bool &ambiguous, SharedResourcesAcquirer sra, ModuleCallingContext const mcc) const

void	getManyByType (TypeID const &typeID, BasicHandleVec &results, EDConsumerBase const consumes, SharedResourcesAcquirer sra, ModuleCallingContext const *mcc) const

ProductResolverBase *	getModifiableProductResolver (BranchID const &oid)

ConstProductResolverPtr	getProductResolver (BranchID const &oid) const

ConstProductResolverPtr	getProductResolverByIndex (ProductResolverIndex const &oid) const

Provenance	getProvenance (BranchID const &bid, ModuleCallingContext const *mcc) const

std::vector< unsigned int > const &	lookupProcessOrder () const

void	prefetchAsync (WaitingTask waitTask, ProductResolverIndex index, bool skipCurrentProcess, ServiceToken const &token, ModuleCallingContext const mcc) const

	Principal (std::shared_ptr< ProductRegistry const > reg, std::shared_ptr< ProductResolverIndexHelper const > productLookup, ProcessConfiguration const &pc, BranchType bt, HistoryAppender *historyAppender, bool isForPrimaryProcess=true)

ProcessConfiguration const &	processConfiguration () const

ProcessHistory const &	processHistory () const

ProcessHistoryID const &	processHistoryID () const

EDProductGetter const *	prodGetter () const

ProductResolverIndexHelper const &	productLookup () const

ProductRegistry const &	productRegistry () const

void	readAllFromSourceAndMergeImmediately (MergeableRunProductMetadata const *mergeableRunProductMetadata=0)

DelayedReader *	reader () const

void	recombine (Principal &other, std::vector< BranchID > const &bids)

void	setupUnscheduled (UnscheduledConfigurator const &)

size_t	size () const

	~Principal () override

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
unsigned int	transitionIndex_ () const override

Private Attributes
edm::propagate_const< std::shared_ptr< RunAuxiliary > >	aux_

RunIndex	index_

ProcessHistoryID	m_reducedHistoryID

edm::propagate_const< std::unique_ptr< MergeableRunProductMetadata > >	mergeableRunProductMetadataPtr_

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::unique_ptr< ProductResolverBase > phb)

void	addProductOrThrow (std::unique_ptr< ProductResolverBase > phb)

template<typename F >
void	applyToResolvers (F iFunc)

ProductResolverBase *	getExistingProduct (BranchID const &branchID)

ProductResolverBase const *	getExistingProduct (BranchID const &branchID) const

ProductResolverBase const *	getExistingProduct (ProductResolverBase const &phb) const

void	putOrMerge (BranchDescription const &bd, std::unique_ptr< WrapperBase > edp) const

Detailed Description

Definition at line 33 of file RunPrincipal.h.

Member Typedef Documentation

typedef RunAuxiliary edm::RunPrincipal::Auxiliary

Definition at line 35 of file RunPrincipal.h.

typedef Principal edm::RunPrincipal::Base

Definition at line 36 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,
		bool	isForPrimaryProcess = `true`,
		MergeableRunProductProcesses const *	mergeableRunProductProcesses = `0`
	)

Definition at line 9 of file RunPrincipal.cc.

References mergeableRunProductMetadataPtr_.

       : Base(reg, reg->productLookup(InRun), pc, InRun, historyAppender, isForPrimaryProcess),
         aux_(aux),
         index_(iRunIndex) {
     if (mergeableRunProductProcesses) {  // primary RunPrincipals of EventProcessor
       mergeableRunProductMetadataPtr_ = (std::make_unique<MergeableRunProductMetadata>(*mergeableRunProductProcesses));
     }
   }

edm::RunPrincipal::~RunPrincipal ( )

override

Definition at line 24 of file RunPrincipal.cc.

24 {}

Member Function Documentation

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

inline

Definition at line 58 of file RunPrincipal.h.

References aux_.

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

58 { return *aux_; }

edm::RunPrincipal::aux_

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

Definition: RunPrincipal.h:85

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

inline

Definition at line 66 of file RunPrincipal.h.

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

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

66 { return aux().beginTime(); }

edm::RunAuxiliary::beginTime

Timestamp const & beginTime() const

Definition: RunAuxiliary.h:39

edm::RunPrincipal::aux

RunAuxiliary const & aux() const

Definition: RunPrincipal.h:58

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

inline

Definition at line 68 of file RunPrincipal.h.

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

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

68 { return aux().endTime(); }

edm::RunAuxiliary::endTime

Timestamp const & endTime() const

Definition: RunAuxiliary.h:40

edm::RunPrincipal::aux

RunAuxiliary const & aux() const

Definition: RunPrincipal.h:58

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

Definition at line 26 of file RunPrincipal.cc.

References aux_, edm::Principal::fillPrincipal(), m_reducedHistoryID, mergeableRunProductMetadataPtr_, 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_().

                                                                                                                  {
     m_reducedHistoryID = processHistoryRegistry.reducedProcessHistoryID(aux_->processHistoryID());
     fillPrincipal(aux_->processHistoryID(), processHistoryRegistry, reader);
 
     for (auto& prod : *this) {
       prod->setProcessHistory(processHistory());
       prod->setMergeableRunProductMetadata(mergeableRunProductMetadataPtr_.get());
     }
   }

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

inline

Definition at line 64 of file RunPrincipal.h.

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

Referenced by DQMRootSource::readRun_().

64 { return aux().id(); }

edm::RunAuxiliary::id

RunID const & id() const

Definition: RunAuxiliary.h:37

edm::RunPrincipal::aux

RunAuxiliary const & aux() const

Definition: RunPrincipal.h:58

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 56 of file RunPrincipal.h.

References index_.

56 { return index_; }

edm::RunPrincipal::index_

RunIndex index_

Definition: RunPrincipal.h:87

MergeableRunProductMetadata* edm::RunPrincipal::mergeableRunProductMetadata ( )

inline

Definition at line 78 of file RunPrincipal.h.

References mergeableRunProductMetadataPtr_, preReadFile(), and transitionIndex_().

Referenced by edm::EventProcessor::endUnfinishedRun(), edm::RootFile::readRun_(), and edm::EventProcessor::writeLumiAsync().

78 { return mergeableRunProductMetadataPtr_.get(); }

edm::RunPrincipal::mergeableRunProductMetadataPtr_

edm::propagate_const< std::unique_ptr< MergeableRunProductMetadata > > mergeableRunProductMetadataPtr_

Definition: RunPrincipal.h:92

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

inline

Definition at line 72 of file RunPrincipal.h.

References aux_, index(), and put().

72 { return aux_->mergeAuxiliary(aux); }

edm::RunPrincipal::aux_

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

Definition: RunPrincipal.h:85

edm::RunPrincipal::aux

RunAuxiliary const & aux() const

Definition: RunPrincipal.h:58

void edm::RunPrincipal::preReadFile ( )

Definition at line 47 of file RunPrincipal.cc.

References mergeableRunProductMetadataPtr_.

Referenced by mergeableRunProductMetadata().

                                  {
     if (mergeableRunProductMetadataPtr_) {
       mergeableRunProductMetadataPtr_->preReadFile();
     }
   }

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

Definition at line 36 of file RunPrincipal.cc.

References eostools::move(), and edm::Principal::putOrMerge().

Referenced by edm::Run::commit_(), mergeAuxiliary(), and LHESource::putRunInfoProduct().

                                                                                           {
     putOrMerge(bd, std::move(edp));
   }

void edm::RunPrincipal::put	(	ProductResolverIndex	index,
		std::unique_ptr< WrapperBase >	edp
	)		const

Definition at line 40 of file RunPrincipal.cc.

References edm::Principal::getProductResolverByIndex(), and eostools::move().

                                                                                          {
     auto phb = getProductResolverByIndex(index);
     phb->putOrMergeProduct(std::move(edp));
   }