compute compaction score once for a batch of range file deletes (#316)

Signed-off-by: tabokie <[email protected]> Signed-off-by: tabokie <[email protected]>
tikv · Sep 26, 2022 · ce0ea61 · ce0ea61
1 parent 6a7472a
commit ce0ea61
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/db/db_impl/db_impl.cc b/db/db_impl/db_impl.cc
@@ -3859,10 +3859,12 @@ Status DBImpl::DeleteFilesInRanges(ColumnFamilyHandle* column_family,
           deleted_files.insert(level_file);
           level_file->being_compacted = true;
         }
-        vstorage->ComputeCompactionScore(*cfd->ioptions(),
-                                         *cfd->GetLatestMutableCFOptions());
       }
     }
+    if (!deleted_files.empty()) {
+      vstorage->ComputeCompactionScore(*cfd->ioptions(),
+                                       *cfd->GetLatestMutableCFOptions());
+    }
     if (edit.GetDeletedFiles().empty()) {
       job_context.Clean();
       return status;