edm::ReducedProvenanceReader Class Reference

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

Constructor & Destructor Documentation

ReducedProvenanceReader()

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

Definition at line 2224 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

readProvenance()

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

overridevirtual

Implements edm::ProvenanceReaderBase.

Definition at line 2312 of file RootFile.cc.

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

                                                                                                      {
    {
      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;
  }

readProvenanceAsync()

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

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

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

Member Data Documentation

acquirer_

SharedResourcesAcquirer edm::ReducedProvenanceReader::acquirer_

private

Definition at line 2221 of file RootFile.cc.

Referenced by readProvenanceAsync().

daqProvenanceHelper_

DaqProvenanceHelper const* edm::ReducedProvenanceReader::daqProvenanceHelper_

private

Definition at line 2219 of file RootFile.cc.

Referenced by readProvenance().

mutex_

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

private

Definition at line 2220 of file RootFile.cc.

Referenced by readProvenance().

parentageIDLookup_

std::vector<ParentageID> const& edm::ReducedProvenanceReader::parentageIDLookup_

private

Definition at line 2218 of file RootFile.cc.

Referenced by readProvenance().

pProvVector_

StoredProductProvenanceVector const* edm::ReducedProvenanceReader::pProvVector_

private

Definition at line 2217 of file RootFile.cc.

provBranch_

edm::propagate_const<TBranch*> edm::ReducedProvenanceReader::provBranch_

private

Definition at line 2215 of file RootFile.cc.

Referenced by ReducedProvenanceReader().

provVector_

StoredProductProvenanceVector edm::ReducedProvenanceReader::provVector_

private

Definition at line 2216 of file RootFile.cc.

Referenced by readProvenance().

rootTree_

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

private

Definition at line 2214 of file RootFile.cc.

Referenced by readProvenanceAsync(), and ReducedProvenanceReader().