CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Types | Public Member Functions | Private Member Functions | Private Attributes
edm::ParentProcessProductResolver Class Reference

#include <ProductResolvers.h>

Inheritance diagram for edm::ParentProcessProductResolver:
edm::ProductResolverBase

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

Private Member Functions

BranchDescription const & branchDescription_ () const override
 
void prefetchAsync_ (WaitingTaskHolder 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 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 410 of file ProductResolvers.h.

Member Typedef Documentation

Definition at line 412 of file ProductResolvers.h.

Constructor & Destructor Documentation

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

Definition at line 413 of file ProductResolvers.h.

414  : ProductResolverBase(), realProduct_(nullptr), bd_(bd), provRetriever_(nullptr), parentPrincipal_(nullptr) {}
std::shared_ptr< BranchDescription const > bd_
ProductProvenanceRetriever const * provRetriever_
ProductResolverBase const * realProduct_

Member Function Documentation

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

Implements edm::ProductResolverBase.

Definition at line 464 of file ProductResolvers.h.

464 { return *bd_; }
std::shared_ptr< BranchDescription const > bd_
void edm::ParentProcessProductResolver::connectTo ( ProductResolverBase const &  iOther,
Principal const *  iParentPrincipal 
)
inlinefinalvirtual

Implements edm::ProductResolverBase.

Definition at line 416 of file ProductResolvers.h.

416  {
417  realProduct_ = &iOther;
418  parentPrincipal_ = iParentPrincipal;
419  };
ProductResolverBase const * realProduct_
void edm::ParentProcessProductResolver::prefetchAsync_ ( WaitingTaskHolder  waitTask,
Principal const &  principal,
bool  skipCurrentProcess,
ServiceToken const &  token,
SharedResourcesAcquirer sra,
ModuleCallingContext const *  mcc 
) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 435 of file ProductResolvers.h.

References edm::Principal::branchType(), edm::ParentContext::globalContext(), edm::InProcess, edm::GlobalContext::kBeginProcessBlock, edm::GlobalContext::kEndProcessBlock, edm::ModuleCallingContext::parent(), and edm::GlobalContext::transition().

440  {
441  if (principal.branchType() == InProcess &&
442  (mcc->parent().globalContext()->transition() == GlobalContext::Transition::kBeginProcessBlock ||
443  mcc->parent().globalContext()->transition() == GlobalContext::Transition::kEndProcessBlock)) {
444  return;
445  }
446 
447  skipCurrentProcess = false;
448  realProduct_->prefetchAsync(waitTask, *parentPrincipal_, skipCurrentProcess, token, sra, mcc);
449  }
void prefetchAsync(WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
ProductResolverBase const * realProduct_
ProductProvenance const * edm::ParentProcessProductResolver::productProvenancePtr_ ( ) const
overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 827 of file ProductResolvers.cc.

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

827  {
828  return provRetriever_ ? provRetriever_->branchIDToProvenance(bd_->originalBranchID()) : nullptr;
829  }
std::shared_ptr< BranchDescription const > bd_
ProductProvenance const * branchIDToProvenance(BranchID const &bid) const
ProductProvenanceRetriever const * provRetriever_
bool edm::ParentProcessProductResolver::productResolved_ ( ) const
inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 457 of file ProductResolvers.h.

457 { return realProduct_->productResolved(); }
ProductResolverBase const * realProduct_
bool edm::ParentProcessProductResolver::productUnavailable_ ( ) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 456 of file ProductResolvers.h.

456 { return realProduct_->productUnavailable(); }
ProductResolverBase const * realProduct_
bool edm::ParentProcessProductResolver::productWasDeleted_ ( ) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 458 of file ProductResolvers.h.

458 { return realProduct_->productWasDeleted(); }
ProductResolverBase const * realProduct_
bool edm::ParentProcessProductResolver::productWasFetchedAndIsValid_ ( bool  iSkipCurrentProcess) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 459 of file ProductResolvers.h.

459  {
460  iSkipCurrentProcess = false;
461  return realProduct_->productWasFetchedAndIsValid(iSkipCurrentProcess);
462  }
ProductResolverBase const * realProduct_
bool productWasFetchedAndIsValid(bool iSkipCurrentProcess) const
Provenance const* edm::ParentProcessProductResolver::provenance_ ( ) const
inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 466 of file ProductResolvers.h.

466 { return realProduct_->provenance(); }
Provenance const * provenance() const
ProductResolverBase const * realProduct_
void edm::ParentProcessProductResolver::resetBranchDescription_ ( std::shared_ptr< BranchDescription const >  bd)
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 465 of file ProductResolvers.h.

465 { bd_ = bd; }
std::shared_ptr< BranchDescription const > bd_
deep_tau::DeepTauBase::BasicDiscriminator bd
Definition: DeepTauId.cc:1082
void edm::ParentProcessProductResolver::resetProductData_ ( bool  deleteEarly)
overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 831 of file ProductResolvers.cc.

831 {}
std::string const& edm::ParentProcessProductResolver::resolvedModuleLabel_ ( ) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 467 of file ProductResolvers.h.

467 { return realProduct_->moduleLabel(); }
ProductResolverBase const * realProduct_
std::string const & moduleLabel() const
Resolution edm::ParentProcessProductResolver::resolveProduct_ ( Principal const &  principal,
bool  skipCurrentProcess,
SharedResourcesAcquirer sra,
ModuleCallingContext const *  mcc 
) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 422 of file ProductResolvers.h.

References edm::Principal::branchType(), edm::ParentContext::globalContext(), edm::InProcess, edm::GlobalContext::kBeginProcessBlock, edm::GlobalContext::kEndProcessBlock, edm::ModuleCallingContext::parent(), Resolution, and edm::GlobalContext::transition().

425  {
426  if (principal.branchType() == InProcess &&
427  (mcc->parent().globalContext()->transition() == GlobalContext::Transition::kBeginProcessBlock ||
428  mcc->parent().globalContext()->transition() == GlobalContext::Transition::kEndProcessBlock)) {
429  return Resolution(nullptr);
430  }
431 
432  skipCurrentProcess = false;
433  return realProduct_->resolveProduct(*parentPrincipal_, skipCurrentProcess, sra, mcc);
434  }
Resolution resolveProduct(Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
ProductResolverBase const * realProduct_
void edm::ParentProcessProductResolver::setProductID_ ( ProductID const &  pid)
overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 825 of file ProductResolvers.cc.

825 {}
void edm::ParentProcessProductResolver::setProductProvenanceRetriever_ ( ProductProvenanceRetriever const *  provRetriever)
overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 821 of file ProductResolvers.cc.

References provRetriever_.

821  {
822  provRetriever_ = provRetriever;
823  }
ProductProvenanceRetriever const * provRetriever_
bool edm::ParentProcessProductResolver::singleProduct_ ( ) const
overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 833 of file ProductResolvers.cc.

833 { return true; }
void edm::ParentProcessProductResolver::throwNullRealProduct ( ) const
private

Definition at line 835 of file ProductResolvers.cc.

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

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

Implements edm::ProductResolverBase.

Definition at line 450 of file ProductResolvers.h.

450  {
451  if (realProduct_)
454  return false;
455  }
ProductResolverBase const * realProduct_

Member Data Documentation

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

Definition at line 476 of file ProductResolvers.h.

Referenced by productProvenancePtr_().

Principal const* edm::ParentProcessProductResolver::parentPrincipal_
private

Definition at line 478 of file ProductResolvers.h.

ProductProvenanceRetriever const* edm::ParentProcessProductResolver::provRetriever_
private

Definition at line 477 of file ProductResolvers.h.

Referenced by productProvenancePtr_(), and setProductProvenanceRetriever_().

ProductResolverBase const* edm::ParentProcessProductResolver::realProduct_
private

Definition at line 475 of file ProductResolvers.h.