Block global termination while spinning the scheduler for a particula…

…r epoch
DARMA-tasking · May 26, 2020 · 0dbd148 · 0dbd148
1 parent 778c136
commit 0dbd148
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/vt/scheduler/scheduler.cc b/src/vt/scheduler/scheduler.cc
@@ -314,7 +314,13 @@ void runScheduler() {
 }
 
 void runSchedulerThrough(EpochType epoch) {
+  // WARNING: This is to prevent global termination from spuriously
+  // thinking that the work done in this loop over the scheduler
+  // represents the entire work of the program, and thus leading to
+  // stuff being torn down
+  theTerm()->produce();
   theSched()->runSchedulerWhile([=]{ return !theTerm()->isEpochTerminated(epoch); });
+  theTerm()->consume();
 }
 
 } //end namespace vt