Inheritance diagram for edm::OldProvenanceReader:

Public Member Functions
	OldProvenanceReader (RootTree rootTree, EntryDescriptionMap const &theMap, DaqProvenanceHelper const daqProvenanceHelper)

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

	~OldProvenanceReader () override

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

virtual	~ProvenanceReaderBase ()

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

Private Attributes
SharedResourcesAcquirer	acquirer_

DaqProvenanceHelper const *	daqProvenanceHelper_

EntryDescriptionMap const &	entryDescriptionMap_

std::vector< EventEntryInfo >	infoVector_

std::shared_ptr< std::recursive_mutex >	mutex_

std::vector< EventEntryInfo > *	pInfoVector_

edm::propagate_const< RootTree * >	rootTree_

Detailed Description

Definition at line 2081 of file RootFile.cc.

Constructor & Destructor Documentation

◆ OldProvenanceReader()

edm::OldProvenanceReader::OldProvenanceReader	(	RootTree *	rootTree,
		EntryDescriptionMap const &	theMap,
		DaqProvenanceHelper const *	daqProvenanceHelper
	)

explicit

Definition at line 2105 of file RootFile.cc.

       : ProvenanceReaderBase(),
         rootTree_(rootTree),
         infoVector_(),
         pInfoVector_(&infoVector_),
         entryDescriptionMap_(theMap),
         daqProvenanceHelper_(daqProvenanceHelper),
         mutex_(SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader().second),
         acquirer_(SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader().first) {}

◆ ~OldProvenanceReader()

edm::OldProvenanceReader::~OldProvenanceReader ( )

inlineoverride

Definition at line 2086 of file RootFile.cc.

2086 {}

Member Function Documentation

◆ readProvenance()

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

overridevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2131 of file RootFile.cc.

                                                                                                   {
     {
       std::lock_guard<std::recursive_mutex> guard(*mutex_);
       rootTree_->branchEntryInfoBranch()->SetAddress(&pInfoVector_);
       roottree::getEntry(rootTree_->branchEntryInfoBranch(), rootTree_->entryNumberForIndex(transitionIndex));
     }
     std::set<ProductProvenance> retValue;
     for (auto const& info : infoVector_) {
       EntryDescriptionMap::const_iterator iter = entryDescriptionMap_.find(info.entryDescriptionID());
       assert(iter != entryDescriptionMap_.end());
       Parentage parentage(iter->second.parents());
       if (daqProvenanceHelper_) {
         retValue.emplace(daqProvenanceHelper_->mapBranchID(info.branchID()),
                          daqProvenanceHelper_->mapParentageID(parentage.id()));
       } else {
         retValue.emplace(info.branchID(), parentage.id());
       }
     }
     return retValue;
   }

References cms::cuda::assert(), daqProvenanceHelper_, entryDescriptionMap_, edm::roottree::getEntry(), info(), infoVector_, edm::DaqProvenanceHelper::mapBranchID(), edm::DaqProvenanceHelper::mapParentageID(), mutex_, pInfoVector_, and rootTree_.

◆ readProvenanceAsync()

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

overrideprivatevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2117 of file RootFile.cc.

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