#include <ProductResolvers.h>

Inheritance diagram for edm::SwitchBaseProductResolver:

Public Types
using	ProductStatus = DataManagingProductResolver::ProductStatus

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

void	setupUnscheduled (UnscheduledConfigurator const &iConfigure) final

	SwitchBaseProductResolver (std::shared_ptr< BranchDescription const > bd, DataManagingOrAliasProductResolver &realProduct)

Public Member Functions inherited from edm::DataManagingOrAliasProductResolver
	DataManagingOrAliasProductResolver ()

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

std::string const &	moduleLabel () const

ProductResolverBase &	operator= (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)

bool	singleProduct () const

StableProvenance const *	stableProvenance () const

void	unsafe_deleteProduct () const

bool	unscheduledWasNotRun () const

void	write (std::ostream &os) const

virtual	~ProductResolverBase ()

Protected Member Functions
std::atomic< bool > &	prefetchRequested () const

DataManagingOrAliasProductResolver const &	realProduct () const

void	resetProductData_ (bool deleteEarly) override

Resolution	resolveProductImpl (Resolution) const

void	unsafe_setWrapperAndProvenance () const

WaitingTaskList &	waitingTasks () const

Worker *	worker () const

Private Member Functions
BranchDescription const &	branchDescription_ () const final

ProductData const &	getProductData () const final

ProductProvenance const *	productProvenancePtr_ () const final

bool	productResolved_ () const final

bool	productWasDeleted_ () const final

bool	productWasFetchedAndIsValid_ (bool iSkipCurrentProcess) const final

Provenance const *	provenance_ () const final

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

std::string const &	resolvedModuleLabel_ () const final

void	setProductID_ (ProductID const &pid) final

void	setProductProvenanceRetriever_ (ProductProvenanceRetriever const *provRetriever) final

bool	singleProduct_ () const final

Private Attributes
ParentageID	parentageID_

std::atomic< bool >	prefetchRequested_

ProductData	productData_

DataManagingOrAliasProductResolver &	realProduct_

WaitingTaskList	waitingTasks_

Worker *	worker_ = nullptr

Detailed Description

Definition at line 339 of file ProductResolvers.h.

Member Typedef Documentation

◆ ProductStatus

using edm::SwitchBaseProductResolver::ProductStatus = DataManagingProductResolver::ProductStatus

Definition at line 341 of file ProductResolvers.h.

Constructor & Destructor Documentation

◆ SwitchBaseProductResolver()

edm::SwitchBaseProductResolver::SwitchBaseProductResolver	(	std::shared_ptr< BranchDescription const >	bd,
		DataManagingOrAliasProductResolver &	realProduct
	)

Definition at line 707 of file ProductResolvers.cc.

References edm::ProductResolverBase::branchDescription(), edm::ParentageRegistry::insertMapped(), edm::ParentageRegistry::instance(), edm::BranchDescription::originalBranchID(), AlCaHLTBitMon_ParallelJobs::p, parentageID_, and realProduct().

       : realProduct_(realProduct), productData_(std::move(bd)), prefetchRequested_(false) {
     // Parentage of this branch is always the same by construction, so we can compute the ID just "once" here.
     Parentage p;
     p.setParents(std::vector<BranchID>{realProduct.branchDescription().originalBranchID()});
     parentageID_ = p.id();
     ParentageRegistry::instance()->insertMapped(p);
   }

Member Function Documentation

◆ branchDescription_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 363 of file ProductResolvers.h.

References edm::ProductData::branchDescription(), and edm::DataManagingProductResolver::productData_.

                                                               {
       return *productData_.branchDescription();
       ;
     }

◆ connectTo()

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

finalvirtual

Implements edm::ProductResolverBase.

Definition at line 717 of file ProductResolvers.cc.

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

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

◆ getProductData()

ProductData const& edm::SwitchBaseProductResolver::getProductData ( ) const

inlinefinalprivatevirtual

Implements edm::DataManagingOrAliasProductResolver.

Definition at line 375 of file ProductResolvers.h.

References edm::DataManagingProductResolver::productData_.

Referenced by unsafe_setWrapperAndProvenance().

375 { return productData_; }

edm::SwitchBaseProductResolver::productData_

ProductData productData_

Definition: ProductResolvers.h:381

◆ prefetchRequested()

std::atomic<bool>& edm::SwitchBaseProductResolver::prefetchRequested ( ) const

inlineprotected

Definition at line 353 of file ProductResolvers.h.

Referenced by edm::SwitchProducerProductResolver::prefetchAsync_(), edm::SwitchAliasProductResolver::prefetchAsync_(), and edm::SwitchProducerProductResolver::putProduct().

353 { return prefetchRequested_; }

edm::SwitchBaseProductResolver::prefetchRequested_

std::atomic< bool > prefetchRequested_

Definition: ProductResolvers.h:384

