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 (WaitingTaskHolder 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 2313 of file RootFile.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 2334 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 2316 of file RootFile.cc.

{}

Member Function Documentation

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

overridevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2357 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_, and rootTree_.

                                                                                                   {
    {
      std::lock_guard<std::recursive_mutex> guard(*mutex_);
      rootTree_->fillBranchEntryMeta(
          rootTree_->branchEntryInfoBranch(), rootTree_->entryNumberForIndex(transitionIndex), pInfoVector_);
    }
    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 ( WaitingTaskHolder  task, ModuleCallingContext const *  moduleCallingContext, unsigned int  transitionIndex, std::atomic< const std::set< ProductProvenance > * > &  writeTo  ) const

overrideprivatevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2343 of file RootFile.cc.

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

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

Referenced by readProvenanceAsync().

DaqProvenanceHelper const* edm::FullProvenanceReader::daqProvenanceHelper_

private

Definition at line 2329 of file RootFile.cc.

Referenced by readProvenance().

ProductProvenanceVector edm::FullProvenanceReader::infoVector_

private

Definition at line 2326 of file RootFile.cc.

Referenced by readProvenance().

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

private

Definition at line 2330 of file RootFile.cc.

Referenced by readProvenance().

ProductProvenanceVector* edm::FullProvenanceReader::pInfoVector_

mutableprivate

Definition at line 2328 of file RootFile.cc.

Referenced by readProvenance().

RootTree* edm::FullProvenanceReader::rootTree_

private

Definition at line 2325 of file RootFile.cc.

Referenced by readProvenance(), and readProvenanceAsync().