Skip to content

Commit

Permalink
Release dependent modules only after the worker has finished for sche…
Browse files Browse the repository at this point in the history
…duled modules
  • Loading branch information
makortel committed Aug 29, 2022
1 parent e2a21d3 commit edbadba
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 9 deletions.
8 changes: 0 additions & 8 deletions FWCore/Framework/src/ProductResolvers.cc
Original file line number Diff line number Diff line change
Expand Up @@ -430,14 +430,6 @@ namespace edm {
}
}

void PuttableProductResolver::putProduct(std::unique_ptr<WrapperBase> edp) const {
ProducedProductResolver::putProduct(std::move(edp));
bool expected = false;
if (prefetchRequested_.compare_exchange_strong(expected, true)) {
m_waitingTasks.doneWaiting(std::exception_ptr());
}
}

void PuttableProductResolver::resetProductData_(bool deleteEarly) {
if (not deleteEarly) {
prefetchRequested_ = false;
Expand Down
1 change: 0 additions & 1 deletion FWCore/Framework/src/ProductResolvers.h
Original file line number Diff line number Diff line change
Expand Up @@ -218,7 +218,6 @@ namespace edm {
ModuleCallingContext const* mcc) const override;
bool unscheduledWasNotRun_() const override { return false; }

void putProduct(std::unique_ptr<WrapperBase> edp) const override;
void resetProductData_(bool deleteEarly) override;

CMS_THREAD_SAFE mutable WaitingTaskList m_waitingTasks;
Expand Down

0 comments on commit edbadba

Please sign in to comment.