#include <ProductResolvers.h>
Public Types | |
enum | ProductStatus { ProductStatus::ProductSet, ProductStatus::NotPut, ProductStatus::ResolveFailed, ProductStatus::ResolveNotRun, ProductStatus::ProductDeleted } |
Protected Member Functions | |
ProductStatus | defaultStatus () const |
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 |
ProductStatus | status () const |
Private Member Functions | |
BranchDescription const & | branchDescription_ () const final |
void | checkType (WrapperBase const &prod) const |
ProductData const & | getProductData () const |
virtual bool | isFromCurrentProcess () const =0 |
void | mergeProduct (std::unique_ptr< WrapperBase > edp, MergeableRunProductMetadata const *) const |
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 | putOrMergeProduct_ (std::unique_ptr< WrapperBase > prod, MergeableRunProductMetadata const *mergeableRunProductMetadata) const final |
void | resetBranchDescription_ (std::shared_ptr< BranchDescription const > bd) final |
std::string const & | resolvedModuleLabel_ () const final |
void | setProcessHistory_ (ProcessHistory const &ph) final |
void | setProvenance_ (ProductProvenanceRetriever const *provRetriever, ProcessHistory const &ph, ProductID const &pid) final |
bool | singleProduct_ () const final |
void | throwProductDeletedException () const |
Private Attributes | |
ProductStatus const | defaultStatus_ |
ProductData | productData_ |
std::atomic< ProductStatus > | theStatus_ |
Definition at line 44 of file ProductResolvers.h.
|
strong |
Enumerator | |
---|---|
ProductSet | |
NotPut | |
ResolveFailed | |
ResolveNotRun | |
ProductDeleted |
Definition at line 46 of file ProductResolvers.h.
|
inline |
Definition at line 48 of file ProductResolvers.h.
References edm::ProductResolverBase::connectTo().
|
inlinefinalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 85 of file ProductResolvers.h.
Referenced by mergeProduct().
|
private |
Definition at line 489 of file ProductResolvers.cc.
References edm::ProductResolverBase::branchDescription(), edm::BranchDescription::branchName(), edm::BranchDescription::className(), edm::WrapperBase::dynamicTypeInfo(), edm::errors::EventCorruption, Exception, edm::TypeWithDict::unvalidatedTypeInfo(), and edm::BranchDescription::unwrappedType().
Referenced by mergeProduct(), and setProduct().
|
finalvirtual |
Implements edm::ProductResolverBase.
Definition at line 474 of file ProductResolvers.cc.
|
inlineprotected |
Definition at line 63 of file ProductResolvers.h.
Referenced by productResolved_(), putOrMergeProduct_(), edm::ProducedProductResolver::putProduct_(), and edm::InputProductResolver::retrieveAndMerge_().
|
inlineprivate |
Definition at line 73 of file ProductResolvers.h.
References edm::ProductResolverBase::productResolved_(), edm::ProductResolverBase::productUnavailable_(), edm::ProductResolverBase::productWasDeleted_(), edm::ProductResolverBase::productWasFetchedAndIsValid_(), and edm::ProductResolverBase::putOrMergeProduct_().
Referenced by mergeProduct(), productUnavailable_(), productWasFetchedAndIsValid_(), and resolveProductImpl().
|
privatepure virtual |
Implemented in edm::ProducedProductResolver, and edm::InputProductResolver.
Referenced by productWasFetchedAndIsValid_().
|
private |
Definition at line 77 of file ProductResolvers.cc.
References edm::ProductResolverBase::branchDescription(), branchDescription_(), edm::BranchDescription::branchName(), edm::BranchDescription::branchType(), checkType(), Exception, edm::MergeableRunProductMetadata::getMergeDecision(), getProductData(), edm::InRun, edm::MergeableRunProductMetadata::MERGE, edm::errors::MismatchedInputFiles, eostools::move(), definitions::original, edm::BranchDescription::processName(), ProductSet, edm::MergeableRunProductMetadata::REPLACE, ResolveFailed, setProduct(), status(), and edm::ProductData::unsafe_wrapper().
Referenced by putOrMergeProduct_().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 554 of file ProductResolvers.cc.
References edm::Provenance::productProvenance(), and edm::ProductResolverBase::provenance().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 521 of file ProductResolvers.cc.
References defaultStatus(), or, ProductDeleted, alignCSCRings::s, and status().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 513 of file ProductResolvers.cc.
References getProductData(), edm::WrapperBase::isPresent(), ProductSet, ResolveNotRun, status(), and edm::ProductData::wrapper().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 527 of file ProductResolvers.cc.
References ProductDeleted, and status().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 529 of file ProductResolvers.cc.
References getProductData(), isFromCurrentProcess(), ProductSet, status(), and wrapper.
|
inlinefinalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 89 of file ProductResolvers.h.
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 476 of file ProductResolvers.cc.
References defaultStatus(), mergeProduct(), eostools::move(), edm::ProductResolverBase::putProduct(), and status().
|
inlinefinalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 86 of file ProductResolvers.h.
|
overridevirtual |
Implements edm::DataManagingOrAliasProductResolver.
Reimplemented in edm::UnscheduledProductResolver, edm::PuttableProductResolver, and edm::InputProductResolver.
Definition at line 558 of file ProductResolvers.cc.
References productData_, ProductDeleted, ProductSet, edm::ProductData::resetProductData(), resetStatus(), and theStatus_.
Referenced by edm::InputProductResolver::resetProductData_(), edm::PuttableProductResolver::resetProductData_(), and edm::UnscheduledProductResolver::resetProductData_().
|
inline |
Definition at line 56 of file ProductResolvers.h.
References edm::DataManagingOrAliasProductResolver::resetProductData_().
Referenced by resetProductData_().
|
inlinefinalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 91 of file ProductResolvers.h.
References edm::ProductResolverBase::moduleLabel(), sysUtil::pid, edm::ProductResolverBase::productProvenancePtr_(), edm::ProductResolverBase::setProcessHistory_(), edm::ProductResolverBase::setProvenance_(), and edm::ProductResolverBase::singleProduct_().
ProductResolverBase::Resolution edm::DataManagingProductResolver::resolveProductImpl | ( | FUNC | resolver | ) | const |
Definition at line 45 of file ProductResolvers.cc.
References getProductData(), ProductSet, edm::ProductResolverBase::productWasDeleted(), Resolution, ResolveNotRun, setFailedStatus(), status(), and throwProductDeletedException().
|
protected |
|
inlineprotected |
Definition at line 64 of file ProductResolvers.h.
References createPayload::checkType, parseEventContent::prod, and edm::throwProductDeletedException().
Referenced by resolveProductImpl(), edm::InputProductResolver::retrieveAndMerge_(), and setProduct().
|
protected |
Definition at line 547 of file ProductResolvers.cc.
References productData_, and edm::ProductData::setMergeableRunProductMetadata().
Referenced by edm::InputProductResolver::setMergeableRunProductMetadata_().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 552 of file ProductResolvers.cc.
References productData_, and edm::ProductData::setProcessHistory().
|
protected |
Definition at line 501 of file ProductResolvers.cc.
References checkType(), eostools::move(), productData_, ProductSet, setFailedStatus(), theStatus_, and edm::ProductData::unsafe_setWrapper().
Referenced by mergeProduct(), edm::InputProductResolver::putProduct_(), and edm::ProducedProductResolver::putProduct_().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 541 of file ProductResolvers.cc.
References productData_, and edm::ProductData::setProvenance().
|
finalprivatevirtual |
Implements edm::ProductResolverBase.
Definition at line 569 of file ProductResolvers.cc.
|
inlineprotected |
Definition at line 62 of file ProductResolvers.h.
Referenced by mergeProduct(), productResolved_(), productUnavailable_(), productWasDeleted_(), productWasFetchedAndIsValid_(), putOrMergeProduct_(), edm::ProducedProductResolver::putProduct_(), resolveProductImpl(), and edm::InputProductResolver::retrieveAndMerge_().
|
private |
Definition at line 31 of file ProductResolvers.cc.
References edm::ProductResolverBase::branchDescription(), cppFunctionSkipper::exception, edm::ProductResolverBase::moduleLabel(), edm::ProductResolverBase::processName(), edm::ProductResolverBase::productInstanceName(), and edm::BranchDescription::unwrappedTypeID().
Referenced by resolveProductImpl().
|
private |
Definition at line 101 of file ProductResolvers.h.
|
private |
Definition at line 99 of file ProductResolvers.h.
Referenced by resetProductData_(), setMergeableRunProductMetadataInProductData(), setProcessHistory_(), setProduct(), and setProvenance_().
|
mutableprivate |
Definition at line 100 of file ProductResolvers.h.
Referenced by resetProductData_(), and setProduct().