#include <ProductResolvers.h>

Inheritance diagram for edm::DataManagingProductResolver:

Public Types
enum	ProductStatus { ProductStatus::ProductSet, ProductStatus::NotPut, ProductStatus::ResolveFailed, ProductStatus::ResolveNotRun, ProductStatus::ProductDeleted }

Public Member Functions
void	connectTo (ProductResolverBase const &, Principal const *) final

	DataManagingProductResolver (std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)

void	resetProductData_ (bool deleteEarly) override

void	resetStatus ()

Public Member Functions inherited from edm::DataManagingOrAliasProductResolver
	DataManagingOrAliasProductResolver ()

Public Member Functions inherited from edm::ProductResolverBase
BranchDescription const &	branchDescription () const

std::string const &	moduleLabel () const

ProductResolverBase &	operator= (ProductResolverBase const &)=delete

void	prefetchAsync (WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, 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	resetBranchDescription (std::shared_ptr< BranchDescription const > bd)

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, MergeableRunProductMetadata const *mergeableRunProductMetadata) const

void	setMergeableRunProductMetadata (MergeableRunProductMetadata const *mrpm)

void	setProductID (ProductID const &pid)

void	setProductProvenanceRetriever (ProductProvenanceRetriever const *provRetriever)

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 ()

Protected Member Functions
void	checkType (WrapperBase const &prod) const

ProductStatus	defaultStatus () const

ProductData const &	getProductData () const final

template<bool callResolver, typename FUNC >
ProductResolverBase::Resolution	resolveProductImpl (FUNC resolver) const

template<bool callResolver, typename FUNC >
Resolution	resolveProductImpl (FUNC resolver) const

void	setFailedStatus () const

void	setMergeableRunProductMetadataInProductData (MergeableRunProductMetadata const *)

void	setProduct (std::shared_ptr< WrapperBase > edp) const

void	setProduct (std::unique_ptr< WrapperBase > edp) const

ProductStatus	status () const

Private Member Functions
BranchDescription const &	branchDescription_ () const final

virtual bool	isFromCurrentProcess () const =0

ProductProvenance const *	productProvenancePtr_ () const final

bool	productResolved_ () const final

bool	productUnavailable_ () const final

bool	productWasDeleted_ () const final

bool	productWasFetchedAndIsValid_ (bool iSkipCurrentProcess) const final

Provenance const *	provenance_ () const final

void	resetBranchDescription_ (std::shared_ptr< BranchDescription const > bd) final

std::string const &	resolvedModuleLabel_ () const final

void	setProductID_ (ProductID const &pid) final

void	setProductProvenanceRetriever_ (ProductProvenanceRetriever const *provRetriever) final

bool	singleProduct_ () const final

void	throwProductDeletedException () const

Private Attributes
const ProductStatus	defaultStatus_

ProductData	productData_

std::atomic< ProductStatus >	theStatus_

Detailed Description

Definition at line 49 of file ProductResolvers.h.

Member Enumeration Documentation

◆ ProductStatus

enum edm::DataManagingProductResolver::ProductStatus

strong

Enumerator
ProductSet
NotPut
ResolveFailed
ResolveNotRun
ProductDeleted

Definition at line 51 of file ProductResolvers.h.

51 { ProductSet, NotPut, ResolveFailed, ResolveNotRun, ProductDeleted };

Constructor & Destructor Documentation

◆ DataManagingProductResolver()

edm::DataManagingProductResolver::DataManagingProductResolver	(	std::shared_ptr< BranchDescription const >	bd,
		ProductStatus	iDefaultStatus
	)

inline

Definition at line 53 of file ProductResolvers.h.

         : DataManagingOrAliasProductResolver(),
           productData_(bd),
           theStatus_(iDefaultStatus),
           defaultStatus_(iDefaultStatus) {}

Member Function Documentation

◆ branchDescription_()

BranchDescription const& edm::DataManagingProductResolver::branchDescription_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 88 of file ProductResolvers.h.

88 { return *getProductData().branchDescription(); }

References edm::ProductData::branchDescription(), and getProductData().

◆ checkType()

void edm::DataManagingProductResolver::checkType ( WrapperBase const & prod ) const

protected

Definition at line 515 of file ProductResolvers.cc.

                                                                            {
     // Check if the types match.
     TypeID typeID(prod.dynamicTypeInfo());
     if (typeID != TypeID{branchDescription().unwrappedType().unvalidatedTypeInfo()}) {
       // Types do not match.
       throw Exception(errors::EventCorruption)
           << "Product on branch " << branchDescription().branchName() << " is of wrong type.\n"
           << "It is supposed to be of type " << branchDescription().className() << ".\n"
           << "It is actually of type " << typeID.className() << ".\n";
     }
   }

