edm::ProductProvenanceRetriever Class Reference

#include <ProductProvenanceRetriever.h>

Inheritance diagram for edm::ProductProvenanceRetriever:

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

Private Member Functions
const ProductProvenanceLookup *	nextRetriever () const final
std::unique_ptr< const std::set< ProductProvenance > >	readProvenance () const final
void	setTransitionIndex (unsigned int transitionIndex)

Private Attributes
edm::propagate_const < std::shared_ptr < ProductProvenanceRetriever > >	nextRetriever_
std::shared_ptr< const ProvenanceReaderBase >	provenanceReader_
unsigned int	transitionIndex_

Additional Inherited Members
Protected Attributes inherited from edm::ProductProvenanceLookup
std::vector < ProducedProvenanceInfo >	entryInfoSet_
edm::propagate_const < ProductProvenanceLookup const * >	parentProcessRetriever_
std::atomic< const std::set < ProductProvenance > * >	readEntryInfoSet_

Detailed Description

Definition at line 37 of file ProductProvenanceRetriever.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 13 of file ProductProvenanceRetriever.cc.

      : ProductProvenanceLookup(), nextRetriever_(), provenanceReader_(), transitionIndex_(iTransitionIndex) {}

edm::ProductProvenanceRetriever::ProductProvenanceRetriever	(	unsigned int	iTransitionIndex,
		edm::ProductRegistry const &	iReg
	)

Definition at line 16 of file ProductProvenanceRetriever.cc.

      : ProductProvenanceLookup(iReg), nextRetriever_(), provenanceReader_(), transitionIndex_(iTransitionIndex) {}

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

explicit

Definition at line 20 of file ProductProvenanceRetriever.cc.

References cms::cuda::assert(), and provenanceReader_.

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

Member Function Documentation

void edm::ProductProvenanceRetriever::deepCopy

(

ProductProvenanceRetriever const &

iFrom

)

Definition at line 46 of file ProductProvenanceRetriever.cc.

References cms::cuda::assert(), edm::ProductProvenanceLookup::entryInfoSet_, nextRetriever_, provenanceReader_, edm::ProductProvenanceLookup::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;
      }
    }
    assert(iFrom.entryInfoSet_.empty());
    provenanceReader_ = iFrom.provenanceReader_;

    if (iFrom.nextRetriever_) {
      if (not nextRetriever_) {
        nextRetriever_ = std::make_shared<ProductProvenanceRetriever>(transitionIndex_);
      }
      nextRetriever_->deepCopy(*(iFrom.nextRetriever_));
    }
  }

void edm::ProductProvenanceRetriever::mergeParentProcessRetriever

(

ProductProvenanceRetriever const &

provRetriever

)

Definition at line 85 of file ProductProvenanceRetriever.cc.

References edm::ProductProvenanceLookup::parentProcessRetriever_.

                                                                                                              {
    parentProcessRetriever_ = &provRetriever;
  }

void edm::ProductProvenanceRetriever::mergeProvenanceRetrievers

(

std::shared_ptr< ProductProvenanceRetriever >

other

)

Definition at line 81 of file ProductProvenanceRetriever.cc.

References nextRetriever_.

                                                                                                            {
    nextRetriever_ = other;
  }

const ProductProvenanceLookup* edm::ProductProvenanceRetriever::nextRetriever ( ) const

inlinefinalprivatevirtual

Implements edm::ProductProvenanceLookup.

Definition at line 57 of file ProductProvenanceRetriever.h.

References nextRetriever_.

{ return nextRetriever_.get(); }

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

delete

std::unique_ptr< const std::set< ProductProvenance > > edm::ProductProvenanceRetriever::readProvenance ( ) const

finalprivatevirtual

Implements edm::ProductProvenanceLookup.

Definition at line 28 of file ProductProvenanceRetriever.cc.

References provenanceReader_, groupFilesInBlocks::temp, and transitionIndex_.

                                                                                                  {
    std::unique_ptr<const std::set<ProductProvenance>> temp;
    if (provenanceReader_) {
      temp = std::make_unique<std::set<ProductProvenance> const>(provenanceReader_->readProvenance(transitionIndex_));
    }
    return temp;
  }

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

Definition at line 36 of file ProductProvenanceRetriever.cc.

References nextRetriever_, provenanceReader_, edm::ProductProvenanceLookup::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 69 of file ProductProvenanceRetriever.cc.

References alignCSCRings::e, edm::ProductProvenanceLookup::entryInfoSet_, nextRetriever_, edm::ProductProvenanceLookup::parentProcessRetriever_, and edm::ProductProvenanceLookup::readEntryInfoSet_.

                                         {
    delete readEntryInfoSet_.load();
    readEntryInfoSet_ = nullptr;
    for (auto& e : entryInfoSet_) {
      e.resetParentage();
    }
    if (nextRetriever_) {
      nextRetriever_->reset();
    }
    parentProcessRetriever_ = nullptr;
  }

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

inlineprivate

Definition at line 58 of file ProductProvenanceRetriever.h.

References transitionIndex_.

{ transitionIndex_ = transitionIndex; }

Member Data Documentation

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

private

Definition at line 60 of file ProductProvenanceRetriever.h.

Referenced by deepCopy(), mergeProvenanceRetrievers(), nextRetriever(), readProvenanceAsync(), and reset().

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

private

Definition at line 61 of file ProductProvenanceRetriever.h.

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

unsigned int edm::ProductProvenanceRetriever::transitionIndex_

private

Definition at line 62 of file ProductProvenanceRetriever.h.

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