#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 52 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 21 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 31 of file ProductProvenanceRetriever.cc.

References readEntryInfoSet_.

31 { delete readEntryInfoSet_.load(); }

edm::ProductProvenanceRetriever::readEntryInfoSet_

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

Definition: ProductProvenanceRetriever.h:83

Member Function Documentation

ProductProvenance const * edm::ProductProvenanceRetriever::branchIDToProvenance ( BranchID const & bid ) const

Definition at line 103 of file ProductProvenanceRetriever.cc.

References DataFormats::L1THGCal::ei, 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 itRead = ptr->find(ei);
         if (itRead != ptr->end()) {
           return &*itRead;
         }
       }
       if (nextRetriever_) {
         return nextRetriever_->branchIDToProvenance(bid);
       }
       return nullptr;
     }
     return &*it;
   }

ProductProvenance const * edm::ProductProvenanceRetriever::branchIDToProvenanceForProducedOnly ( BranchID const & bid ) const

Definition at line 127 of file ProductProvenanceRetriever.cc.

References DataFormats::L1THGCal::ei, 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 54 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 87 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, and eostools::move().

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

                                                                                   {
     //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 99 of file ProductProvenanceRetriever.cc.

References parentProcessRetriever_.

                                                                                                               {
     parentProcessRetriever_ = &provRetriever;
   }

void edm::ProductProvenanceRetriever::mergeProvenanceRetrievers ( std::shared_ptr< ProductProvenanceRetriever > other )

Definition at line 95 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 33 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 44 of file ProductProvenanceRetriever.cc.

References nextRetriever_, provenanceReader_, readEntryInfoSet_, and transitionIndex_.

                                                                                                                {
     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 77 of file ProductProvenanceRetriever.cc.

References entryInfoSet_, nextRetriever_, parentProcessRetriever_, and readEntryInfoSet_.

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