#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 (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	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	putOrMergeProduct_ (std::unique_ptr< WrapperBase > edp, MergeableRunProductMetadata const *mergeableRunProductMetadata) 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 264 of file ProductResolvers.h.

Member Typedef Documentation

◆ ProductStatus

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

Definition at line 266 of file ProductResolvers.h.

Constructor & Destructor Documentation

◆ SwitchBaseProductResolver()

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

Definition at line 612 of file ProductResolvers.cc.

       : 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);
   }

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

Member Function Documentation

◆ branchDescription_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 290 of file ProductResolvers.h.

                                                               {
       return *productData_.branchDescription();
       ;
     }

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

◆ connectTo()

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

finalvirtual

Implements edm::ProductResolverBase.

Definition at line 622 of file ProductResolvers.cc.

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

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

◆ getProductData()

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

inlinefinalprivatevirtual

Implements edm::DataManagingOrAliasProductResolver.

Definition at line 302 of file ProductResolvers.h.

302 { return productData_; }

References edm::DataManagingProductResolver::productData_.

Referenced by unsafe_setWrapperAndProvenance().

◆ prefetchRequested()

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

inlineprotected

Definition at line 278 of file ProductResolvers.h.

278 { return prefetchRequested_; }

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

◆ productProvenancePtr_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 301 of file ProductResolvers.h.

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

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

◆ productResolved_()

bool edm::SwitchBaseProductResolver::productResolved_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 638 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 284 of file ProductResolvers.h.

284 { return realProduct_.productWasDeleted(); }

◆ productWasFetchedAndIsValid_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 285 of file ProductResolvers.h.

                                                                             {
       return realProduct_.productWasFetchedAndIsValid(iSkipCurrentProcess);
     }

◆ provenance_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 297 of file ProductResolvers.h.

297 { return &productData_.provenance(); }

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

◆ putOrMergeProduct_()

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

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 646 of file ProductResolvers.cc.

                                                                                                {
     throw Exception(errors::LogicError)
         << "SwitchBaseProductResolver::putOrMergeProduct_(std::unique_ptr<WrapperBase> edp, "
            "MergeableRunProductMetadata const*) not implemented and should never be called.\n"
         << "Contact a Framework developer\n";
   }

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

◆ realProduct()

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

inlineprotected

Definition at line 277 of file ProductResolvers.h.

277 { return realProduct_; }

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

◆ resetBranchDescription_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 294 of file ProductResolvers.h.

                                                                                   {
       productData_.resetBranchDescription(bd);
     }

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

◆ resetProductData_()

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

overrideprotectedvirtual

Implements edm::DataManagingOrAliasProductResolver.

Reimplemented in edm::SwitchProducerProductResolver.

Definition at line 663 of file ProductResolvers.cc.

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

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

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

◆ resolvedModuleLabel_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 298 of file ProductResolvers.h.

298 { return moduleLabel(); }

References edm::ProductResolverBase::moduleLabel().

◆ resolveProductImpl()

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

protected

Definition at line 632 of file ProductResolvers.cc.

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

References productData_, and Resolution.

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

◆ setProductID_()

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

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 658 of file ProductResolvers.cc.

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

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

◆ setProductProvenanceRetriever_()

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

finalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 654 of file ProductResolvers.cc.

                                                                                                                 {
     productData_.setProvenance(provRetriever);
   }

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

◆ setupUnscheduled()

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

finalvirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 628 of file ProductResolvers.cc.

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

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

◆ singleProduct_()

bool edm::SwitchBaseProductResolver::singleProduct_ ( ) const

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 303 of file ProductResolvers.h.

303 { return true; }

◆ unsafe_setWrapperAndProvenance()

void edm::SwitchBaseProductResolver::unsafe_setWrapperAndProvenance ( ) const

protected

Definition at line 672 of file ProductResolvers.cc.

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

References edm::ProductResolverBase::branchDescription(), getProductData(), edm::ProductProvenanceRetriever::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_().

◆ waitingTasks()

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

inlineprotected

Definition at line 275 of file ProductResolvers.h.

275 { return waitingTasks_; }

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

◆ worker()

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

inlineprotected

Definition at line 276 of file ProductResolvers.h.

276 { return worker_; }

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

Member Data Documentation

◆ parentageID_

ParentageID edm::SwitchBaseProductResolver::parentageID_

private

Definition at line 313 of file ProductResolvers.h.

Referenced by SwitchBaseProductResolver(), and unsafe_setWrapperAndProvenance().

◆ prefetchRequested_

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

mutableprivate

Definition at line 311 of file ProductResolvers.h.

Referenced by resetProductData_().

◆ productData_

ProductData edm::SwitchBaseProductResolver::productData_

private

Definition at line 308 of file ProductResolvers.h.

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

◆ realProduct_

DataManagingOrAliasProductResolver& edm::SwitchBaseProductResolver::realProduct_

private

Definition at line 306 of file ProductResolvers.h.

Referenced by resetProductData_().

◆ waitingTasks_

WaitingTaskList edm::SwitchBaseProductResolver::waitingTasks_

mutableprivate

Definition at line 310 of file ProductResolvers.h.

Referenced by resetProductData_().

◆ worker_

Worker* edm::SwitchBaseProductResolver::worker_ = nullptr

private

Definition at line 309 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_()

◆ putOrMergeProduct_()

◆ realProduct()

◆ resetBranchDescription_()

◆ resetProductData_()

◆ resolvedModuleLabel_()

◆ resolveProductImpl()

◆ setProductID_()

◆ setProductProvenanceRetriever_()

◆ setupUnscheduled()

◆ singleProduct_()

◆ unsafe_setWrapperAndProvenance()

◆ waitingTasks()

◆ worker()

Member Data Documentation

◆ parentageID_

◆ prefetchRequested_

◆ productData_

◆ realProduct_

◆ waitingTasks_

◆ worker_