◆ productProvenancePtr_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 374 of file ProductResolvers.h.

References edm::Provenance::productProvenance(), and edm::ProductResolverBase::provenance().

374 { return provenance()->productProvenance(); }

edm::Provenance::productProvenance

ProductProvenance const * productProvenance() const

Definition: Provenance.cc:24

edm::ProductResolverBase::provenance

Provenance const * provenance() const

Definition: ProductResolverBase.cc:31

◆ productResolved_()

bool edm::SwitchBaseProductResolver::productResolved_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 733 of file ProductResolvers.cc.

                                                          {
     // SwitchProducer will never put anything in the event, and
     // "false" will make Event::commit_() to call putProduct() with
     // null unique_ptr<WrapperBase> to signal that the produce() was
     // run.
     return false;
   }

◆ productWasDeleted_()

bool edm::SwitchBaseProductResolver::productWasDeleted_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 359 of file ProductResolvers.h.

359 { return realProduct_.productWasDeleted(); }

edm::SwitchBaseProductResolver::realProduct_

DataManagingOrAliasProductResolver & realProduct_

Definition: ProductResolvers.h:379

edm::ProductResolverBase::productWasDeleted

bool productWasDeleted() const

Definition: ProductResolverBase.h:100

◆ productWasFetchedAndIsValid_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 360 of file ProductResolvers.h.

                                                                             {
       return realProduct_.productWasFetchedAndIsValid(iSkipCurrentProcess);
     }

◆ provenance_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 370 of file ProductResolvers.h.

References edm::DataManagingProductResolver::productData_, and edm::ProductData::provenance().

370 { return &productData_.provenance(); }

edm::ProductData::provenance

Provenance const & provenance() const

Definition: ProductData.h:33

edm::SwitchBaseProductResolver::productData_

ProductData productData_

Definition: ProductResolvers.h:381

◆ realProduct()

DataManagingOrAliasProductResolver const& edm::SwitchBaseProductResolver::realProduct ( ) const

inlineprotected

Definition at line 352 of file ProductResolvers.h.

Referenced by edm::SwitchAliasProductResolver::prefetchAsync_(), edm::SwitchProducerProductResolver::productUnavailable_(), edm::SwitchProducerProductResolver::resolveProduct_(), edm::SwitchAliasProductResolver::resolveProduct_(), SwitchBaseProductResolver(), and unsafe_setWrapperAndProvenance().

352 { return realProduct_; }

edm::SwitchBaseProductResolver::realProduct_

DataManagingOrAliasProductResolver & realProduct_

Definition: ProductResolvers.h:379

◆ resetBranchDescription_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 367 of file ProductResolvers.h.

References edm::DataManagingProductResolver::productData_, and edm::ProductData::resetBranchDescription().

                                                                                   {
       productData_.resetBranchDescription(bd);
     }

◆ resetProductData_()

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

overrideprotectedvirtual

Implements edm::DataManagingOrAliasProductResolver.

Reimplemented in edm::SwitchProducerProductResolver.

Definition at line 750 of file ProductResolvers.cc.

References prefetchRequested_, productData_, realProduct_, edm::WaitingTaskList::reset(), edm::ProductData::resetProductData(), edm::DataManagingOrAliasProductResolver::resetProductData_(), and waitingTasks_.

Referenced by edm::SwitchProducerProductResolver::resetProductData_().

                                                                     {
     productData_.resetProductData();
     realProduct_.resetProductData_(deleteEarly);
     if (not deleteEarly) {
       prefetchRequested_ = false;
       waitingTasks_.reset();
     }
   }

◆ resolvedModuleLabel_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 371 of file ProductResolvers.h.

References edm::ProductResolverBase::moduleLabel().

371 { return moduleLabel(); }

edm::ProductResolverBase::moduleLabel

std::string const & moduleLabel() const

Definition: ProductResolverBase.h:119

◆ resolveProductImpl()

ProductResolverBase::Resolution edm::SwitchBaseProductResolver::resolveProductImpl ( Resolution res ) const

protected

Definition at line 727 of file ProductResolvers.cc.

References productData_, and Resolution.

Referenced by edm::SwitchProducerProductResolver::resolveProduct_(), and edm::SwitchAliasProductResolver::resolveProduct_().

                                                                                                   {
     if (res.data() == nullptr)
       return res;
     return Resolution(&productData_);
   }

◆ setProductID_()

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

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 745 of file ProductResolvers.cc.

References productData_, and edm::ProductData::setProductID().

                                                                     {
     // insertIntoSet is const, so let's exploit that to fake the getting of the "input" product
     productData_.setProductID(pid);
   }

◆ setProductProvenanceRetriever_()

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

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 741 of file ProductResolvers.cc.

References productData_, and edm::ProductData::setProvenance().

                                                                                                                 {
     productData_.setProvenance(provRetriever);
   }

◆ setupUnscheduled()

