#1942: add isActive() for other epochs

DARMA-tasking · Sep 27, 2022 · 86278ca · 86278ca
1 parent d4afc7b
commit 86278ca
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/vt/termination/termination.cc b/src/vt/termination/termination.cc
@@ -172,7 +172,7 @@ TerminationDetector::getDSTerm(EpochType epoch, bool is_root) {
 }
 
 void TerminationDetector::maybePropagate() {
-  if (any_epoch_state_.readySubmitParent()) {
+  if (any_epoch_state_.isActive() and any_epoch_state_.readySubmitParent()) {
     propagateEpoch(any_epoch_state_);
   }
 
@@ -181,7 +181,7 @@ void TerminationDetector::maybePropagate() {
   }
 
   for (auto&& state : epoch_state_) {
-    if (state.second.readySubmitParent()) {
+    if (state.second.isActive() and state.second.readySubmitParent()) {
       propagateEpoch(state.second);
     }
   }
@@ -202,7 +202,7 @@ void TerminationDetector::propagateEpochExternalState(
 
   state.notifyChildReceive();
 
-  if (state.readySubmitParent()) {
+  if (state.isActive() and state.readySubmitParent()) {
     propagateEpoch(state);
   }
 }

diff --git a/src/vt/termination/termination.impl.h b/src/vt/termination/termination.impl.h
@@ -97,7 +97,7 @@ inline void TerminationDetector::produceConsumeState(
     print_bool(produce)
   );
 
-  if (state.readySubmitParent()) {
+  if (state.isActive() and state.readySubmitParent()) {
     propagateEpoch(state);
   }
 }