edm::ProductProvenanceRetriever Class Reference

#include <ProductProvenanceRetriever.h>

Public Member Functions
ProductProvenance const *	branchIDToProvenance (BranchID const &bid) const
ProductProvenance const *	branchIDToProvenanceForProducedOnly (BranchID const &bid) const
void	deepCopy (ProductProvenanceRetriever const &)
void	insertIntoSet (ProductProvenance provenanceProduct) const
void	mergeParentProcessRetriever (ProductProvenanceRetriever const &provRetriever)
void	mergeProvenanceRetrievers (std::shared_ptr< ProductProvenanceRetriever > other)
ProductProvenanceRetriever &	operator= (ProductProvenanceRetriever const &)=delete
	ProductProvenanceRetriever (unsigned int iTransitionIndex)
	ProductProvenanceRetriever (std::unique_ptr< ProvenanceReaderBase > reader)
void	readProvenanceAsync (WaitingTask *task, ModuleCallingContext const *moduleCallingContext) const
void	reset ()
	~ProductProvenanceRetriever ()

Private Member Functions
void	readProvenance () const
void	setTransitionIndex (unsigned int transitionIndex)

Private Attributes
tbb::concurrent_unordered_set< ProductProvenance, ProductProvenanceHasher, ProductProvenanceEqual >	entryInfoSet_
edm::propagate_const< std::shared_ptr< ProductProvenanceRetriever > >	nextRetriever_
edm::propagate_const< ProductProvenanceRetriever const * >	parentProcessRetriever_
std::shared_ptr< const ProvenanceReaderBase >	provenanceReader_
std::atomic< const std::set< ProductProvenance > * >	readEntryInfoSet_
unsigned int	transitionIndex_

Detailed Description

Definition at line 55 of file ProductProvenanceRetriever.h.

Constructor & Destructor Documentation

edm::ProductProvenanceRetriever::ProductProvenanceRetriever ( unsigned int  iTransitionIndex )

explicit

Definition at line 13 of file ProductProvenanceRetriever.cc.

                                                                                      :
      entryInfoSet_(),
      readEntryInfoSet_(),
      nextRetriever_(),
      parentProcessRetriever_(nullptr),
      provenanceReader_(),
      transitionIndex_(iTransitionIndex){
  }

edm::ProductProvenanceRetriever::ProductProvenanceRetriever ( std::unique_ptr< ProvenanceReaderBase >  reader )

explicit

Definition at line 22 of file ProductProvenanceRetriever.cc.

References provenanceReader_.

                                                                                                   :
      entryInfoSet_(),
      readEntryInfoSet_(),
      nextRetriever_(),
      parentProcessRetriever_(nullptr),
      provenanceReader_(reader.release()),
      transitionIndex_(std::numeric_limits<unsigned int>::max())
  {
    assert(provenanceReader_);
  }

edm::ProductProvenanceRetriever::~ProductProvenanceRetriever

(

)

Definition at line 33 of file ProductProvenanceRetriever.cc.

References readEntryInfoSet_.

                                                          {
    delete readEntryInfoSet_.load();
  }

Member Function Documentation

ProductProvenance const * edm::ProductProvenanceRetriever::branchIDToProvenance

(

BranchID const &

bid

)

const

Definition at line 114 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, nextRetriever_, parentProcessRetriever_, readEntryInfoSet_, and readProvenance().

Referenced by edm::RootOutputFile::fillBranches(), edm::RootOutputFile::insertAncestors(), and edm::Provenance::productProvenance().

                                                                            {
    ProductProvenance ei(bid);
    auto it = entryInfoSet_.find(ei);
    if(it == entryInfoSet_.end()) {
      if (parentProcessRetriever_) {
        return parentProcessRetriever_->branchIDToProvenance(bid);
      }
      //check in source
      readProvenance();
      auto ptr =readEntryInfoSet_.load();
      if(ptr) {
        auto it = ptr->find(ei);
        if(it!= ptr->end()) {
          return &*it;
        }
      }
      if(nextRetriever_) {
        return nextRetriever_->branchIDToProvenance(bid);
      }
      return nullptr;
    }
    return &*it;
  }

ProductProvenance const * edm::ProductProvenanceRetriever::branchIDToProvenanceForProducedOnly

(

BranchID const &

bid

)

const

Definition at line 139 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, nextRetriever_, and parentProcessRetriever_.

Referenced by edm::PoolOutputModule::updateBranchParentsForOneBranch().

                                                                                           {
    ProductProvenance ei(bid);
    auto it = entryInfoSet_.find(ei);
    if(it == entryInfoSet_.end()) {
      if (parentProcessRetriever_) {
        return parentProcessRetriever_->branchIDToProvenanceForProducedOnly(bid);
      }
      if(nextRetriever_) {
        return nextRetriever_->branchIDToProvenanceForProducedOnly(bid);
      }
      return nullptr;
    }
    return &*it;
  }

void edm::ProductProvenanceRetriever::deepCopy

(

ProductProvenanceRetriever const &

iFrom

)

Definition at line 59 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, nextRetriever_, provenanceReader_, readEntryInfoSet_, and transitionIndex_.

  {
    if(iFrom.readEntryInfoSet_) {
      if (readEntryInfoSet_) {
        delete readEntryInfoSet_.exchange(nullptr);
      }
      readEntryInfoSet_ = new std::set<ProductProvenance>(*iFrom.readEntryInfoSet_);
    } else {
      if(readEntryInfoSet_) {
        delete readEntryInfoSet_.load();
        readEntryInfoSet_ = nullptr;
      }
    }
    entryInfoSet_ = iFrom.entryInfoSet_;
    provenanceReader_ = iFrom.provenanceReader_;
    
    if(iFrom.nextRetriever_) {
      if(not nextRetriever_) {
        nextRetriever_ = std::make_shared<ProductProvenanceRetriever>(transitionIndex_);
      }
      nextRetriever_->deepCopy(*(iFrom.nextRetriever_));
    }
  }

