diff --git a/db/column_family.cc b/db/column_family.cc index fabe7ac21..c290594c9 100644 --- a/db/column_family.cc +++ b/db/column_family.cc @@ -1143,7 +1143,7 @@ void ColumnFamilyData::SetL0BaseCompactionSpeed(uint64_t l0_bytes_compacted) { void ColumnFamilyData::MaybeStartL0L1Timer() { auto* vstorage = current_->storage_info(); // start timer for L0 clearance when trigger passed. - if (!started_l0_timer_ && vstorage->IsL0ScoreAbove1()) { + if (!started_l0_timer_ && vstorage->IsL0Score1AndAbove()) { started_l0_timer_ = true; l0_start_clearance_time_ = ioptions_.clock->NowMicros(); ROCKS_LOG_INFO(ioptions_.logger, diff --git a/db/version_set.cc b/db/version_set.cc index 4bd9ff5b2..f914882c4 100644 --- a/db/version_set.cc +++ b/db/version_set.cc @@ -3631,14 +3631,14 @@ void VersionStorageInfo::ComputeCompactionScore( EstimateCompactionBytesNeeded(mutable_cf_options); } -bool VersionStorageInfo::IsL0ScoreAbove1() { +bool VersionStorageInfo::IsL0Score1AndAbove() { if (!finalized_) { return false; } for (size_t i = 0; i < compaction_level_.size(); i++) { if (compaction_level_[i] == 0) { - return compaction_score_[i] > 1; + return compaction_score_[i] >= 1; } } return false; diff --git a/db/version_set.h b/db/version_set.h index d1e29adfb..474cc9d76 100644 --- a/db/version_set.h +++ b/db/version_set.h @@ -609,7 +609,7 @@ class VersionStorageInfo { return bottommost_files_mark_threshold_; } - bool IsL0ScoreAbove1(); + bool IsL0Score1AndAbove(); // Returns whether any key in [`smallest_key`, `largest_key`] could appear in // an older L0 file than `last_l0_idx` or in a greater level than `last_level`