#include <ProductResolvers.h>

Inheritance diagram for edm::ParentProcessProductResolver:

Public Types
typedef ProducedProductResolver::ProductStatus	ProductStatus

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

	ParentProcessProductResolver (std::shared_ptr< BranchDescription const > bd)

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

std::string const &	moduleLabel () const

ProductResolverBase &	operator= (ProductResolverBase const &)=delete

void	prefetchAsync (WaitingTask 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	putOrMergeProduct (std::unique_ptr< WrapperBase > edp, MergeableRunProductMetadata const *mergeableRunProductMetadata=nullptr) const

void	putProduct (std::unique_ptr< WrapperBase > edp) 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 ()

Private Member Functions
BranchDescription const &	branchDescription_ () const override

void	prefetchAsync_ (WaitingTask waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer sra, ModuleCallingContext const *mcc) const override

ProductProvenance const *	productProvenancePtr_ () const override

bool	productResolved_ () const final

bool	productUnavailable_ () const override

bool	productWasDeleted_ () const override

bool	productWasFetchedAndIsValid_ (bool iSkipCurrentProcess) const override

Provenance const *	provenance_ () const final

void	putOrMergeProduct_ (std::unique_ptr< WrapperBase > prod, MergeableRunProductMetadata const *mergeableRunProductMetadata) const final

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

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

void	resetProductData_ (bool deleteEarly) override

std::string const &	resolvedModuleLabel_ () const override

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

void	setProductID_ (ProductID const &pid) override

void	setProductProvenanceRetriever_ (ProductProvenanceRetriever const *provRetriever) override

bool	singleProduct_ () const override

void	throwNullRealProduct () const

bool	unscheduledWasNotRun_ () const override

Private Attributes
std::shared_ptr< BranchDescription const >	bd_

Principal const *	parentPrincipal_

ProductProvenanceRetriever const *	provRetriever_

ProductResolverBase const *	realProduct_

Detailed Description

Definition at line 369 of file ProductResolvers.h.

Member Typedef Documentation

◆ ProductStatus

typedef ProducedProductResolver::ProductStatus edm::ParentProcessProductResolver::ProductStatus

Definition at line 371 of file ProductResolvers.h.

Constructor & Destructor Documentation

◆ ParentProcessProductResolver()

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

inlineexplicit

Definition at line 372 of file ProductResolvers.h.

373 : ProductResolverBase(), realProduct_(nullptr), bd_(bd), provRetriever_(nullptr), parentPrincipal_(nullptr) {}

Member Function Documentation

◆ branchDescription_()

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 414 of file ProductResolvers.h.

414 { return *bd_; }

◆ connectTo()

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

inlinefinalvirtual

Implements edm::ProductResolverBase.

Definition at line 375 of file ProductResolvers.h.

                                                                                                {
       realProduct_ = &iOther;
       parentPrincipal_ = iParentPrincipal;
     };

◆ prefetchAsync_()

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 388 of file ProductResolvers.h.

                                                                         {
       skipCurrentProcess = false;
       realProduct_->prefetchAsync(waitTask, *parentPrincipal_, skipCurrentProcess, token, sra, mcc);
     }

References unpackBuffers-CaloStage2::token.

◆ productProvenancePtr_()

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 810 of file ProductResolvers.cc.

                                                                                      {
     return provRetriever_ ? provRetriever_->branchIDToProvenance(bd_->originalBranchID()) : nullptr;
   }

References bd_, edm::ProductProvenanceRetriever::branchIDToProvenance(), and provRetriever_.

◆ productResolved_()

bool edm::ParentProcessProductResolver::productResolved_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 404 of file ProductResolvers.h.

404 { return realProduct_->productResolved(); }

◆ productUnavailable_()

bool edm::ParentProcessProductResolver::productUnavailable_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 403 of file ProductResolvers.h.

403 { return realProduct_->productUnavailable(); }

◆ productWasDeleted_()

bool edm::ParentProcessProductResolver::productWasDeleted_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 405 of file ProductResolvers.h.

405 { return realProduct_->productWasDeleted(); }

◆ productWasFetchedAndIsValid_()

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 406 of file ProductResolvers.h.

                                                                                {
       iSkipCurrentProcess = false;
       return realProduct_->productWasFetchedAndIsValid(iSkipCurrentProcess);
     }

◆ provenance_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 416 of file ProductResolvers.h.

416 { return realProduct_->provenance(); }

◆ putOrMergeProduct_()

void edm::ParentProcessProductResolver::putOrMergeProduct_	(	std::unique_ptr< WrapperBase >	prod,
		MergeableRunProductMetadata const *	mergeableRunProductMetadata
	)		const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 824 of file ProductResolvers.cc.

                                                                                                   {
     throw Exception(errors::LogicError)
         << "ParentProcessProductResolver::putOrMergeProduct_(std::unique_ptr<WrapperBase> edp, "
            "MergeableRunProductMetadata const*) not implemented and should never be called.\n"
         << "Contact a Framework developer\n";
   }

References Exception, and edm::errors::LogicError.

◆ putProduct_()

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 818 of file ProductResolvers.cc.

                                                                                  {
     throw Exception(errors::LogicError)
         << "ParentProcessProductResolver::putProduct_() not implemented and should never be called.\n"
         << "Contact a Framework developer\n";
   }

References Exception, and edm::errors::LogicError.

◆ resetBranchDescription_()

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 415 of file ProductResolvers.h.

415 { bd_ = bd; }

◆ resetProductData_()

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 814 of file ProductResolvers.cc.

814 {}

◆ resolvedModuleLabel_()

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 417 of file ProductResolvers.h.

417 { return realProduct_->moduleLabel(); }

◆ resolveProduct_()

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 381 of file ProductResolvers.h.

                                                                                {
       skipCurrentProcess = false;
       return realProduct_->resolveProduct(*parentPrincipal_, skipCurrentProcess, sra, mcc);
     }

◆ setProductID_()

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 808 of file ProductResolvers.cc.

808 {}

◆ setProductProvenanceRetriever_()

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 804 of file ProductResolvers.cc.

                                                                                                                    {
     provRetriever_ = provRetriever;
   }

References provRetriever_.

◆ singleProduct_()

bool edm::ParentProcessProductResolver::singleProduct_ ( ) const

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 816 of file ProductResolvers.cc.

816 { return true; }

◆ throwNullRealProduct()

void edm::ParentProcessProductResolver::throwNullRealProduct ( ) const

private

Definition at line 832 of file ProductResolvers.cc.

                                                                 {
     // In principle, this ought to be fixed. I noticed one hits this error
     // when in a SubProcess and calling the Event::getProvenance function
     // with a BranchID to a branch from an earlier SubProcess or the top
     // level process and this branch is not kept in this SubProcess. It might
     // be possible to hit this in other contexts. I say it ought to be
     // fixed because one does not encounter this issue if the SubProcesses
     // are split into genuinely different processes (in principle that
     // ought to give identical behavior and results). No user has ever
     // reported this issue which has been around for some time and it was only
     // noticed when testing some rare corner cases after modifying Core code.
     // After discussing this with Chris we decided that at least for the moment
     // there are higher priorities than fixing this ... I converted it so it
     // causes an exception instead of a seg fault. The issue that may need to
     // be addressed someday is how ProductResolvers for non-kept branches are
     // connected to earlier SubProcesses.
     throw Exception(errors::LogicError)
         << "ParentProcessProductResolver::throwNullRealProduct RealProduct pointer not set in this context.\n"
         << "Contact a Framework developer\n";
   }

References Exception, and edm::errors::LogicError.

◆ unscheduledWasNotRun_()

bool edm::ParentProcessProductResolver::unscheduledWasNotRun_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 397 of file ProductResolvers.h.

                                                 {
       if (realProduct_)
         return realProduct_->unscheduledWasNotRun();
       throwNullRealProduct();
       return false;
     }

Member Data Documentation

◆ bd_

std::shared_ptr<BranchDescription const> edm::ParentProcessProductResolver::bd_

private

Definition at line 426 of file ProductResolvers.h.

Referenced by productProvenancePtr_().

◆ parentPrincipal_

Principal const* edm::ParentProcessProductResolver::parentPrincipal_

private

Definition at line 428 of file ProductResolvers.h.

◆ provRetriever_

ProductProvenanceRetriever const* edm::ParentProcessProductResolver::provRetriever_

private

Definition at line 427 of file ProductResolvers.h.

Referenced by productProvenancePtr_(), and setProductProvenanceRetriever_().

◆ realProduct_

ProductResolverBase const* edm::ParentProcessProductResolver::realProduct_

private

Definition at line 425 of file ProductResolvers.h.

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ ProductStatus

Constructor & Destructor Documentation

◆ ParentProcessProductResolver()

Member Function Documentation

◆ branchDescription_()

◆ connectTo()

◆ prefetchAsync_()

◆ productProvenancePtr_()

◆ productResolved_()

◆ productUnavailable_()

◆ productWasDeleted_()

◆ productWasFetchedAndIsValid_()

◆ provenance_()

◆ putOrMergeProduct_()

◆ putProduct_()

◆ resetBranchDescription_()

◆ resetProductData_()

◆ resolvedModuleLabel_()

◆ resolveProduct_()

◆ setProductID_()

◆ setProductProvenanceRetriever_()

◆ singleProduct_()

◆ throwNullRealProduct()

◆ unscheduledWasNotRun_()

Member Data Documentation

◆ bd_

◆ parentPrincipal_

◆ provRetriever_

◆ realProduct_