void edm::ProductProvenanceRetriever::insertIntoSet

(

ProductProvenance

provenanceProduct

)

const

Definition at line 95 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, and eostools::move().

Referenced by edm::EventPrincipal::put(), and edm::EventPrincipal::putOnRead().

                                                                             {
    //NOTE:do not read provenance here because we only need the full
    // provenance when someone tries to access it not when doing the insert
    // doing the delay saves 20% of time when doing an analysis job
    //readProvenance();
    entryInfoSet_.insert(std::move(entryInfo));
  }

void edm::ProductProvenanceRetriever::mergeParentProcessRetriever

(

ProductProvenanceRetriever const &

provRetriever

)

Definition at line 109 of file ProductProvenanceRetriever.cc.

References parentProcessRetriever_.

                                                                                                         {
    parentProcessRetriever_ = &provRetriever;
  }

void edm::ProductProvenanceRetriever::mergeProvenanceRetrievers

(

std::shared_ptr< ProductProvenanceRetriever >

other

)

Definition at line 104 of file ProductProvenanceRetriever.cc.

References nextRetriever_, and trackingPlots::other.

                                                                                                       {
    nextRetriever_ = other;
  }

ProductProvenanceRetriever& edm::ProductProvenanceRetriever::operator= ( ProductProvenanceRetriever const &  )

delete

void edm::ProductProvenanceRetriever::readProvenance ( ) const

private

Definition at line 38 of file ProductProvenanceRetriever.cc.

References provenanceReader_, readEntryInfoSet_, groupFilesInBlocks::temp, and transitionIndex_.

Referenced by branchIDToProvenance().

                                                   {
    if(nullptr == readEntryInfoSet_.load() && provenanceReader_) {
      auto temp = std::make_unique<std::set<ProductProvenance> const>(provenanceReader_->readProvenance(transitionIndex_));
      std::set<ProductProvenance> const* expected = nullptr;
      if(readEntryInfoSet_.compare_exchange_strong(expected, temp.get())) {
        temp.release();
      }
    }
  }

void edm::ProductProvenanceRetriever::readProvenanceAsync	(	WaitingTask *	task,
		ModuleCallingContext const *	moduleCallingContext
	)		const

Definition at line 49 of file ProductProvenanceRetriever.cc.

References nextRetriever_, provenanceReader_, readEntryInfoSet_, and transitionIndex_.

Referenced by edm::PoolOutputModule::preActionBeforeRunEventAsync().

                                                                                                                           {
    if(provenanceReader_ and nullptr == readEntryInfoSet_.load() ) {
      provenanceReader_->readProvenanceAsync(task, moduleCallingContext,transitionIndex_,readEntryInfoSet_);
    }
    if(nextRetriever_) {
      nextRetriever_->readProvenanceAsync(task,moduleCallingContext);
    }
  }

void edm::ProductProvenanceRetriever::reset

(

void

)

Definition at line 84 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, nextRetriever_, parentProcessRetriever_, and readEntryInfoSet_.

                                    {
    delete readEntryInfoSet_.load();
    readEntryInfoSet_ = nullptr;
    entryInfoSet_.clear();
    if(nextRetriever_) {
      nextRetriever_->reset();
    }
    parentProcessRetriever_ = nullptr;
  }

void edm::ProductProvenanceRetriever::setTransitionIndex ( unsigned int  transitionIndex )

inlineprivate

Definition at line 82 of file ProductProvenanceRetriever.h.

                                                          {
      transitionIndex_=transitionIndex;
    }

Member Data Documentation

tbb::concurrent_unordered_set<ProductProvenance, ProductProvenanceHasher, ProductProvenanceEqual> edm::ProductProvenanceRetriever::entryInfoSet_

mutableprivate

Definition at line 86 of file ProductProvenanceRetriever.h.

Referenced by branchIDToProvenance(), branchIDToProvenanceForProducedOnly(), deepCopy(), insertIntoSet(), and reset().

edm::propagate_const<std::shared_ptr<ProductProvenanceRetriever> > edm::ProductProvenanceRetriever::nextRetriever_

private

Definition at line 88 of file ProductProvenanceRetriever.h.

Referenced by branchIDToProvenance(), branchIDToProvenanceForProducedOnly(), deepCopy(), mergeProvenanceRetrievers(), readProvenanceAsync(), and reset().

edm::propagate_const<ProductProvenanceRetriever const*> edm::ProductProvenanceRetriever::parentProcessRetriever_

private

Definition at line 89 of file ProductProvenanceRetriever.h.

Referenced by branchIDToProvenance(), branchIDToProvenanceForProducedOnly(), mergeParentProcessRetriever(), and reset().

std::shared_ptr<const ProvenanceReaderBase> edm::ProductProvenanceRetriever::provenanceReader_

private

Definition at line 90 of file ProductProvenanceRetriever.h.

Referenced by deepCopy(), ProductProvenanceRetriever(), readProvenance(), and readProvenanceAsync().

std::atomic<const std::set<ProductProvenance>*> edm::ProductProvenanceRetriever::readEntryInfoSet_

mutableprivate

Definition at line 87 of file ProductProvenanceRetriever.h.

Referenced by branchIDToProvenance(), deepCopy(), readProvenance(), readProvenanceAsync(), reset(), and ~ProductProvenanceRetriever().

unsigned int edm::ProductProvenanceRetriever::transitionIndex_

private

Definition at line 91 of file ProductProvenanceRetriever.h.

Referenced by deepCopy(), readProvenance(), and readProvenanceAsync().