CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Member Functions | Private Member Functions | Private Attributes
edm::PuttableProductResolver Class Reference

#include <ProductResolvers.h>

Inheritance diagram for edm::PuttableProductResolver:
edm::ProducedProductResolver edm::DataManagingProductResolver edm::ProductPutterBase edm::DataManagingOrAliasProductResolver edm::ProductResolverBase

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)
 
- 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::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 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
void checkType (WrapperBase const &prod) const
 
ProductStatus defaultStatus () const
 
ProductData const & getProductData () const final
 
template<bool callResolver, typename FUNC >
Resolution resolveProductImpl (FUNC resolver) const
 
void setFailedStatus () const
 
void setMergeableRunProductMetadataInProductData (MergeableRunProductMetadata const *)
 
void setProduct (std::unique_ptr< WrapperBase > edp) const
 
void setProduct (std::shared_ptr< WrapperBase > edp) const
 
ProductStatus status () const
 

Detailed Description

Definition at line 201 of file ProductResolvers.h.

Constructor & Destructor Documentation

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

Definition at line 203 of file ProductResolvers.h.

204  : ProducedProductResolver(bd, ProductStatus::NotPut), worker_(nullptr), prefetchRequested_(false) {}
edm::ProducedProductResolver::ProducedProductResolver
ProducedProductResolver(std::shared_ptr< BranchDescription const > bd, ProductStatus iDefaultStatus)
Definition: ProductResolvers.h:189
edm::PuttableProductResolver::prefetchRequested_
std::atomic< bool > prefetchRequested_
Definition: ProductResolvers.h:226
deep_tau::DeepTauBase::BasicDiscriminator
BasicDiscriminator
Definition: DeepTauBase.h:115

Member Function Documentation

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

Implements edm::ProductResolverBase.

Definition at line 366 of file ProductResolvers.cc.

References edm::WaitingTaskList::add(), edm::BranchDescription::availableOnlyAtEndTransition(), edm::ProductResolverBase::branchDescription(), edm::Worker::callWhenDoneAsync(), edm::WaitingTaskList::doneWaiting(), edm::ParentContext::globalContext(), edm::WaitingTaskHolder::group(), edm::InProcess, edm::ParentContext::isAtEndTransition(), edm::GlobalContext::kAccessInputProcessBlock, m_waitingTasks, edm::make_waiting_task(), edm::ModuleCallingContext::parent(), prefetchRequested_, edm::GlobalContext::transition(), and worker_.

371  {
372  if (not skipCurrentProcess) {
373  if (branchDescription().branchType() == InProcess &&
374  mcc->parent().globalContext()->transition() == GlobalContext::Transition::kAccessInputProcessBlock) {
375  // This is an accessInputProcessBlock transition
376  // We cannot access produced products in those transitions
377  // except for in SubProcesses where they should have already run.
378  return;
379  }
380  if (branchDescription().availableOnlyAtEndTransition() and mcc) {
381  if (not mcc->parent().isAtEndTransition()) {
382  return;
383  }
384  }
385 
386  //Need to try modifying prefetchRequested_ before adding to m_waitingTasks
387  bool expected = false;
388  bool prefetchRequested = prefetchRequested_.compare_exchange_strong(expected, true);
389  m_waitingTasks.add(waitTask);
390 
391  if (worker_ and prefetchRequested) {
392  //using a waiting task to do a callback guarantees that
393  // the m_waitingTasks list will be released from waiting even
394  // if the module does not put this data product or the
395  // module has an exception while running
396 
397  auto waiting = make_waiting_task([this](std::exception_ptr const* iException) {
398  if (nullptr != iException) {
399  m_waitingTasks.doneWaiting(*iException);
400  } else {
401  m_waitingTasks.doneWaiting(std::exception_ptr());
402  }
403  });
404  worker_->callWhenDoneAsync(WaitingTaskHolder(*waitTask.group(), waiting));
405  }
406  }
407  }
edm::PuttableProductResolver::prefetchRequested_
std::atomic< bool > prefetchRequested_
Definition: ProductResolvers.h:226
edm::WaitingTaskList::doneWaiting
void doneWaiting(std::exception_ptr iPtr)
Signals that the resource is now available and tasks should be spawned.
Definition: WaitingTaskList.cc:212
edm::make_waiting_task
FunctorWaitingTask< F > * make_waiting_task(F f)
Definition: WaitingTask.h:101
edm::Worker::callWhenDoneAsync
void callWhenDoneAsync(WaitingTaskHolder task)
Definition: Worker.h:167
edm::WaitingTaskList::add
void add(tbb::task_group *, WaitingTask *)
Adds task to the waiting list.
Definition: WaitingTaskList.cc:125
edm::ProductResolverBase::branchDescription
BranchDescription const & branchDescription() const
Definition: ProductResolverBase.h:110
edm::BranchDescription::availableOnlyAtEndTransition
bool availableOnlyAtEndTransition() const
Definition: BranchDescription.h:90
void edm::PuttableProductResolver::putProduct ( std::unique_ptr< WrapperBase >  edp) const
overrideprivatevirtual

