bug fix

ajkr · Apr 24, 2024 · 0e2f7b3 · 0e2f7b3
1 parent 5e2140b
commit 0e2f7b3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/db/db_impl/db_impl_compaction_flush.cc b/db/db_impl/db_impl_compaction_flush.cc
@@ -2175,9 +2175,6 @@ Status DBImpl::RunManualCompaction(
               Status::Incomplete(Status::SubCode::kManualCompactionPaused);
         }
       }
-      if (!manual.done) {
-        bg_cv_.Wait();
-      }
       if (manual_compaction_paused_ > 0 && scheduled && !unscheduled) {
         assert(thread_pool_priority != Env::Priority::TOTAL);
         // unschedule all manual compactions
@@ -2195,6 +2192,9 @@ Status DBImpl::RunManualCompaction(
         unscheduled = true;
         TEST_SYNC_POINT("DBImpl::RunManualCompaction:Unscheduled");
       }
+      if (!manual.done) {
+        bg_cv_.Wait();
+      }
       if (scheduled && manual.incomplete == true) {
         assert(!manual.in_progress);
         scheduled = false;