edm::SwitchBaseProductResolver Class Reference

#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 308 of file ProductResolvers.h.

Member Typedef Documentation

ProductStatus

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

Definition at line 310 of file ProductResolvers.h.

Constructor & Destructor Documentation

SwitchBaseProductResolver()

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

Definition at line 619 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 332 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 629 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 344 of file ProductResolvers.h.

References edm::DataManagingProductResolver::productData_.

Referenced by unsafe_setWrapperAndProvenance().

{ return productData_; }

prefetchRequested()

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

inlineprotected

Definition at line 322 of file ProductResolvers.h.

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

{ return prefetchRequested_; }

productProvenancePtr_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 343 of file ProductResolvers.h.

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

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

productResolved_()

bool edm::SwitchBaseProductResolver::productResolved_ ( ) const

finalprivatevirtual

Implements edm::ProductResolverBase.

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

{ return realProduct_.productWasDeleted(); }

productWasFetchedAndIsValid_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 329 of file ProductResolvers.h.

                                                                            {
      return realProduct_.productWasFetchedAndIsValid(iSkipCurrentProcess);
    }

provenance_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 339 of file ProductResolvers.h.

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

{ return &productData_.provenance(); }

realProduct()

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

inlineprotected

Definition at line 321 of file ProductResolvers.h.

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

{ return realProduct_; }

resetBranchDescription_()

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

inlinefinalprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 336 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 662 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 340 of file ProductResolvers.h.

References edm::ProductResolverBase::moduleLabel().

{ return moduleLabel(); }

resolveProductImpl()

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

protected

Definition at line 639 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 657 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 653 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 635 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 345 of file ProductResolvers.h.

{ return true; }

unsafe_setWrapperAndProvenance()

void edm::SwitchBaseProductResolver::unsafe_setWrapperAndProvenance ( ) const

protected

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

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

{ return waitingTasks_; }

worker()

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

inlineprotected

Definition at line 320 of file ProductResolvers.h.

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

{ return worker_; }

Member Data Documentation

parentageID_

ParentageID edm::SwitchBaseProductResolver::parentageID_

private

Definition at line 355 of file ProductResolvers.h.

Referenced by SwitchBaseProductResolver(), and unsafe_setWrapperAndProvenance().

prefetchRequested_

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

mutableprivate

Definition at line 353 of file ProductResolvers.h.

Referenced by resetProductData_().

productData_

ProductData edm::SwitchBaseProductResolver::productData_

private

Definition at line 350 of file ProductResolvers.h.

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

realProduct_

DataManagingOrAliasProductResolver& edm::SwitchBaseProductResolver::realProduct_

private

Definition at line 348 of file ProductResolvers.h.

Referenced by resetProductData_().

waitingTasks_

WaitingTaskList edm::SwitchBaseProductResolver::waitingTasks_

mutableprivate

Definition at line 352 of file ProductResolvers.h.

Referenced by resetProductData_().

worker_

Worker* edm::SwitchBaseProductResolver::worker_ = nullptr

private

Definition at line 351 of file ProductResolvers.h.

Referenced by setupUnscheduled().