diff --git a/db/db_impl/db_impl.cc b/db/db_impl/db_impl.cc index cae9276497..d8f682ac28 100644 --- 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 index 3efe1e1c82..fe43d3c629 100644 --- 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(db)->BackgroundCallPurge(); TEST_SYNC_POINT("DBImpl::BGWorkPurge:end");