References edm::ProductResolverBase::branchDescription(), edm::BranchDescription::branchName(), edm::BranchDescription::className(), edm::errors::EventCorruption, Exception, dumpMFGeometry_cfg::prod, edm::TypeWithDict::unvalidatedTypeInfo(), and edm::BranchDescription::unwrappedType().

Referenced by edm::MergeableInputProductResolver::mergeProduct(), and setProduct().

◆ connectTo()

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

finalvirtual

Implements edm::ProductResolverBase.

Definition at line 513 of file ProductResolvers.cc.

513 { assert(false); }

References cms::cuda::assert().

◆ defaultStatus()

ProductStatus edm::DataManagingProductResolver::defaultStatus ( ) const

inlineprotected

Definition at line 69 of file ProductResolvers.h.

69 { return defaultStatus_; }

References defaultStatus_.

Referenced by productResolved_(), edm::PutOnReadInputProductResolver::putProduct(), edm::ProducedProductResolver::putProduct(), edm::DelayedReaderInputProductResolver::retrieveAndMerge_(), and edm::MergeableInputProductResolver::setOrMergeProduct().

◆ getProductData()

ProductData const& edm::DataManagingProductResolver::getProductData ( ) const

inlinefinalprotectedvirtual

Implements edm::DataManagingOrAliasProductResolver.

Definition at line 74 of file ProductResolvers.h.

74 { return productData_; }

References productData_.

Referenced by branchDescription_(), edm::MergeableInputProductResolver::mergeProduct(), productUnavailable_(), productWasFetchedAndIsValid_(), and resolveProductImpl().

◆ isFromCurrentProcess()

virtual bool edm::DataManagingProductResolver::isFromCurrentProcess ( ) const

privatepure virtual

Implemented in edm::ProducedProductResolver, edm::PutOnReadInputProductResolver, and edm::DelayedReaderInputProductResolver.

Referenced by productWasFetchedAndIsValid_().

◆ productProvenancePtr_()

ProductProvenance const * edm::DataManagingProductResolver::productProvenancePtr_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 588 of file ProductResolvers.cc.

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

References edm::Provenance::productProvenance(), and edm::ProductResolverBase::provenance().

◆ productResolved_()

bool edm::DataManagingProductResolver::productResolved_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 557 of file ProductResolvers.cc.

                                                            {
     auto s = status();
     return (s != defaultStatus()) or (s == ProductStatus::ProductDeleted);
   }

References defaultStatus(), or, ProductDeleted, alignCSCRings::s, and status().

◆ productUnavailable_()

bool edm::DataManagingProductResolver::productUnavailable_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 549 of file ProductResolvers.cc.

                                                               {
     auto presentStatus = status();
     if (presentStatus == ProductStatus::ProductSet) {
       return !(getProductData().wrapper()->isPresent());
     }
     return presentStatus != ProductStatus::ResolveNotRun;
   }

References getProductData(), edm::WrapperBase::isPresent(), ProductSet, ResolveNotRun, status(), and edm::ProductData::wrapper().

◆ productWasDeleted_()

bool edm::DataManagingProductResolver::productWasDeleted_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 563 of file ProductResolvers.cc.

563 { return status() == ProductStatus::ProductDeleted; }

References ProductDeleted, and status().

◆ productWasFetchedAndIsValid_()

