#34: set purges as Pri::Low

speedb-io · Sep 6, 2022 · ead8128 · ead8128
1 parent 8554fcf
commit ead8128
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/db/db_impl/db_impl.cc b/db/db_impl/db_impl.cc
@@ -1540,9 +1540,9 @@ void DBImpl::SchedulePurge() {
   mutex_.AssertHeld();
   assert(opened_successfully_);
 
-  // Purge operations are put into High priority queue
+  // Purge operations are put into the low priority queue
   bg_purge_scheduled_++;
-  env_->Schedule(&DBImpl::BGWorkPurge, this, Env::Priority::HIGH, nullptr);
+  env_->Schedule(&DBImpl::BGWorkPurge, this, Env::Priority::LOW, nullptr);
 }
 
 void DBImpl::BackgroundCallPurge() {

diff --git a/db/db_impl/db_impl_compaction_flush.cc b/db/db_impl/db_impl_compaction_flush.cc
@@ -2661,7 +2661,7 @@ void DBImpl::BGWorkBottomCompaction(void* arg) {
 }
 
 void DBImpl::BGWorkPurge(void* db) {
-  IOSTATS_SET_THREAD_POOL_ID(Env::Priority::HIGH);
+  IOSTATS_SET_THREAD_POOL_ID(Env::Priority::LOW);
   TEST_SYNC_POINT("DBImpl::BGWorkPurge:start");
   reinterpret_cast<DBImpl*>(db)->BackgroundCallPurge();
   TEST_SYNC_POINT("DBImpl::BGWorkPurge:end");