edm::FullProvenanceReader Class Reference

Inheritance diagram for edm::FullProvenanceReader:

Public Member Functions
	FullProvenanceReader (RootTree *rootTree, DaqProvenanceHelper const *daqProvenanceHelper)
std::set< ProductProvenance >	readProvenance (unsigned int transitionIndex) const override
	~FullProvenanceReader () 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_
ProductProvenanceVector	infoVector_
std::shared_ptr< std::recursive_mutex >	mutex_
ProductProvenanceVector *	pInfoVector_
RootTree *	rootTree_

Detailed Description

Definition at line 1966 of file RootFile.cc.

Constructor & Destructor Documentation

edm::FullProvenanceReader::FullProvenanceReader ( RootTree *  rootTree, DaqProvenanceHelper const *  daqProvenanceHelper  )

explicit

Definition at line 1986 of file RootFile.cc.

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

edm::FullProvenanceReader::~FullProvenanceReader ( )

inlineoverride

Definition at line 1969 of file RootFile.cc.

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

{}

Member Function Documentation

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

overridevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2014 of file RootFile.cc.

References edm::RootTree::branchEntryInfoBranch(), daqProvenanceHelper_, edm::RootTree::entryNumberForIndex(), edm::RootTree::fillBranchEntryMeta(), info(), infoVector_, edm::DaqProvenanceHelper::mapBranchID(), edm::DaqProvenanceHelper::mapParentageID(), mutex_, pInfoVector_, rootTree_, and edm::setRefCoreStreamer().

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

                                                                         {
    {
      std::lock_guard<std::recursive_mutex> guard(*mutex_);
      rootTree_->fillBranchEntryMeta(rootTree_->branchEntryInfoBranch(), rootTree_->entryNumberForIndex(transitionIndex), pInfoVector_);
      setRefCoreStreamer(true);
    }
    std::set<ProductProvenance> retValue;
    if(daqProvenanceHelper_) {
      for(auto const& info : infoVector_) {
        retValue.emplace(daqProvenanceHelper_->mapBranchID(info.branchID()),
                         daqProvenanceHelper_->mapParentageID(info.parentageID()));
      }
    } else {
      for(auto const& info : infoVector_) {
        retValue.emplace(info);
      }
    }
    return retValue;
  }

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

overrideprivatevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 1998 of file RootFile.cc.

References acquirer_, edm::DelayedReader::postEventReadFromSourceSignal(), edm::DelayedReader::preEventReadFromSourceSignal(), edm::RootTree::rootDelayedReader(), rootTree_, and edm::SharedResourcesAcquirer::serialQueueChain().

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

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

Member Data Documentation

SharedResourcesAcquirer edm::FullProvenanceReader::acquirer_

private

Definition at line 1983 of file RootFile.cc.

Referenced by readProvenanceAsync().

DaqProvenanceHelper const* edm::FullProvenanceReader::daqProvenanceHelper_

private

Definition at line 1981 of file RootFile.cc.

Referenced by readProvenance().

ProductProvenanceVector edm::FullProvenanceReader::infoVector_

private

Definition at line 1979 of file RootFile.cc.

Referenced by readProvenance().

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

private

Definition at line 1982 of file RootFile.cc.

Referenced by readProvenance().

ProductProvenanceVector* edm::FullProvenanceReader::pInfoVector_

mutableprivate

Definition at line 1980 of file RootFile.cc.

Referenced by readProvenance().

RootTree* edm::FullProvenanceReader::rootTree_

private

Definition at line 1978 of file RootFile.cc.

Referenced by readProvenance(), and readProvenanceAsync().