bool edm::DataManagingProductResolver::productWasFetchedAndIsValid_ ( bool iSkipCurrentProcess ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 565 of file ProductResolvers.cc.

                                                                                                {
     if (iSkipCurrentProcess and isFromCurrentProcess()) {
       return false;
     }
     if (status() == ProductStatus::ProductSet) {
       if (getProductData().wrapper()->isPresent()) {
         return true;
       }
     }
     return false;
   }

References getProductData(), isFromCurrentProcess(), ProductSet, status(), and wrapper.

◆ provenance_()

Provenance const* edm::DataManagingProductResolver::provenance_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 92 of file ProductResolvers.h.

92 { return &productData_.provenance(); }

References productData_, and edm::ProductData::provenance().

◆ resetBranchDescription_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 89 of file ProductResolvers.h.

                                                                                   {
       productData_.resetBranchDescription(bd);
     }

References productData_, and edm::ProductData::resetBranchDescription().

◆ resetProductData_()

void edm::DataManagingProductResolver::resetProductData_ ( bool deleteEarly )

overridevirtual

Implements edm::DataManagingOrAliasProductResolver.

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

Definition at line 592 of file ProductResolvers.cc.

                                                                       {
     if (theStatus_ == ProductStatus::ProductSet) {
       productData_.resetProductData();
     }
     if (deleteEarly) {
       theStatus_ = ProductStatus::ProductDeleted;
     } else {
       resetStatus();
     }
   }

References productData_, ProductDeleted, ProductSet, edm::ProductData::resetProductData(), resetStatus(), and theStatus_.

Referenced by edm::DelayedReaderInputProductResolver::resetProductData_(), edm::PuttableProductResolver::resetProductData_(), and edm::UnscheduledProductResolver::resetProductData_().

◆ resetStatus()

void edm::DataManagingProductResolver::resetStatus ( )

inline

Definition at line 61 of file ProductResolvers.h.

61 { theStatus_ = defaultStatus_; }

References defaultStatus_, and theStatus_.

Referenced by resetProductData_().

◆ resolvedModuleLabel_()

std::string const& edm::DataManagingProductResolver::resolvedModuleLabel_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 94 of file ProductResolvers.h.

94 { return moduleLabel(); }

References edm::ProductResolverBase::moduleLabel().

◆ resolveProductImpl() [1/2]

template<bool callResolver, typename FUNC >

ProductResolverBase::Resolution edm::DataManagingProductResolver::resolveProductImpl ( FUNC resolver ) const

protected

Definition at line 48 of file ProductResolvers.cc.

                                                                                                    {
     if (productWasDeleted()) {
       throwProductDeletedException();
     }
     auto presentStatus = status();
  
     if (callResolver && presentStatus == ProductStatus::ResolveNotRun) {
       //if resolver fails because of exception or not setting product
       // make sure the status goes to failed
       auto failedStatusSetter = [this](ProductStatus* iPresentStatus) {
         if (this->status() == ProductStatus::ResolveNotRun) {
           this->setFailedStatus();
         }
         *iPresentStatus = this->status();
       };
       std::unique_ptr<ProductStatus, decltype(failedStatusSetter)> failedStatusGuard(&presentStatus,
                                                                                      failedStatusSetter);
  
       //If successful, this will call setProduct
       resolver();
     }
  
     if (presentStatus == ProductStatus::ProductSet) {
       auto pd = &getProductData();
       if (pd->wrapper()->isPresent()) {
         return Resolution(pd);
       }
     }
  
     return Resolution(nullptr);
   }

References getProductData(), ProductSet, edm::ProductResolverBase::productWasDeleted(), Resolution, ResolveNotRun, setFailedStatus(), status(), and throwProductDeletedException().

◆ resolveProductImpl() [2/2]

template<bool callResolver, typename FUNC >

Resolution edm::DataManagingProductResolver::resolveProductImpl ( FUNC resolver ) const

protected

◆ setFailedStatus()

void edm::DataManagingProductResolver::setFailedStatus ( ) const

inlineprotected

Definition at line 70 of file ProductResolvers.h.

70 { theStatus_ = ProductStatus::ResolveFailed; }

References ResolveFailed, and theStatus_.

Referenced by resolveProductImpl(), edm::DelayedReaderInputProductResolver::retrieveAndMerge_(), and setProduct().

◆ setMergeableRunProductMetadataInProductData()

void edm::DataManagingProductResolver::setMergeableRunProductMetadataInProductData ( MergeableRunProductMetadata const * mrpm )

protected

Definition at line 583 of file ProductResolvers.cc.

                                                {
     productData_.setMergeableRunProductMetadata(mrpm);
   }

References productData_, and edm::ProductData::setMergeableRunProductMetadata().

Referenced by edm::DelayedReaderInputProductResolver::setMergeableRunProductMetadata_().

◆ setProduct() [1/2]

void edm::DataManagingProductResolver::setProduct ( std::shared_ptr< WrapperBase > edp ) const

protected

Definition at line 536 of file ProductResolvers.cc.

                                                                                    {
     if (edp) {
       checkType(*edp);
       productData_.unsafe_setWrapper(std::move(edp));
       theStatus_ = ProductStatus::ProductSet;
     } else {
       setFailedStatus();
     }
   }

References checkType(), eostools::move(), productData_, ProductSet, setFailedStatus(), theStatus_, and edm::ProductData::unsafe_setWrapper().

◆ setProduct() [2/2]

void edm::DataManagingProductResolver::setProduct ( std::unique_ptr< WrapperBase > edp ) const

protected

Definition at line 527 of file ProductResolvers.cc.

                                                                                    {
     if (edp) {
       checkType(*edp);
       productData_.unsafe_setWrapper(std::move(edp));
       theStatus_ = ProductStatus::ProductSet;
     } else {
       setFailedStatus();
     }
   }

References checkType(), eostools::move(), productData_, ProductSet, setFailedStatus(), theStatus_, and edm::ProductData::unsafe_setWrapper().

Referenced by edm::MergeableInputProductResolver::mergeProduct(), edm::DelayedReaderInputProductResolver::prefetchAsync_(), edm::PutOnReadInputProductResolver::putProduct(), edm::ProducedProductResolver::putProduct(), edm::DelayedReaderInputProductResolver::resolveProduct_(), and edm::MergeableInputProductResolver::setOrMergeProduct().

◆ setProductID_()

void edm::DataManagingProductResolver::setProductID_ ( ProductID const & pid )

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 581 of file ProductResolvers.cc.

581 { productData_.setProductID(pid); }

References productData_, and edm::ProductData::setProductID().

◆ setProductProvenanceRetriever_()

void edm::DataManagingProductResolver::setProductProvenanceRetriever_ ( ProductProvenanceRetriever const * provRetriever )

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 577 of file ProductResolvers.cc.

                                                                                                                   {
     productData_.setProvenance(provRetriever);
   }

References productData_, and edm::ProductData::setProvenance().

◆ singleProduct_()

bool edm::DataManagingProductResolver::singleProduct_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 603 of file ProductResolvers.cc.

603 { return true; }

◆ status()

ProductStatus edm::DataManagingProductResolver::status ( void ) const

inlineprotected

Definition at line 68 of file ProductResolvers.h.

68 { return theStatus_; }

References theStatus_.

Referenced by edm::MergeableInputProductResolver::mergeProduct(), productResolved_(), productUnavailable_(), productWasDeleted_(), productWasFetchedAndIsValid_(), edm::PutOnReadInputProductResolver::putProduct(), edm::ProducedProductResolver::putProduct(), resolveProductImpl(), edm::DelayedReaderInputProductResolver::retrieveAndMerge_(), edm::MergeableInputProductResolver::setOrMergeProduct(), and edm::UnscheduledProductResolver::unscheduledWasNotRun_().

◆ throwProductDeletedException()

void edm::DataManagingProductResolver::throwProductDeletedException ( ) const

private

Definition at line 34 of file ProductResolvers.cc.

                                                                        {
     ProductDeletedException exception;
     exception << "DataManagingProductResolver::resolveProduct_: The product matching all criteria was already deleted\n"
               << "Looking for type: " << branchDescription().unwrappedTypeID() << "\n"
               << "Looking for module label: " << moduleLabel() << "\n"
               << "Looking for productInstanceName: " << productInstanceName() << "\n"
               << (processName().empty() ? "" : "Looking for process: ") << processName() << "\n"
               << "This means there is a configuration error.\n"
               << "The module which is asking for this data must be configured to state that it will read this data.";
     throw exception;
   }

References edm::ProductResolverBase::branchDescription(), cppFunctionSkipper::exception, edm::ProductResolverBase::moduleLabel(), edm::ProductResolverBase::processName(), edm::ProductResolverBase::productInstanceName(), and edm::BranchDescription::unwrappedTypeID().

Referenced by resolveProductImpl().

Member Data Documentation

◆ defaultStatus_

const ProductStatus edm::DataManagingProductResolver::defaultStatus_

private

Definition at line 102 of file ProductResolvers.h.

Referenced by defaultStatus(), and resetStatus().

◆ productData_

ProductData edm::DataManagingProductResolver::productData_

private

Definition at line 100 of file ProductResolvers.h.

Referenced by edm::SwitchBaseProductResolver::branchDescription_(), getProductData(), edm::SwitchBaseProductResolver::getProductData(), provenance_(), edm::SwitchBaseProductResolver::provenance_(), resetBranchDescription_(), edm::SwitchBaseProductResolver::resetBranchDescription_(), resetProductData_(), setMergeableRunProductMetadataInProductData(), setProduct(), setProductID_(), and setProductProvenanceRetriever_().

◆ theStatus_

std::atomic<ProductStatus> edm::DataManagingProductResolver::theStatus_

mutableprivate

Definition at line 101 of file ProductResolvers.h.

Referenced by resetProductData_(), resetStatus(), setFailedStatus(), setProduct(), and status().

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Enumeration Documentation

◆ ProductStatus

Constructor & Destructor Documentation

◆ DataManagingProductResolver()

Member Function Documentation

◆ branchDescription_()

◆ checkType()

◆ connectTo()

◆ defaultStatus()

◆ getProductData()

◆ isFromCurrentProcess()

◆ productProvenancePtr_()

◆ productResolved_()

◆ productUnavailable_()

◆ productWasDeleted_()

◆ productWasFetchedAndIsValid_()

◆ provenance_()

◆ resetBranchDescription_()

◆ resetProductData_()

◆ resetStatus()

◆ resolvedModuleLabel_()

◆ resolveProductImpl() [1/2]

◆ resolveProductImpl() [2/2]

◆ setFailedStatus()

◆ setMergeableRunProductMetadataInProductData()

◆ setProduct() [1/2]

◆ setProduct() [2/2]

◆ setProductID_()

◆ setProductProvenanceRetriever_()

◆ singleProduct_()

◆ status()

◆ throwProductDeletedException()

Member Data Documentation

◆ defaultStatus_

◆ productData_

◆ theStatus_