#include <ProductResolvers.h>

Inheritance diagram for edm::InputProductResolver:

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

virtual void	setupUnscheduled (UnscheduledConfigurator const &) overridefinal

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

	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)

virtual void	resetFailedFromThisProcess ()

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
virtual bool	isFromCurrentProcess () const overridefinal

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

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

virtual void	resetProductData_ (bool deleteEarly) override

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

virtual void	retrieveAndMerge_ (Principal const &principal) const override

virtual bool	unscheduledWasNotRun_ () const overridefinal

Private Attributes
UnscheduledAuxiliary const *	aux_

std::atomic< bool >	m_prefetchRequested

WaitingTaskList	m_waitingTasks

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

Constructor & Destructor Documentation

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

inlineexplicit

Definition at line 98 of file ProductResolvers.h.

                                                                              :
       DataManagingProductResolver(bd, ProductStatus::ResolveNotRun),
       m_prefetchRequested{ false },
       aux_{nullptr} {}

Member Function Documentation

bool edm::InputProductResolver::isFromCurrentProcess ( ) const

finaloverrideprivatevirtual

Implements edm::DataManagingProductResolver.

Definition at line 256 of file ProductResolvers.cc.

                                                    {
     return false;
   }

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 190 of file ProductResolvers.cc.

References edm::WaitingTaskList::add(), edm::ProductResolverBase::branchDescription(), edm::WaitingTaskList::doneWaiting(), edm::InEvent, edm::ServiceRegistry::instance(), m_prefetchRequested, m_waitingTasks, edm::make_functor_task(), edm::ServiceRegistry::presentToken(), cmsRelvalreport::principal(), edm::ProductResolverBase::productResolved(), edm::SerialTaskQueueChain::push(), edm::ProductResolverBase::putProduct(), mps_fire::queue, matplotRender::reader, t, and unpackBuffers-CaloStage2::token.

                                                                                    {
     m_waitingTasks.add(waitTask);
     
     bool expected = false;
     if( m_prefetchRequested.compare_exchange_strong(expected, true) ) {
       
       //need to make sure Service system is activated on the reading thread
       auto token = ServiceRegistry::instance().presentToken();
       auto workToDo = [this, mcc, &principal, token] () {
         ServiceRegistry::Operate guard(token);
         try {
           resolveProductImpl<true>([this,&principal,mcc]() {
             if(principal.branchType() != InEvent) { return; }
             if(auto reader = principal.reader()) {
               std::unique_lock<std::recursive_mutex> guard;
               if(auto sr = reader->sharedResources().second) {
                 guard =std::unique_lock<std::recursive_mutex>(*sr);
               }
               if ( not productResolved()) {
                 //another thread could have finished this while we were waiting
                 putProduct( reader->getProduct(BranchKey(branchDescription()), &principal, mcc));
               }
             }
           });
         } catch(...) {
           this->m_waitingTasks.doneWaiting(std::current_exception());
           return;
         }
         this->m_waitingTasks.doneWaiting(nullptr);
       };
       
       SerialTaskQueueChain* queue = nullptr;
       if(auto reader = principal.reader()) {
         if (auto shared_res = reader->sharedResources().first) {
           queue = &(shared_res->serialQueueChain());
         }
       }
       if(queue) {
         queue->push(workToDo);
       } else {
         //Have to create a new task
         auto t = make_functor_task(tbb::task::allocate_root(),
                                    workToDo);
         tbb::task::spawn(*t);
       }
     }
   }

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 438 of file ProductResolvers.cc.

References eostools::move(), edm::ProductResolverBase::productResolved(), and edm::DataManagingProductResolver::setProduct().

                                                                         {
     if ( not productResolved()) {
       //Another thread could have set this
       setProduct(std::move(edp));
     }
   }

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

overrideprivatevirtual

Reimplemented from edm::DataManagingProductResolver.

Definition at line 243 of file ProductResolvers.cc.

