#include <ProductResolvers.h>

Inheritance diagram for edm::PuttableProductResolver:

Public Member Functions
	PuttableProductResolver (std::shared_ptr< BranchDescription const > bd)

void	setupUnscheduled (UnscheduledConfigurator const &) final

Public Member Functions inherited from edm::ProducedProductResolver
	ProducedProductResolver (std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)

void	resetFailedFromThisProcess () override

Public Member Functions inherited from edm::DataManagingProductResolver
void	connectTo (ProductResolverBase const &, Principal const *) final

	DataManagingProductResolver (std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)

void	resetStatus ()

template<bool callResolver, typename FUNC >
ProductResolverBase::Resolution	resolveProductImpl (FUNC resolver) const

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, 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) 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) const

void	setProcessHistory (ProcessHistory const &ph)

void	setProvenance (ProductProvenanceRetriever const *provRetriever, ProcessHistory const &ph, ProductID const &pid)

bool	singleProduct () const

StableProvenance const *	stableProvenance () const

void	unsafe_deleteProduct () const

bool	unscheduledWasNotRun () const

void	write (std::ostream &os) const

virtual	~ProductResolverBase ()

Private Member Functions
void	prefetchAsync_ (WaitingTask waitTask, Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer sra, ModuleCallingContext const *mcc) const override

void	putProduct_ (std::unique_ptr< WrapperBase > edp) const override

void	resetProductData_ (bool deleteEarly) override

Resolution	resolveProduct_ (Principal const &principal, bool skipCurrentProcess, SharedResourcesAcquirer sra, ModuleCallingContext const mcc) const override

bool	unscheduledWasNotRun_ () const override

Private Attributes
WaitingTaskList	m_waitingTasks

std::atomic< bool >	prefetchRequested_

Worker *	worker_

Additional Inherited Members
Public Types inherited from edm::DataManagingProductResolver
enum	ProductStatus { ProductStatus::ProductSet, ProductStatus::NotPut, ProductStatus::ResolveFailed, ProductStatus::ResolveNotRun, ProductStatus::ProductDeleted }

Protected Member Functions inherited from edm::DataManagingProductResolver
ProductStatus	defaultStatus () const

template<bool callResolver, typename FUNC >
Resolution	resolveProductImpl (FUNC resolver) const

void	setFailedStatus () const

void	setProduct (std::unique_ptr< WrapperBase > edp) const

ProductStatus	status () const

Detailed Description

Definition at line 146 of file ProductResolvers.h.

Constructor & Destructor Documentation

edm::PuttableProductResolver::PuttableProductResolver ( std::shared_ptr< BranchDescription const > bd )

inlineexplicit

Definition at line 148 of file ProductResolvers.h.

References edm::ProductResolverBase::prefetchAsync_(), cmsRelvalreport::principal(), edm::ProductResolverBase::resolveProduct_(), and edm::ProductResolverBase::setupUnscheduled().

148 : ProducedProductResolver(bd, ProductStatus::NotPut), worker_(nullptr), prefetchRequested_(false) {}

edm::DataManagingProductResolver::ProductStatus::NotPut

edm::PuttableProductResolver::worker_

Worker * worker_

Definition: ProductResolvers.h:168

edm::ProducedProductResolver::ProducedProductResolver

ProducedProductResolver(std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)

Definition: ProductResolvers.h:135

edm::PuttableProductResolver::prefetchRequested_

std::atomic< bool > prefetchRequested_

Definition: ProductResolvers.h:169

Member Function Documentation

void edm::PuttableProductResolver::prefetchAsync_	(	WaitingTask *	waitTask,
		Principal const &	principal,
		bool	skipCurrentProcess,
		SharedResourcesAcquirer *	sra,
		ModuleCallingContext const *	mcc
	)		const

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 255 of file ProductResolvers.cc.

References edm::Principal::atEndTransition(), edm::ProductResolverBase::branchDescription(), and edm::make_waiting_task().

                                                                                       {
     if(not skipCurrentProcess) {
       if(branchDescription().availableOnlyAtEndTransition() and
          not principal.atEndTransition()) {
         return;
       }
       m_waitingTasks.add(waitTask);
       
       bool expected = false;
       if(worker_ and prefetchRequested_.compare_exchange_strong(expected,true)) {
         //using a waiting task to do a callback guarantees that
         // the m_waitingTasks list will be released from waiting even
         // if the module does not put this data product or the
         // module has an exception while running
         
         auto waiting = make_waiting_task(tbb::task::allocate_root(),
                                          [this](std::exception_ptr const *  iException) {
                                            if(nullptr != iException) {
                                              m_waitingTasks.doneWaiting(*iException);
                                            } else {
                                              m_waitingTasks.doneWaiting(std::exception_ptr());
                                            }
                                          });
         worker_->callWhenDoneAsync(waiting);
       }
     }
   }

void edm::PuttableProductResolver::putProduct_ ( std::unique_ptr< WrapperBase > edp ) const

overrideprivatevirtual

Reimplemented from edm::ProducedProductResolver.

Definition at line 288 of file ProductResolvers.cc.

References eostools::move(), and edm::ProducedProductResolver::putProduct_().

                                                                            {
     ProducedProductResolver::putProduct_(std::move(edp));
     bool expected = false;
     if(prefetchRequested_.compare_exchange_strong(expected,true)) {
       m_waitingTasks.doneWaiting(std::exception_ptr());
     }
   }

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

overrideprivatevirtual

Reimplemented from edm::DataManagingProductResolver.

Definition at line 298 of file ProductResolvers.cc.

References edm::DataManagingProductResolver::resetProductData_().

                                                              {
     m_waitingTasks.reset();
     DataManagingProductResolver::resetProductData_(deleteEarly);
     prefetchRequested_ = false;
   }

ProductResolverBase::Resolution edm::PuttableProductResolver::resolveProduct_	(	Principal const &	principal,
		bool	skipCurrentProcess,
		SharedResourcesAcquirer *	sra,
		ModuleCallingContext const *	mcc
	)		const

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 244 of file ProductResolvers.cc.

References Resolution.

                                                                               {
     if (!skipCurrentProcess) {
       //'false' means never call the lambda function
       return resolveProductImpl<false>([](){return;});
     }
     return Resolution(nullptr);
   }

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

finalvirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 305 of file ProductResolvers.cc.

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

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

bool edm::PuttableProductResolver::unscheduledWasNotRun_ ( ) const

inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 162 of file ProductResolvers.h.

References edm::ProductResolverBase::putProduct_(), and edm::DataManagingProductResolver::resetProductData_().

162 {return false;}

Member Data Documentation

WaitingTaskList edm::PuttableProductResolver::m_waitingTasks

mutableprivate

Definition at line 167 of file ProductResolvers.h.

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

mutableprivate

Definition at line 169 of file ProductResolvers.h.

Worker* edm::PuttableProductResolver::worker_

private

Definition at line 168 of file ProductResolvers.h.

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation