Start timer when L0 score is 1 and greater.

speedb-io · Mar 7, 2024 · f1230f9 · f1230f9
1 parent 4506ef9
commit f1230f9
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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`