Fix an earlier fix to algorithm::traverse, where the earlier fix was …

…obviously broken.
ned14 · May 11, 2021 · bfef269 · bfef269
1 parent aaac3b0
commit bfef269
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/include/llfio/v2.0/detail/impl/traverse.ipp b/include/llfio/v2.0/detail/impl/traverse.ipp
@@ -415,11 +415,11 @@ namespace algorithm
                     state.threads_sleeping++;
                     maincond.notify_all();
                     cond.wait(g);
+                    state.threads_sleeping--;
                     if(done)
                     {
                       break;
                     }
-                    state.threads_sleeping--;
                   }
                   else
                   {
@@ -441,6 +441,7 @@ namespace algorithm
                     break;
                   }
                 }
+                state.threads_sleeping++;
                 state.threads_running--;
                 maincond.notify_all();
               },
@@ -449,7 +450,7 @@ namespace algorithm
           }
           {
             std::unique_lock<std::mutex> g(state.lock);
-            while(state.threads_sleeping < threads)
+            while(state.threads_sleeping < threads && !done)
             {
               maincond.wait(g);
             }