edm::ParentProcessProductResolver Class Reference

#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	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
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	setProcessHistory_ (ProcessHistory const &ph) override
void	setProvenance_ (ProductProvenanceRetriever const *provRetriever, ProcessHistory const &ph, ProductID const &pid) 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 256 of file ProductResolvers.h.

Member Typedef Documentation

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

Definition at line 258 of file ProductResolvers.h.

Constructor & Destructor Documentation

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

inlineexplicit

Definition at line 259 of file ProductResolvers.h.

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

Member Function Documentation

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 298 of file ProductResolvers.h.

{return *bd_;}

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

inlinefinalvirtual

Implements edm::ProductResolverBase.

Definition at line 261 of file ProductResolvers.h.

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

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 274 of file ProductResolvers.h.

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

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 666 of file ProductResolvers.cc.

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

bool edm::ParentProcessProductResolver::productResolved_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 289 of file ProductResolvers.h.

{ return realProduct_->productResolved(); }

bool edm::ParentProcessProductResolver::productUnavailable_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 288 of file ProductResolvers.h.

{return realProduct_->productUnavailable();}

bool edm::ParentProcessProductResolver::productWasDeleted_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 290 of file ProductResolvers.h.

{return realProduct_->productWasDeleted();}

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 291 of file ProductResolvers.h.

References parseEventContent::prod, edm::DataManagingProductResolver::putOrMergeProduct_(), and edm::ProductResolverBase::putProduct_().

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

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 300 of file ProductResolvers.h.

                                                {return realProduct_->provenance();
    }

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

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 683 of file ProductResolvers.cc.

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

                                                                                                                                {
    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";
  }

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 677 of file ProductResolvers.cc.

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

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

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 299 of file ProductResolvers.h.

{bd_ = bd;}

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 670 of file ProductResolvers.cc.

                                                                       {
  }

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 302 of file ProductResolvers.h.

References sysUtil::pid, edm::DataManagingProductResolver::productProvenancePtr_(), edm::DataManagingProductResolver::resetProductData_(), edm::DataManagingProductResolver::setProcessHistory_(), edm::DataManagingProductResolver::setProvenance_(), and edm::DataManagingProductResolver::singleProduct_().

{return realProduct_->moduleLabel();}

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

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 267 of file ProductResolvers.h.

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

void edm::ParentProcessProductResolver::setProcessHistory_ ( ProcessHistory const &  ph )

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 663 of file ProductResolvers.cc.

                                                                                {
  }

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 659 of file ProductResolvers.cc.

                                                                                                                                                   {
    provRetriever_ = provRetriever;
  }

bool edm::ParentProcessProductResolver::singleProduct_ ( ) const

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 673 of file ProductResolvers.cc.

                                                          {
    return true;
  }

void edm::ParentProcessProductResolver::throwNullRealProduct ( ) const

private

Definition at line 689 of file ProductResolvers.cc.

References Exception, edm::errors::LogicError, and edm::NoProcessProductResolver::NoProcessProductResolver().

                                                                {
    // 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";
  }

bool edm::ParentProcessProductResolver::unscheduledWasNotRun_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 283 of file ProductResolvers.h.

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

Member Data Documentation

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

private

Definition at line 311 of file ProductResolvers.h.

Principal const* edm::ParentProcessProductResolver::parentPrincipal_

private

Definition at line 313 of file ProductResolvers.h.

ProductProvenanceRetriever const* edm::ParentProcessProductResolver::provRetriever_

private

Definition at line 312 of file ProductResolvers.h.

ProductResolverBase const* edm::ParentProcessProductResolver::realProduct_

private

Definition at line 310 of file ProductResolvers.h.