Inheritance diagram for edm::ReducedProvenanceReader:

Public Member Functions
std::set< ProductProvenance >	readProvenance (unsigned int) const override

	ReducedProvenanceReader (RootTree iRootTree, std::vector< ParentageID > const &iParentageIDLookup, DaqProvenanceHelper const daqProvenanceHelper)

Public Member Functions inherited from edm::ProvenanceReaderBase
	ProvenanceReaderBase ()

virtual	~ProvenanceReaderBase ()

Private Member Functions
void	readProvenanceAsync (WaitingTaskHolder task, ModuleCallingContext const moduleCallingContext, unsigned int transitionIndex, std::atomic< const std::set< ProductProvenance > > &writeTo) const override

Private Attributes
SharedResourcesAcquirer	acquirer_

DaqProvenanceHelper const *	daqProvenanceHelper_

std::shared_ptr < std::recursive_mutex >	mutex_

std::vector< ParentageID > const &	parentageIDLookup_

StoredProductProvenanceVector const *	pProvVector_

edm::propagate_const< TBranch * >	provBranch_

StoredProductProvenanceVector	provVector_

edm::propagate_const< RootTree * >	rootTree_

Detailed Description

Definition at line 2171 of file RootFile.cc.

Constructor & Destructor Documentation

edm::ReducedProvenanceReader::ReducedProvenanceReader	(	RootTree *	iRootTree,
		std::vector< ParentageID > const &	iParentageIDLookup,
		DaqProvenanceHelper const *	daqProvenanceHelper
	)

Definition at line 2195 of file RootFile.cc.

References edm::BranchTypeToProductProvenanceBranchName(), provBranch_, and rootTree_.

       : ProvenanceReaderBase(),
         rootTree_(iRootTree),
         pProvVector_(&provVector_),
         parentageIDLookup_(iParentageIDLookup),
         daqProvenanceHelper_(daqProvenanceHelper),
         mutex_(SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader().second),
         acquirer_(SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader().first) {
     provBranch_ =
         rootTree_->tree()->GetBranch(BranchTypeToProductProvenanceBranchName(rootTree_->branchType()).c_str());
   }

Member Function Documentation

std::set< ProductProvenance > edm::ReducedProvenanceReader::readProvenance ( unsigned int transitionIndex ) const

overridevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2283 of file RootFile.cc.

References daqProvenanceHelper_, Exception, edm::errors::LogicError, edm::DaqProvenanceHelper::mapBranchID(), edm::DaqProvenanceHelper::mapParentageID(), hlt_dqm_clientPB-live_cfg::me, mutex_, parentageIDLookup_, pProvVector_, provBranch_, provVector_, and rootTree_.

                                                                                                       {
     {
       std::lock_guard<std::recursive_mutex> guard(*mutex_);
       ReducedProvenanceReader* me = const_cast<ReducedProvenanceReader*>(this);
       me->rootTree_->fillBranchEntry(
           me->provBranch_, me->rootTree_->entryNumberForIndex(transitionIndex), me->pProvVector_);
     }
     std::set<ProductProvenance> retValue;
     if (daqProvenanceHelper_) {
       for (auto const& prov : provVector_) {
         BranchID bid(prov.branchID_);
         retValue.emplace(daqProvenanceHelper_->mapBranchID(BranchID(prov.branchID_)),
                          daqProvenanceHelper_->mapParentageID(parentageIDLookup_[prov.parentageIDIndex_]));
       }
     } else {
       for (auto const& prov : provVector_) {
         if (prov.parentageIDIndex_ >= parentageIDLookup_.size()) {
           throw edm::Exception(errors::LogicError)
               << "ReducedProvenanceReader::ReadProvenance\n"
               << "The parentage ID index value " << prov.parentageIDIndex_
               << " is out of bounds.  The maximum value is " << parentageIDLookup_.size() - 1 << ".\n"
               << "This should never happen.\n"
               << "Please report this to the framework hypernews forum 'hn-cms-edmFramework@cern.ch'.\n";
         }
         retValue.emplace(BranchID(prov.branchID_), parentageIDLookup_[prov.parentageIDIndex_]);
       }
     }
     return retValue;
   }

void edm::ReducedProvenanceReader::readProvenanceAsync	(	WaitingTaskHolder	task,
		ModuleCallingContext const *	moduleCallingContext,
		unsigned int	transitionIndex,
		std::atomic< const std::set< ProductProvenance > * > &	writeTo
	)		const

overrideprivatevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2269 of file RootFile.cc.

References acquirer_, rootTree_, and edm::SharedResourcesAcquirer::serialQueueChain().

                                                                                                                 {
     readProvenanceAsyncImpl(this,
                             acquirer_.serialQueueChain(),
                             task,
                             transitionIndex,
                             writeTo,
                             moduleCallingContext,
                             rootTree_->rootDelayedReader()->preEventReadFromSourceSignal(),
                             rootTree_->rootDelayedReader()->postEventReadFromSourceSignal());
   }