edm::OldProvenanceReader Class Reference

Inheritance diagram for edm::OldProvenanceReader:

Public Member Functions
	OldProvenanceReader (RootTree *rootTree, EntryDescriptionMap const &theMap, DaqProvenanceHelper const *daqProvenanceHelper)
virtual std::set< ProductProvenance >	readProvenance (unsigned int transitionIndex) const override
virtual	~OldProvenanceReader ()
Public Member Functions inherited from edm::ProvenanceReaderBase
	ProvenanceReaderBase ()
virtual	~ProvenanceReaderBase ()

Private Member Functions
virtual 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 2034 of file RootFile.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 2055 of file RootFile.cc.

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

virtual edm::OldProvenanceReader::~OldProvenanceReader ( )

inlinevirtual

Definition at line 2037 of file RootFile.cc.

References edm::FullProvenanceReader::readProvenance(), and edm::FullProvenanceReader::readProvenanceAsync().

{}

Member Function Documentation

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

overridevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2084 of file RootFile.cc.

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

Referenced by edm::DummyProvenanceReader::~DummyProvenanceReader().

                                                                        {
    {
      std::lock_guard<std::recursive_mutex> guard(*mutex_);
      rootTree_->branchEntryInfoBranch()->SetAddress(&pInfoVector_);
      roottree::getEntry(rootTree_->branchEntryInfoBranch(), rootTree_->entryNumberForIndex(transitionIndex));
      setRefCoreStreamer(true);
    }
    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;
  }

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 2068 of file RootFile.cc.

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

Referenced by edm::DummyProvenanceReader::~DummyProvenanceReader().

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

Member Data Documentation

SharedResourcesAcquirer edm::OldProvenanceReader::acquirer_

private

Definition at line 2052 of file RootFile.cc.

Referenced by readProvenanceAsync().

DaqProvenanceHelper const* edm::OldProvenanceReader::daqProvenanceHelper_

private

Definition at line 2050 of file RootFile.cc.

Referenced by readProvenance().

EntryDescriptionMap const& edm::OldProvenanceReader::entryDescriptionMap_

private

Definition at line 2049 of file RootFile.cc.

Referenced by readProvenance().

std::vector<EventEntryInfo> edm::OldProvenanceReader::infoVector_

private

Definition at line 2047 of file RootFile.cc.

Referenced by readProvenance().

std::shared_ptr<std::recursive_mutex> edm::OldProvenanceReader::mutex_

private

Definition at line 2051 of file RootFile.cc.

Referenced by readProvenance().

std::vector<EventEntryInfo>* edm::OldProvenanceReader::pInfoVector_

mutableprivate

Definition at line 2048 of file RootFile.cc.

Referenced by readProvenance().

edm::propagate_const<RootTree*> edm::OldProvenanceReader::rootTree_

private

Definition at line 2046 of file RootFile.cc.

Referenced by readProvenance(), and readProvenanceAsync().