fix a bug

krypdkat · krypdkat · commit d41e427e3fbf · 2026-02-24T21:34:01.000+07:00
diff --git a/database/garbageCleaner.cpp b/database/garbageCleaner.cpp
@@ -28,12 +28,12 @@ bool cleanTransactionAndLogsAndSaveToDisk(TickData& td, LogRangesPerTxInTick& lr
     lr.getMinMax(min_log_id, max_log_id);
     if (min_log_id != -1 && max_log_id != -1)
     {
-        if (!db_move_logs_to_kvrocks_by_range(td.epoch, min_log_id, max_log_id - 1))
+        if (!db_move_logs_to_kvrocks_by_range(gCurrentProcessingEpoch, min_log_id, max_log_id - 1))
         {
-            Logger::get()->error("Failed to move logs to kvrocks for tick {} - epoch {}", td.tick, td.epoch);
+            Logger::get()->error("Failed to move logs to kvrocks for tick {} - epoch {}", td.tick, gCurrentProcessingEpoch);
             return false;
         }
-        db_delete_logs(td.epoch, min_log_id, max_log_id - 1);
+        db_delete_logs(gCurrentProcessingEpoch, min_log_id, max_log_id - 1);
     }
     return true;
 }

Original file line number	Diff line number	Diff line change
`@@ -28,12 +28,12 @@ bool cleanTransactionAndLogsAndSaveToDisk(TickData& td, LogRangesPerTxInTick& lr`
`28`	`28`	`lr.getMinMax(min_log_id, max_log_id);`
`29`	`29`	`if (min_log_id != -1 && max_log_id != -1)`
`30`	`30`	`{`
`31`		`- if (!db_move_logs_to_kvrocks_by_range(td.epoch, min_log_id, max_log_id - 1))`
	`31`	`+ if (!db_move_logs_to_kvrocks_by_range(gCurrentProcessingEpoch, min_log_id, max_log_id - 1))`
`32`	`32`	`{`
`33`		`- Logger::get()->error("Failed to move logs to kvrocks for tick {} - epoch {}", td.tick, td.epoch);`
	`33`	`+ Logger::get()->error("Failed to move logs to kvrocks for tick {} - epoch {}", td.tick, gCurrentProcessingEpoch);`
`34`	`34`	`return false;`
`35`	`35`	`}`
`36`		`- db_delete_logs(td.epoch, min_log_id, max_log_id - 1);`
	`36`	`+ db_delete_logs(gCurrentProcessingEpoch, min_log_id, max_log_id - 1);`
`37`	`37`	`}`
`38`	`38`	`return true;`
`39`	`39`	`}`