References m_prefetchRequested, m_waitingTasks, edm::WaitingTaskList::reset(), and edm::DataManagingProductResolver::resetProductData_().

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

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

overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 113 of file ProductResolvers.cc.

References aux_, edm::ProductResolverBase::branchDescription(), revisionDML::branchType(), edm::ModuleCallingContext::getStreamContext(), edm::InEvent, edm::make_sentry(), cmsRelvalreport::principal(), edm::ProductResolverBase::productResolved(), edm::ProductResolverBase::putProduct(), and matplotRender::reader.

                                                                                {
     return resolveProductImpl<true>([this,&principal,mcc]() {
       auto branchType = principal.branchType();
       if(branchType != InEvent) {
         //delayed get has not been allowed with Run or Lumis
         // The file may already be closed so the reader is invalid
         return;
       }
       if(mcc and (branchType == InEvent) and aux_) {
         aux_->preModuleDelayedGetSignal_.emit(*(mcc->getStreamContext()),*mcc);
       }
 
       auto sentry( make_sentry(mcc,
                                [this, branchType](ModuleCallingContext const* iContext){
                                  if(branchType == InEvent and aux_) {
                                    aux_->postModuleDelayedGetSignal_.emit(*(iContext->getStreamContext()), *iContext); }
                                }));
 
       if(auto reader=principal.reader()) {
         std::unique_lock<std::recursive_mutex> guard;
         if(auto sr = reader->sharedResources().second) {
           guard =std::unique_lock<std::recursive_mutex>(*sr);
         }
         if ( not productResolved()) {
           //another thread could have beaten us here
           putProduct( reader->getProduct(BranchKey(branchDescription()), &principal, mcc));
         }
       }
     });
                               
   }

void edm::InputProductResolver::retrieveAndMerge_ ( Principal const & principal ) const

overrideprivatevirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 149 of file ProductResolvers.cc.

References edm::ProductResolverBase::branchDescription(), edm::DataManagingProductResolver::defaultStatus(), eostools::move(), edm::ProductResolverBase::putOrMergeProduct(), edm::Principal::reader(), matplotRender::reader, edm::DataManagingProductResolver::setFailedStatus(), and edm::DataManagingProductResolver::status().

                                                                           {
     if(auto reader = principal.reader()) {
 
       std::unique_lock<std::recursive_mutex> guard;
       if(auto sr = reader->sharedResources().second) {
         guard =std::unique_lock<std::recursive_mutex>(*sr);
       }
 
       //Can't use resolveProductImpl since it first checks to see
       // if the product was already retrieved and then returns if it is
       BranchKey const bk = BranchKey(branchDescription());
       std::unique_ptr<WrapperBase> edp(reader->getProduct(bk, &principal));
       
       if(edp.get() != nullptr) {
         putOrMergeProduct(std::move(edp));
       } else if( status()== defaultStatus()) {
         setFailedStatus();
       }
     }
   }

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

finaloverridevirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 250 of file ProductResolvers.cc.

References aux_, and edm::UnscheduledConfigurator::auxiliary().

                                                                                   {
     aux_ = iConfigure.auxiliary();
   }

virtual bool edm::InputProductResolver::unscheduledWasNotRun_ ( ) const

inlinefinaloverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 122 of file ProductResolvers.h.

122 {return false;}

Member Data Documentation

UnscheduledAuxiliary const* edm::InputProductResolver::aux_

private

Definition at line 128 of file ProductResolvers.h.

Referenced by resolveProduct_(), and setupUnscheduled().

std::atomic<bool> edm::InputProductResolver::m_prefetchRequested

mutableprivate

Definition at line 126 of file ProductResolvers.h.

Referenced by prefetchAsync_(), and resetProductData_().

WaitingTaskList edm::InputProductResolver::m_waitingTasks

mutableprivate

Definition at line 127 of file ProductResolvers.h.

Referenced by prefetchAsync_(), and resetProductData_().

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation