fix(purger): Fix the purger loop (#337)

rockset · Oct 16, 2024 · adb9f1a · adb9f1a
1 parent bfd97aa
commit adb9f1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cloud/purge.cc b/cloud/purge.cc
@@ -34,7 +34,7 @@ void CloudFileSystemImpl::Purger() {
 
   while (true) {
     std::unique_lock<std::mutex> lk(purger_lock_);
-    purger_cv_.wait_for(lk, period, [&]() { return purger_is_running_; });
+    purger_cv_.wait_for(lk, period, [&]() { return !purger_is_running_; });
     if (!purger_is_running_) {
       break;
     }