#include <ProductResolvers.h>

Inheritance diagram for edm::UnscheduledProductResolver:

Public Member Functions
void	setupUnscheduled (UnscheduledConfigurator const &) final

	UnscheduledProductResolver (std::shared_ptr< BranchDescription const > bd)

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

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 ()

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 ()

Public Member Functions inherited from edm::ProductPutterBase
	ProductPutterBase ()=default

virtual	~ProductPutterBase ()=default

Private Member Functions
void	prefetchAsync_ (WaitingTaskHolder waitTask, Principal const &principal, bool skipCurrentProcess, ServiceToken const &token, SharedResourcesAcquirer sra, ModuleCallingContext const mcc) 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
UnscheduledAuxiliary const *	aux_ = nullptr

std::atomic< bool >	prefetchRequested_ = false

WaitingTaskList	waitingTasks_

Worker *	worker_ = nullptr

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::ProducedProductResolver
void	putProduct (std::unique_ptr< WrapperBase > edp) const override

Protected Member Functions inherited from edm::DataManagingProductResolver
void	checkType (WrapperBase const &prod) const

ProductStatus	defaultStatus () const

ProductData const &	getProductData () const final

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

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

void	setFailedStatus () const

void	setMergeableRunProductMetadataInProductData (MergeableRunProductMetadata const *)

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

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

ProductStatus	status () const

Detailed Description

Definition at line 229 of file ProductResolvers.h.

Constructor & Destructor Documentation

◆ UnscheduledProductResolver()

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

inlineexplicit

Definition at line 231 of file ProductResolvers.h.

232 : ProducedProductResolver(bd, ProductStatus::ResolveNotRun) {}

Member Function Documentation

◆ prefetchAsync_()

void edm::UnscheduledProductResolver::prefetchAsync_	(	WaitingTaskHolder	waitTask,
		Principal const &	principal,
		bool	skipCurrentProcess,
		ServiceToken const &	token,
		SharedResourcesAcquirer *	sra,
		ModuleCallingContext const *	mcc
	)		const

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 452 of file ProductResolvers.cc.

                                                                                          {
     if (skipCurrentProcess) {
       return;
     }
     if (worker_ == nullptr) {
       throw cms::Exception("LogicError") << "UnscheduledProductResolver::prefetchAsync_()  called with null worker_. "
                                             "This should not happen, please contact framework developers.";
     }
     //need to try changing prefetchRequested_ before adding to waitingTasks_
     bool expected = false;
     bool prefetchRequested = prefetchRequested_.compare_exchange_strong(expected, true);
     waitingTasks_.add(waitTask);
     if (prefetchRequested) {
       //Have to create a new task which will make sure the state for UnscheduledProductResolver
       // is properly set after the module has run
       auto t = make_waiting_task([this](std::exception_ptr const* iPtr) {
         //The exception is being rethrown because resolveProductImpl sets the ProductResolver to a failed
         // state for the case where an exception occurs during the call to the function.
         // Caught exception is propagated via WaitingTaskList
         CMS_SA_ALLOW try {
           resolveProductImpl<true>([iPtr]() {
             if (iPtr) {
               std::rethrow_exception(*iPtr);
             }
           });
         } catch (...) {
           waitingTasks_.doneWaiting(std::current_exception());
           return;
         }
         waitingTasks_.doneWaiting(nullptr);
       });
  
       ParentContext parentContext(mcc);
       EventTransitionInfo const& info = aux_->eventTransitionInfo();
       worker_->doWorkAsync<OccurrenceTraits<EventPrincipal, BranchActionStreamBegin> >(
           WaitingTaskHolder(*waitTask.group(), t),
           info,
           token,
           info.principal().streamID(),
           parentContext,
           mcc->getStreamContext());
     }
   }

References edm::WaitingTaskList::add(), aux_, CMS_SA_ALLOW, edm::WaitingTaskList::doneWaiting(), edm::Worker::doWorkAsync(), edm::UnscheduledAuxiliary::eventTransitionInfo(), Exception, edm::ModuleCallingContext::getStreamContext(), edm::WaitingTaskHolder::group(), info(), edm::make_waiting_task(), prefetchRequested_, submitPVValidationJobs::t, unpackBuffers-CaloStage2::token, waitingTasks_, and worker_.

◆ resetProductData_()

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

overrideprivatevirtual

Reimplemented from edm::DataManagingProductResolver.

Definition at line 501 of file ProductResolvers.cc.

                                                                      {
     if (not deleteEarly) {
       prefetchRequested_ = false;
       waitingTasks_.reset();
     }
     DataManagingProductResolver::resetProductData_(deleteEarly);
   }

References prefetchRequested_, edm::WaitingTaskList::reset(), edm::DataManagingProductResolver::resetProductData_(), and waitingTasks_.

◆ resolveProduct_()

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 434 of file ProductResolvers.cc.

                                                                                                                  {
     if (!skipCurrentProcess and worker_) {
       return resolveProductImpl<true>([this]() {
         edm::Exception ex(errors::UnimplementedFeature);
         ex << "Attempting to run unscheduled module without doing prefetching";
         std::ostringstream ost;
         ost << "Calling produce method for unscheduled module " << worker_->description()->moduleName() << "/'"
             << worker_->description()->moduleLabel() << "'";
         ex.addContext(ost.str());
         throw ex;
       });
     }
     return Resolution(nullptr);
   }

References cms::Exception::addContext(), edm::Worker::description(), edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), Resolution, edm::errors::UnimplementedFeature, and worker_.

◆ setupUnscheduled()

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

finalvirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 429 of file ProductResolvers.cc.

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