edm::ProductResolverBase Class Reference

#include <ProductResolverBase.h>

Inheritance diagram for edm::ProductResolverBase:

Classes
class	Resolution

Public Member Functions
BranchDescription const &	branchDescription () const
virtual void	connectTo (ProductResolverBase const &, Principal const *)=0
std::string const &	moduleLabel () const
ProductResolverBase &	operator= (ProductResolverBase const &)=delete
void	prefetchAsync (WaitingTask *waitTask, Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
std::string const &	processName () const
ProductID const &	productID () const
std::string const &	productInstanceName () const
ProductProvenance const *	productProvenancePtr () const
bool	productResolved () const
	ProductResolverBase ()
	ProductResolverBase (ProductResolverBase const &)=delete
TypeID	productType () const
bool	productUnavailable () const
bool	productWasDeleted () const
bool	productWasFetchedAndIsValid (bool iSkipCurrentProcess) const
Provenance const *	provenance () const
bool	provenanceAvailable () const
void	putOrMergeProduct (std::unique_ptr< WrapperBase > edp) const
void	putProduct (std::unique_ptr< WrapperBase > edp) const
void	resetBranchDescription (std::shared_ptr< BranchDescription const > bd)
virtual void	resetFailedFromThisProcess ()
void	resetProductData ()
std::string const &	resolvedModuleLabel () const
Resolution	resolveProduct (Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
void	retrieveAndMerge (Principal const &principal) const
void	setProcessHistory (ProcessHistory const &ph)
void	setProvenance (ProductProvenanceRetriever const *provRetriever, ProcessHistory const &ph, ProductID const &pid)
virtual void	setupUnscheduled (UnscheduledConfigurator const &)
bool	singleProduct () const
StableProvenance const *	stableProvenance () const
void	unsafe_deleteProduct () const
bool	unscheduledWasNotRun () const
void	write (std::ostream &os) const
virtual	~ProductResolverBase ()

Private Member Functions
virtual BranchDescription const &	branchDescription_ () const =0
virtual void	prefetchAsync_ (WaitingTask *waitTask, Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const =0
virtual ProductProvenance const *	productProvenancePtr_ () const =0
virtual bool	productResolved_ () const =0
virtual bool	productUnavailable_ () const =0
virtual bool	productWasDeleted_ () const =0
virtual bool	productWasFetchedAndIsValid_ (bool iSkipCurrentProcess) const =0
virtual Provenance const *	provenance_ () const =0
virtual void	putOrMergeProduct_ (std::unique_ptr< WrapperBase > edp) const =0
virtual void	putProduct_ (std::unique_ptr< WrapperBase > edp) const =0
virtual void	resetBranchDescription_ (std::shared_ptr< BranchDescription const > bd)=0
virtual void	resetProductData_ (bool deleteEarly)=0
virtual std::string const &	resolvedModuleLabel_ () const =0
virtual Resolution	resolveProduct_ (Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const =0
virtual void	retrieveAndMerge_ (Principal const &principal) const
virtual void	setProcessHistory_ (ProcessHistory const &ph)=0
virtual void	setProvenance_ (ProductProvenanceRetriever const *provRetriever, ProcessHistory const &ph, ProductID const &pid)=0
virtual bool	singleProduct_ () const =0
virtual bool	unscheduledWasNotRun_ () const =0

Detailed Description

Definition at line 32 of file ProductResolverBase.h.

Constructor & Destructor Documentation

edm::ProductResolverBase::ProductResolverBase

(

)

Definition at line 14 of file ProductResolverBase.cc.

{}

edm::ProductResolverBase::~ProductResolverBase ( )

virtual

Definition at line 16 of file ProductResolverBase.cc.

{}

edm::ProductResolverBase::ProductResolverBase ( ProductResolverBase const &  )

delete

Member Function Documentation

BranchDescription const& edm::ProductResolverBase::branchDescription ( ) const

inline

Definition at line 107 of file ProductResolverBase.h.

References branchDescription_().

Referenced by edm::DataManagingProductResolver::checkType(), edm::PrincipalGetAdapter::getBranchDescription(), edm::Principal::getExistingProduct(), edm::DataManagingProductResolver::mergeProduct(), moduleLabel(), edm::InputProductResolver::prefetchAsync_(), edm::PuttableProductResolver::prefetchAsync_(), processName(), productInstanceName(), productType(), provenanceAvailable(), edm::ProducedProductResolver::putProduct_(), edm::InputProductResolver::resolveProduct_(), edm::InputProductResolver::retrieveAndMerge_(), edm::PuttableProductResolver::setupUnscheduled(), edm::UnscheduledProductResolver::setupUnscheduled(), and edm::DataManagingProductResolver::throwProductDeletedException().

{return branchDescription_();}

virtual BranchDescription const& edm::ProductResolverBase::branchDescription_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by branchDescription(), and putOrMergeProduct().

virtual void edm::ProductResolverBase::connectTo ( ProductResolverBase const &  , Principal const *    )

pure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by edm::SubProcess::propagateProducts(), and putOrMergeProduct().

std::string const& edm::ProductResolverBase::moduleLabel ( ) const

inline

Definition at line 116 of file ProductResolverBase.h.

References branchDescription(), and edm::BranchDescription::moduleLabel().

Referenced by edm::DataManagingProductResolver::resolvedModuleLabel_(), edm::NoProcessProductResolver::resolvedModuleLabel_(), edm::SingleChoiceNoProcessProductResolver::resolvedModuleLabel_(), edm::PuttableProductResolver::setupUnscheduled(), edm::UnscheduledProductResolver::setupUnscheduled(), and edm::DataManagingProductResolver::throwProductDeletedException().

{return branchDescription().moduleLabel();}

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

delete

void edm::ProductResolverBase::prefetchAsync ( WaitingTask *  waitTask, Principal const &  principal, bool  skipCurrentProcess, SharedResourcesAcquirer *  sra, ModuleCallingContext const *  mcc  ) const

inline

oDataFetchedIsValid is allowed to be nullptr in which case no value will be assigned

Definition at line 66 of file ProductResolverBase.h.

References prefetchAsync_().

Referenced by edm::NoProcessProductResolver::tryPrefetchResolverAsync().

                                                              {
      return prefetchAsync_(waitTask, principal, skipCurrentProcess, sra, mcc);
    }

virtual void edm::ProductResolverBase::prefetchAsync_ ( WaitingTask *  waitTask, Principal const &  principal, bool  skipCurrentProcess, SharedResourcesAcquirer *  sra, ModuleCallingContext const *  mcc  ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, edm::UnscheduledProductResolver, edm::PuttableProductResolver, and edm::InputProductResolver.

Referenced by edm::InputProductResolver::InputProductResolver(), prefetchAsync(), putOrMergeProduct(), edm::PuttableProductResolver::PuttableProductResolver(), edm::SingleChoiceNoProcessProductResolver::SingleChoiceNoProcessProductResolver(), and edm::UnscheduledProductResolver::UnscheduledProductResolver().

std::string const& edm::ProductResolverBase::processName ( ) const

inline

Definition at line 127 of file ProductResolverBase.h.

References branchDescription(), edm::BranchDescription::processName(), and provenance().

Referenced by edm::DataManagingProductResolver::throwProductDeletedException().

{return branchDescription().processName();}

ProductID const& edm::ProductResolverBase::productID ( ) const

inline

Definition at line 150 of file ProductResolverBase.h.

References edm::Provenance::productID(), and provenance().

Referenced by write().

{return provenance()->productID();}

std::string const& edm::ProductResolverBase::productInstanceName ( ) const

inline

Definition at line 124 of file ProductResolverBase.h.

References branchDescription(), and edm::BranchDescription::productInstanceName().

Referenced by edm::DataManagingProductResolver::throwProductDeletedException().

{return branchDescription().productInstanceName();}

ProductProvenance const* edm::ProductResolverBase::productProvenancePtr ( ) const

inline

Definition at line 104 of file ProductResolverBase.h.

References productProvenancePtr_().

{ return productProvenancePtr_(); }

virtual ProductProvenance const* edm::ProductResolverBase::productProvenancePtr_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by productProvenancePtr(), and putOrMergeProduct().

bool edm::ProductResolverBase::productResolved ( ) const

inline

Definition at line 89 of file ProductResolverBase.h.

References productResolved_(), and provenanceAvailable().

Referenced by edm::InputProductResolver::prefetchAsync_(), provenanceAvailable(), edm::InputProductResolver::putProduct_(), and edm::InputProductResolver::resolveProduct_().

{ return productResolved_(); }

virtual bool edm::ProductResolverBase::productResolved_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by productResolved(), and putOrMergeProduct().

TypeID edm::ProductResolverBase::productType

(

)

const

Definition at line 31 of file ProductResolverBase.cc.

References branchDescription().

Referenced by setProcessHistory().

                                         {
    return TypeID(branchDescription().wrappedTypeID());
  }

bool edm::ProductResolverBase::productUnavailable ( ) const

inline

Definition at line 86 of file ProductResolverBase.h.

References productUnavailable_().

{return productUnavailable_();}

virtual bool edm::ProductResolverBase::productUnavailable_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by productUnavailable(), and putOrMergeProduct().

bool edm::ProductResolverBase::productWasDeleted ( ) const

inline

Definition at line 99 of file ProductResolverBase.h.

References productWasDeleted_().

Referenced by edm::DataManagingProductResolver::resolveProductImpl().

{return productWasDeleted_();}

virtual bool edm::ProductResolverBase::productWasDeleted_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by productWasDeleted(), and putOrMergeProduct().

bool edm::ProductResolverBase::productWasFetchedAndIsValid ( bool  iSkipCurrentProcess ) const

inline

Definition at line 101 of file ProductResolverBase.h.

References productWasFetchedAndIsValid_().

Referenced by edm::NoProcessProductResolver::dataValidFromResolver().

{ return productWasFetchedAndIsValid_(iSkipCurrentProcess); }

virtual bool edm::ProductResolverBase::productWasFetchedAndIsValid_ ( bool  iSkipCurrentProcess ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by productWasFetchedAndIsValid(), and putOrMergeProduct().

Provenance const * edm::ProductResolverBase::provenance

(

)

const

Definition at line 36 of file ProductResolverBase.cc.

References provenance_().

Referenced by processName(), productID(), edm::DataManagingProductResolver::productProvenancePtr_(), edm::AliasProductResolver::productProvenancePtr_(), and stableProvenance().

                                        {
    return provenance_();
  }

virtual Provenance const* edm::ProductResolverBase::provenance_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by provenance(), and putOrMergeProduct().

bool edm::ProductResolverBase::provenanceAvailable

(

)

const

Definition at line 19 of file ProductResolverBase.cc.

References branchDescription(), edm::es::produced, and productResolved().

Referenced by productResolved().

                                                 {
    // If this product is from a the current process,
    // the provenance is available if and only if a product has been put.
    if(branchDescription().produced()) {
      return productResolved();
    }
    // If this product is from a prior process, the provenance is available,
    // although the per event part may have been dropped.
    return true;
  }

void edm::ProductResolverBase::putOrMergeProduct ( std::unique_ptr< WrapperBase >  edp ) const

inline

Definition at line 158 of file ProductResolverBase.h.

References branchDescription_(), connectTo(), eostools::move(), sysUtil::pid, prefetchAsync_(), cmsRelvalreport::principal(), productProvenancePtr_(), productResolved_(), productUnavailable_(), productWasDeleted_(), productWasFetchedAndIsValid_(), provenance_(), putOrMergeProduct_(), putProduct_(), resetBranchDescription_(), resetProductData_(), resolvedModuleLabel_(), resolveProduct_(), retrieveAndMerge_(), setProcessHistory_(), setProvenance_(), setupUnscheduled(), singleProduct_(), AlCaHLTBitMon_QueryRunRegistry::string, and unscheduledWasNotRun_().

Referenced by edm::Principal::putOrMerge(), and edm::InputProductResolver::retrieveAndMerge_().

                                                                 {
      putOrMergeProduct_(std::move(edp));
    }

virtual void edm::ProductResolverBase::putOrMergeProduct_ ( std::unique_ptr< WrapperBase >  edp ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct().

void edm::ProductResolverBase::putProduct ( std::unique_ptr< WrapperBase >  edp ) const

inline

Definition at line 153 of file ProductResolverBase.h.

References eostools::move(), and putProduct_().

Referenced by edm::InputProductResolver::prefetchAsync_(), edm::DataManagingProductResolver::putOrMergeProduct_(), and edm::InputProductResolver::resolveProduct_().

                                                          {
      putProduct_(std::move(edp));
    }

virtual void edm::ProductResolverBase::putProduct_ ( std::unique_ptr< WrapperBase >  edp ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, edm::PuttableProductResolver, edm::ProducedProductResolver, and edm::InputProductResolver.

Referenced by edm::InputProductResolver::InputProductResolver(), edm::ProducedProductResolver::ProducedProductResolver(), edm::AliasProductResolver::productWasFetchedAndIsValid_(), edm::ParentProcessProductResolver::productWasFetchedAndIsValid_(), putOrMergeProduct(), putProduct(), edm::SingleChoiceNoProcessProductResolver::SingleChoiceNoProcessProductResolver(), and edm::PuttableProductResolver::unscheduledWasNotRun_().

void edm::ProductResolverBase::resetBranchDescription ( std::shared_ptr< BranchDescription const >  bd )

inline

Definition at line 113 of file ProductResolverBase.h.

References resetBranchDescription_().

Referenced by edm::Principal::adjustToNewProductRegistry().

{resetBranchDescription_(bd);}

virtual void edm::ProductResolverBase::resetBranchDescription_ ( std::shared_ptr< BranchDescription const >  bd )

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct(), and resetBranchDescription().

void edm::ProductResolverBase::resetFailedFromThisProcess ( )

virtual

Reimplemented in edm::ProducedProductResolver.

Definition at line 56 of file ProductResolverBase.cc.

Referenced by edm::ProducedProductResolver::ProducedProductResolver(), and resetProductData().

{}

void edm::ProductResolverBase::resetProductData ( )

inline

Definition at line 77 of file ProductResolverBase.h.

References resetFailedFromThisProcess(), and resetProductData_().

{ resetProductData_(false); }

virtual void edm::ProductResolverBase::resetProductData_ ( bool  deleteEarly )

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, edm::UnscheduledProductResolver, edm::PuttableProductResolver, edm::InputProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct(), resetProductData(), and unsafe_deleteProduct().

std::string const& edm::ProductResolverBase::resolvedModuleLabel ( ) const

inline

Definition at line 121 of file ProductResolverBase.h.

References resolvedModuleLabel_().

{return resolvedModuleLabel_();}

virtual std::string const& edm::ProductResolverBase::resolvedModuleLabel_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct(), and resolvedModuleLabel().

Resolution edm::ProductResolverBase::resolveProduct ( Principal const &  principal, bool  skipCurrentProcess, SharedResourcesAcquirer *  sra, ModuleCallingContext const *  mcc  ) const

inline

Definition at line 57 of file ProductResolverBase.h.

References resolveProduct_().

Referenced by edm::NoProcessProductResolver::tryResolver().

                                                                     {
      return resolveProduct_( principal, skipCurrentProcess, sra, mcc);
    }

virtual Resolution edm::ProductResolverBase::resolveProduct_ ( Principal const &  principal, bool  skipCurrentProcess, SharedResourcesAcquirer *  sra, ModuleCallingContext const *  mcc  ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, edm::UnscheduledProductResolver, edm::PuttableProductResolver, and edm::InputProductResolver.

Referenced by edm::InputProductResolver::InputProductResolver(), putOrMergeProduct(), edm::PuttableProductResolver::PuttableProductResolver(), resolveProduct(), edm::SingleChoiceNoProcessProductResolver::SingleChoiceNoProcessProductResolver(), and edm::UnscheduledProductResolver::UnscheduledProductResolver().

void edm::ProductResolverBase::retrieveAndMerge ( Principal const &  principal ) const

inline

Definition at line 74 of file ProductResolverBase.h.

References retrieveAndMerge_().

                                                            {
      retrieveAndMerge_(principal);
    }

void edm::ProductResolverBase::retrieveAndMerge_ ( Principal const &  principal ) const

privatevirtual

Reimplemented in edm::InputProductResolver.

Definition at line 41 of file ProductResolverBase.cc.

Referenced by edm::InputProductResolver::InputProductResolver(), putOrMergeProduct(), and retrieveAndMerge().

                                                                         {
  }

void edm::ProductResolverBase::setProcessHistory ( ProcessHistory const &  ph )

inline

Definition at line 139 of file ProductResolverBase.h.

References productType(), setProcessHistory_(), and write().

{ setProcessHistory_(ph); }

virtual void edm::ProductResolverBase::setProcessHistory_ ( ProcessHistory const &  ph )

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct(), and setProcessHistory().

void edm::ProductResolverBase::setProvenance ( ProductProvenanceRetriever const *  provRetriever, ProcessHistory const &  ph, ProductID const &  pid  )

inline

Definition at line 136 of file ProductResolverBase.h.

References setProvenance_().

{ setProvenance_(provRetriever, ph, pid); }

virtual void edm::ProductResolverBase::setProvenance_ ( ProductProvenanceRetriever const *  provRetriever, ProcessHistory const &  ph, ProductID const &  pid  )

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct(), and setProvenance().

void edm::ProductResolverBase::setupUnscheduled ( UnscheduledConfigurator const &  )

virtual

Reimplemented in edm::UnscheduledProductResolver, edm::PuttableProductResolver, and edm::InputProductResolver.

Definition at line 54 of file ProductResolverBase.cc.

Referenced by edm::InputProductResolver::InputProductResolver(), putOrMergeProduct(), edm::PuttableProductResolver::PuttableProductResolver(), edm::Principal::setupUnscheduled(), and edm::UnscheduledProductResolver::UnscheduledProductResolver().

{}

bool edm::ProductResolverBase::singleProduct ( ) const

inline

Definition at line 110 of file ProductResolverBase.h.

References singleProduct_().

{return singleProduct_();}

virtual bool edm::ProductResolverBase::singleProduct_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, and edm::DataManagingProductResolver.

Referenced by putOrMergeProduct(), and singleProduct().

StableProvenance const* edm::ProductResolverBase::stableProvenance ( ) const

inline

Definition at line 133 of file ProductResolverBase.h.

References provenance(), and edm::Provenance::stable().

{return &provenance()->stable();}

void edm::ProductResolverBase::unsafe_deleteProduct ( ) const

inline

Definition at line 81 of file ProductResolverBase.h.

References resetProductData_().

                                      {
      const_cast<ProductResolverBase*>(this)->resetProductData_(true);
    }

bool edm::ProductResolverBase::unscheduledWasNotRun ( ) const

inline

Definition at line 96 of file ProductResolverBase.h.

References unscheduledWasNotRun_().

{return unscheduledWasNotRun_();}

virtual bool edm::ProductResolverBase::unscheduledWasNotRun_ ( ) const

privatepure virtual

Implemented in edm::SingleChoiceNoProcessProductResolver, edm::NoProcessProductResolver, edm::ParentProcessProductResolver, edm::AliasProductResolver, edm::UnscheduledProductResolver, edm::PuttableProductResolver, and edm::InputProductResolver.

Referenced by putOrMergeProduct(), edm::SingleChoiceNoProcessProductResolver::SingleChoiceNoProcessProductResolver(), and unscheduledWasNotRun().

void edm::ProductResolverBase::write

(

std::ostream &

os

)

const

Definition at line 46 of file ProductResolverBase.cc.

References productID(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by pkg.AbstractPkg::generate(), edm::operator<<(), and setProcessHistory().

                                                 {
    // This is grossly inadequate. It is also not critical for the
    // first pass.
    os << std::string("ProductResolver for product with ID: ")
       << productID();
  }