#include <ProductResolvers.h>

Inheritance diagram for edm::PutOnReadInputProductResolver:

Public Member Functions
	PutOnReadInputProductResolver (std::shared_ptr< BranchDescription const > bd)

Public Member Functions inherited from edm::MergeableInputProductResolver
	MergeableInputProductResolver (std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)

Public Member Functions inherited from edm::DataManagingProductResolver
void	connectTo (ProductResolverBase const &, Principal const *) final

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

void	resetProductData_ (bool deleteEarly) override

void	resetStatus ()

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

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

Public Member Functions inherited from edm::ProductPutterBase
	ProductPutterBase ()=default

virtual	~ProductPutterBase ()=default

Public Member Functions inherited from edm::ProductPutOrMergerBase
	ProductPutOrMergerBase ()=default

virtual	~ProductPutOrMergerBase ()=default

Protected Member Functions
void	prefetchAsync_ (WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer sra, ModuleCallingContext const mcc) const final

void	putOrMergeProduct (std::unique_ptr< WrapperBase > prod) const override

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

Resolution	resolveProduct_ (Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer sra, ModuleCallingContext const mcc) const final

bool	unscheduledWasNotRun_ () const final

Protected Member Functions inherited from edm::MergeableInputProductResolver
void	mergeProduct (std::shared_ptr< WrapperBase > edp, MergeableRunProductMetadata const *) const

void	setOrMergeProduct (std::shared_ptr< WrapperBase > prod, MergeableRunProductMetadata const *mergeableRunProductMetadata) const

Protected Member Functions inherited from edm::DataManagingProductResolver
void	checkType (WrapperBase const &prod) const

ProductStatus	defaultStatus () const

ProductData const &	getProductData () const final

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

void	setFailedStatus () const

void	setMergeableRunProductMetadataInProductData (MergeableRunProductMetadata const *)

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

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

ProductStatus	status () const

Private Member Functions
bool	isFromCurrentProcess () const final

Additional Inherited Members
Public Types inherited from edm::DataManagingProductResolver
enum	ProductStatus { ProductStatus::ProductSet, ProductStatus::NotPut, ProductStatus::ResolveFailed, ProductStatus::ResolveNotRun, ProductStatus::ProductDeleted }

Detailed Description

Definition at line 157 of file ProductResolvers.h.

Constructor & Destructor Documentation

edm::PutOnReadInputProductResolver::PutOnReadInputProductResolver ( std::shared_ptr< BranchDescription const > bd )

inline

Definition at line 161 of file ProductResolvers.h.

References cms::cuda::assert().

         : MergeableInputProductResolver(bd, ProductStatus::ResolveNotRun) {
       assert(not bd->produced());
       assert(not bd->onDemand());
     }

Member Function Documentation

bool edm::PutOnReadInputProductResolver::isFromCurrentProcess ( ) const

finalprivatevirtual

Implements edm::DataManagingProductResolver.

Definition at line 359 of file ProductResolvers.cc.

359 { return false; }

void edm::PutOnReadInputProductResolver::prefetchAsync_	(	WaitingTaskHolder	waitTask,
		Principal const &	principal,
		bool	skipCurrentProcess,
		ServiceToken const &	token,
		SharedResourcesAcquirer *	sra,
		ModuleCallingContext const *	mcc
	)		const

finalprotectedvirtual

Implements edm::ProductResolverBase.

Definition at line 368 of file ProductResolvers.cc.

373 {}

void edm::PutOnReadInputProductResolver::putOrMergeProduct ( std::unique_ptr< WrapperBase > prod ) const

overrideprotectedvirtual

Implements edm::ProductPutOrMergerBase.

Definition at line 375 of file ProductResolvers.cc.

References eostools::move(), and edm::MergeableInputProductResolver::setOrMergeProduct().

                                                                                             {
     setOrMergeProduct(std::move(edp), nullptr);
   }

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

overrideprotectedvirtual

Implements edm::ProductPutterBase.

Definition at line 350 of file ProductResolvers.cc.

References edm::ProductResolverBase::branchDescription(), edm::BranchDescription::branchName(), edm::DataManagingProductResolver::defaultStatus(), Exception, edm::errors::InsertFailure, eostools::move(), edm::DataManagingProductResolver::setProduct(), and edm::DataManagingProductResolver::status().

                                                                                      {
     if (status() != defaultStatus()) {
       throw Exception(errors::InsertFailure)
           << "Attempt to insert more than one product on branch " << branchDescription().branchName() << "\n";
     }
 
     setProduct(std::move(edp));  // ProductResolver takes ownership
   }

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

finalprotectedvirtual

Implements edm::ProductResolverBase.

Definition at line 361 of file ProductResolvers.cc.

                                                                                                                     {
     return resolveProductImpl<false>([]() { return; });
   }

bool edm::PutOnReadInputProductResolver::unscheduledWasNotRun_ ( ) const

inlinefinalprotectedvirtual

Implements edm::ProductResolverBase.

Definition at line 181 of file ProductResolvers.h.

181 { return false; }

Public Member Functions

Protected Member Functions

Private Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation