|
|
Go to the documentation of this file. 1 #ifndef FWCore_Framework_ProductResolvers_h
2 #define FWCore_Framework_ProductResolvers_h
30 class MergeableRunProductMetadata;
31 class ProductProvenanceRetriever;
33 class ModuleCallingContext;
66 void setProduct(std::unique_ptr<WrapperBase> edp)
const;
67 void setProduct(std::shared_ptr<WrapperBase> edp)
const;
72 template <
bool callResolver,
typename FUNC>
111 void setOrMergeProduct(std::shared_ptr<WrapperBase>
prod,
132 bool skipCurrentProcess,
134 ModuleCallingContext
const* mcc)
const override;
136 Principal
const& principal,
137 bool skipCurrentProcess,
140 ModuleCallingContext
const* mcc)
const override;
143 MergeableRunProductMetadata
const* mergeableRunProductMetadata)
const override;
167 void putProduct(std::unique_ptr<WrapperBase> edp)
const override;
168 void putOrMergeProduct(std::unique_ptr<WrapperBase>
prod)
const override;
171 bool skipCurrentProcess,
176 bool skipCurrentProcess,
194 void putProduct(std::unique_ptr<WrapperBase> edp)
const override;
209 bool skipCurrentProcess,
214 bool skipCurrentProcess,
220 void putProduct(std::unique_ptr<WrapperBase> edp)
const override;
237 bool skipCurrentProcess,
242 bool skipCurrentProcess,
253 mutable std::atomic<bool> prefetchRequested_ =
false;
264 realProduct_.connectTo(iOther, iParentPrincipal);
269 bool skipCurrentProcess,
272 return realProduct_.resolveProduct(principal, skipCurrentProcess, sra, mcc);
276 bool skipCurrentProcess,
280 realProduct_.prefetchAsync(waitTask, principal, skipCurrentProcess,
token, sra, mcc);
287 return realProduct_.productWasFetchedAndIsValid(iSkipCurrentProcess);
303 std::shared_ptr<BranchDescription const>
bd_;
322 void unsafe_setWrapperAndProvenance()
const;
329 return realProduct_.productWasFetchedAndIsValid(iSkipCurrentProcess);
365 bool skipCurrentProcess,
370 bool skipCurrentProcess,
374 void putProduct(std::unique_ptr<WrapperBase> edp)
const final;
396 bool skipCurrentProcess,
401 bool skipCurrentProcess,
413 :
ProductResolverBase(), realProduct_(nullptr), bd_(
bd), provRetriever_(nullptr), parentPrincipal_(nullptr) {}
416 realProduct_ = &iOther;
417 parentPrincipal_ = iParentPrincipal;
422 bool skipCurrentProcess,
425 skipCurrentProcess =
false;
426 return realProduct_->resolveProduct(*parentPrincipal_, skipCurrentProcess, sra, mcc);
430 bool skipCurrentProcess,
434 skipCurrentProcess =
false;
435 realProduct_->prefetchAsync(waitTask, *parentPrincipal_, skipCurrentProcess,
token, sra, mcc);
439 return realProduct_->unscheduledWasNotRun();
440 throwNullRealProduct();
447 iSkipCurrentProcess =
false;
448 return realProduct_->productWasFetchedAndIsValid(iSkipCurrentProcess);
460 void throwNullRealProduct()
const;
463 std::shared_ptr<BranchDescription const>
bd_;
472 std::vector<bool>
const& ambiguous,
477 void tryPrefetchResolverAsync(
unsigned int iProcessingIndex,
479 bool skipCurrentProcess,
483 tbb::task_group*)
const;
485 bool dataValidFromResolver(
unsigned int iProcessingIndex,
487 bool iSkipCurrentProcess)
const;
489 void prefetchFailed(
unsigned int iProcessingIndex,
491 bool iSkipCurrentProcess,
492 std::exception_ptr iExceptPtr)
const;
495 unsigned int unsetIndexValue()
const;
497 bool skipCurrentProcess,
502 bool skipCurrentProcess,
525 bool skipCurrentProcess,
552 bool skipCurrentProcess,
557 bool skipCurrentProcess,
SwitchAliasProductResolver(std::shared_ptr< BranchDescription const > bd, DataManagingOrAliasProductResolver &realProduct)
Provenance const * provenance() const
DataManagingOrAliasProductResolver()
std::string const & resolvedModuleLabel_() const final
bool productWasFetchedAndIsValid_(bool iSkipCurrentProcess) const final
ParentProcessProductResolver(std::shared_ptr< BranchDescription const > bd)
ProducedProductResolver(std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)
void resetBranchDescription_(std::shared_ptr< BranchDescription const > bd) override
unsigned int ProductResolverIndex
DataManagingProductResolver(std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)
void connectTo(ProductResolverBase const &iOther, Principal const *iParentPrincipal) final
std::vector< ProductResolverIndex > matchingHolders_
std::shared_ptr< BranchDescription const > bd_
bool singleProduct_() const final
deep_tau::DeepTauBase::BasicDiscriminator bd
bool productResolved_() const final
std::vector< bool > ambiguous_
ProducedProductResolver::ProductStatus ProductStatus
ProductProvenance const * productProvenance() const
std::atomic< unsigned int > lastSkipCurrentCheckIndex_
WaitingTaskList waitingTasks_
PuttableProductResolver(std::shared_ptr< BranchDescription const > bd)
std::atomic< ProductStatus > theStatus_
bool unscheduledWasNotRun_() const final
virtual void prefetchAsync_(WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const =0
void setMergeableRunProductMetadataInProductData(MergeableRunProductMetadata const *)
ProductProvenanceRetriever const * provRetriever_
ProductResolverBase const * realProduct_
std::atomic< unsigned int > lastCheckIndex_
const ProductStatus defaultStatus_
ProductStatus defaultStatus() const
bool productWasFetchedAndIsValid_(bool iSkipCurrentProcess) const final
WaitingTaskList & waitingTasks() const
Provenance const & provenance() const
bool productWasFetchedAndIsValid_(bool iSkipCurrentProcess) const final
bool productUnavailable() const
std::shared_ptr< BranchDescription const > bd_
std::atomic< bool > skippingPrefetchRequested_
bool productWasFetchedAndIsValid_(bool iSkipCurrentProcess) const override
bool productResolved_() const final
Provenance const * provenance_() const final
void resetBranchDescription(std::shared_ptr< BranchDescription const > bd)
void setProduct(std::unique_ptr< WrapperBase > edp) const
Principal const * parentPrincipal_
bool productUnavailable_() const final
ProducedProductResolver::ProductStatus ProductStatus
bool unscheduledWasNotRun() const
virtual bool unscheduledWasNotRun_() const =0
Resolution resolveProductImpl(FUNC resolver) const
bool productUnavailable_() const final
DataManagingOrAliasProductResolver const & realProduct() const
WaitingTaskList waitingTasks_
ProducedProductResolver::ProductStatus ProductStatus
void throwProductDeletedException() const
ProductResolverIndex realResolverIndex_
virtual ProductData const & getProductData() const =0
Resolution resolveProduct_(Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const override
void setProductProvenanceRetriever_(ProductProvenanceRetriever const *provRetriever) final
bool unscheduledWasNotRun_() const override
DataManagingOrAliasProductResolver & realProduct_
bool unscheduledWasNotRun_() const override
BranchDescription const & branchDescription_() const override
virtual void setMergeableRunProductMetadata_(MergeableRunProductMetadata const *)
Provenance const * provenance_() const final
std::atomic< bool > prefetchRequested_
bool unscheduledWasNotRun_() const override
void connectTo(ProductResolverBase const &iOther, Principal const *iParentPrincipal) final
std::atomic< bool > prefetchRequested_
bool unscheduledWasNotRun_() const final
SingleChoiceNoProcessProductResolver(ProductResolverIndex iChoice)
void setProductID_(ProductID const &pid) final
void resetProductData_(bool deleteEarly) override=0
ProducedProductResolver::ProductStatus ProductStatus
void resetBranchDescription_(std::shared_ptr< BranchDescription const > bd) override
Resolution resolveProduct_(Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const override
bool productWasDeleted_() const override
WaitingTaskList m_waitingTasks
bool productUnavailable_() const override
WaitingTaskList waitingTasks_
std::string const & resolvedModuleLabel_() const final
std::string const & moduleLabel() const
void resetProductData_(bool deleteEarly) override
virtual void retrieveAndMerge_(Principal const &principal, MergeableRunProductMetadata const *mergeableRunProductMetadata) const
bool singleProduct_() const final
bool productUnavailable_() const override
BranchDescription const & branchDescription_() const final
void checkType(WrapperBase const &prod) const
ProductStatus status() const
std::string const & resolvedModuleLabel_() const override
virtual Resolution resolveProduct_(Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const =0
ProductData const & getProductData() const final
AliasProductResolver(std::shared_ptr< BranchDescription const > bd, DataManagingOrAliasProductResolver &realProduct)
WaitingTaskList skippingWaitingTasks_
void resetBranchDescription_(std::shared_ptr< BranchDescription const > bd) final
std::string const & resolvedModuleLabel_() const override
ProductData const & getProductData() const final
Provenance const * provenance_() const final
BranchDescription const & branchDescription_() const override
std::shared_ptr< BranchDescription const > const & branchDescription() const
BranchDescription const & branchDescription_() const final
void setFailedStatus() const
ProductData const & getProductData() const final
virtual void setupUnscheduled(UnscheduledConfigurator const &)
bool productWasDeleted_() const override
std::atomic< bool > prefetchRequested_
void resetBranchDescription_(std::shared_ptr< BranchDescription const > bd) final
std::atomic< bool > & prefetchRequested() const
DataManagingOrAliasProductResolver & realProduct_
void connectTo(ProductResolverBase const &, Principal const *) final
UnscheduledProductResolver(std::shared_ptr< BranchDescription const > bd)
bool productResolved_() const final
ProductProvenance const * productProvenancePtr_() const final
Provenance const * provenance_() const final
bool unscheduledWasNotRun_() const override
ProductProvenance const * productProvenancePtr_() const final
void prefetchAsync_(WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const override
bool productWasDeleted_() const final
virtual bool isFromCurrentProcess() const =0
void prefetchAsync_(WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const override