void edm::SwitchBaseProductResolver::setupUnscheduled ( UnscheduledConfigurator const & iConfigure )

finalvirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 723 of file ProductResolvers.cc.

References edm::ProductResolverBase::branchDescription(), edm::UnscheduledConfigurator::findWorker(), edm::ProductResolverBase::moduleLabel(), and worker_.

                                                                                             {
     worker_ = iConfigure.findWorker(branchDescription().moduleLabel());
   }

◆ singleProduct_()

bool edm::SwitchBaseProductResolver::singleProduct_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 376 of file ProductResolvers.h.

376 { return true; }

◆ unsafe_setWrapperAndProvenance()

void edm::SwitchBaseProductResolver::unsafe_setWrapperAndProvenance ( ) const

protected

Definition at line 759 of file ProductResolvers.cc.

References edm::ProductResolverBase::branchDescription(), getProductData(), edm::ProductProvenanceLookup::insertIntoSet(), parentageID_, productData_, edm::ProductData::provenance(), realProduct(), edm::Provenance::store(), and edm::ProductData::unsafe_setWrapper().

Referenced by edm::SwitchProducerProductResolver::prefetchAsync_(), edm::SwitchAliasProductResolver::prefetchAsync_(), and edm::SwitchProducerProductResolver::putProduct().

                                                                        {
     // update provenance
     productData_.provenance().store()->insertIntoSet(ProductProvenance(branchDescription().branchID(), parentageID_));
     // Use the Wrapper of the pointed-to resolver, but the provenance of this resolver
     productData_.unsafe_setWrapper(realProduct().getProductData().sharedConstWrapper());
   }

◆ waitingTasks()

WaitingTaskList& edm::SwitchBaseProductResolver::waitingTasks ( ) const

inlineprotected

Definition at line 350 of file ProductResolvers.h.

Referenced by edm::SwitchProducerProductResolver::prefetchAsync_(), edm::SwitchAliasProductResolver::prefetchAsync_(), and edm::SwitchProducerProductResolver::putProduct().

350 { return waitingTasks_; }

edm::SwitchBaseProductResolver::waitingTasks_

WaitingTaskList waitingTasks_

Definition: ProductResolvers.h:383

◆ worker()

Worker* edm::SwitchBaseProductResolver::worker ( ) const

inlineprotected

Definition at line 351 of file ProductResolvers.h.

Referenced by edm::SwitchProducerProductResolver::prefetchAsync_().

351 { return worker_; }

edm::SwitchBaseProductResolver::worker_

Worker * worker_

Definition: ProductResolvers.h:382

Member Data Documentation

◆ parentageID_

ParentageID edm::SwitchBaseProductResolver::parentageID_

private

Definition at line 386 of file ProductResolvers.h.

Referenced by SwitchBaseProductResolver(), and unsafe_setWrapperAndProvenance().

◆ prefetchRequested_

std::atomic<bool> edm::SwitchBaseProductResolver::prefetchRequested_

mutableprivate

Definition at line 384 of file ProductResolvers.h.

Referenced by resetProductData_().

◆ productData_

ProductData edm::SwitchBaseProductResolver::productData_

private

Definition at line 381 of file ProductResolvers.h.

Referenced by resetProductData_(), resolveProductImpl(), setProductID_(), setProductProvenanceRetriever_(), and unsafe_setWrapperAndProvenance().

◆ realProduct_

DataManagingOrAliasProductResolver& edm::SwitchBaseProductResolver::realProduct_

private

Definition at line 379 of file ProductResolvers.h.

Referenced by resetProductData_().

◆ waitingTasks_

WaitingTaskList edm::SwitchBaseProductResolver::waitingTasks_

mutableprivate

Definition at line 383 of file ProductResolvers.h.

Referenced by resetProductData_().

◆ worker_

Worker* edm::SwitchBaseProductResolver::worker_ = nullptr

private

Definition at line 382 of file ProductResolvers.h.

Referenced by setupUnscheduled().

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ ProductStatus

Constructor & Destructor Documentation

◆ SwitchBaseProductResolver()

Member Function Documentation

◆ branchDescription_()

◆ connectTo()

◆ getProductData()

◆ prefetchRequested()

◆ productProvenancePtr_()

◆ productResolved_()

◆ productWasDeleted_()

◆ productWasFetchedAndIsValid_()

◆ provenance_()

◆ realProduct()

◆ resetBranchDescription_()

◆ resetProductData_()

◆ resolvedModuleLabel_()

◆ resolveProductImpl()

◆ setProductID_()

◆ setProductProvenanceRetriever_()

◆ setupUnscheduled()

◆ singleProduct_()

◆ unsafe_setWrapperAndProvenance()

◆ waitingTasks()

◆ worker()

Member Data Documentation

◆ parentageID_

◆ prefetchRequested_

◆ productData_

◆ realProduct_

◆ waitingTasks_

◆ worker_