Reimplemented from edm::ProducedProductResolver.

Definition at line 409 of file ProductResolvers.cc.

References edm::WaitingTaskList::doneWaiting(), m_waitingTasks, eostools::move(), prefetchRequested_, and edm::ProducedProductResolver::putProduct().

409  {
410  ProducedProductResolver::putProduct(std::move(edp));
411  bool expected = false;
412  if (prefetchRequested_.compare_exchange_strong(expected, true)) {
413  m_waitingTasks.doneWaiting(std::exception_ptr());
414  }
415  }
edm::PuttableProductResolver::prefetchRequested_
std::atomic< bool > prefetchRequested_
Definition: ProductResolvers.h:226
edm::WaitingTaskList::doneWaiting
void doneWaiting(std::exception_ptr iPtr)
Signals that the resource is now available and tasks should be spawned.
Definition: WaitingTaskList.cc:212
eostools.move
def move
Definition: eostools.py:511
edm::ProducedProductResolver::putProduct
void putProduct(std::unique_ptr< WrapperBase > edp) const override
Definition: ProductResolvers.cc:501
void edm::PuttableProductResolver::resetProductData_ ( bool  deleteEarly)
overrideprivatevirtual

Reimplemented from edm::DataManagingProductResolver.

Definition at line 417 of file ProductResolvers.cc.

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

417  {
418  if (not deleteEarly) {
419  prefetchRequested_ = false;
420  m_waitingTasks.reset();
421  }
422  DataManagingProductResolver::resetProductData_(deleteEarly);
423  }
edm::DataManagingProductResolver::resetProductData_
void resetProductData_(bool deleteEarly) override
Definition: ProductResolvers.cc:591
edm::PuttableProductResolver::prefetchRequested_
std::atomic< bool > prefetchRequested_
Definition: ProductResolvers.h:226
edm::WaitingTaskList::reset
void reset()
Resets access to the resource so that added tasks will wait.
Definition: WaitingTaskList.cc:53
ProductResolverBase::Resolution edm::PuttableProductResolver::resolveProduct_ ( Principal const &  principal,
bool  skipCurrentProcess,
SharedResourcesAcquirer *  sra,
ModuleCallingContext const *  mcc 
) const
overrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 355 of file ProductResolvers.cc.

References Resolution.

358  {
359  if (!skipCurrentProcess) {
360  //'false' means never call the lambda function
361  return resolveProductImpl<false>([]() { return; });
362  }
363  return Resolution(nullptr);
364  }
void edm::PuttableProductResolver::setupUnscheduled ( UnscheduledConfigurator const &  iConfigure)
finalvirtual

Reimplemented from edm::ProductResolverBase.

Definition at line 425 of file ProductResolvers.cc.

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

425  {
426  worker_ = iConfigure.findWorker(branchDescription().moduleLabel());
427  }
edm::ProductResolverBase::branchDescription
BranchDescription const & branchDescription() const
Definition: ProductResolverBase.h:110
edm::ProductResolverBase::moduleLabel
std::string const & moduleLabel() const
Definition: ProductResolverBase.h:119
bool edm::PuttableProductResolver::unscheduledWasNotRun_ ( ) const
inlineoverrideprivatevirtual

Implements edm::ProductResolverBase.

Definition at line 219 of file ProductResolvers.h.

219 { return false; }

Member Data Documentation

WaitingTaskList edm::PuttableProductResolver::m_waitingTasks
mutableprivate

Definition at line 224 of file ProductResolvers.h.

Referenced by prefetchAsync_(), putProduct(), and resetProductData_().

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

Definition at line 226 of file ProductResolvers.h.

Referenced by prefetchAsync_(), putProduct(), and resetProductData_().

Worker* edm::PuttableProductResolver::worker_
private

Definition at line 225 of file ProductResolvers.h.

Referenced by prefetchAsync_(), and setupUnscheduled().

Generated for CMSSW Reference Manual by doxygen 1.8.5