rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2025-12-26 08:00:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: saturating duration since (#7380)

Browse Source 
chore: sat duration since

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2025-12-10 15:10:46 +08:00
committed by GitHub
parent 9f1aefe98f
commit 4d1a587079
3 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/meta-srv/src/gc/candidate.rs
View File

@@ -88,7 +88,8 @@ impl GcScheduler {
// Skip regions that are in cooldown period
if let Some(gc_info) = tracker.get(&region_stat.id)
&& now.duration_since(gc_info.last_gc_time) < self.config.gc_cooldown_period
&& now.saturating_duration_since(gc_info.last_gc_time)
< self.config.gc_cooldown_period
{
debug!("Skipping region {} due to cooldown", region_stat.id);
continue;

2
src/meta-srv/src/gc/handler.rs
View File

@@ -434,7 +434,7 @@ impl GcScheduler {
if let Some(gc_info) = gc_tracker.get(&region_id) {
if let Some(last_full_listing) = gc_info.last_full_listing_time {
// check if pass cooling down interval after last full listing
let elapsed = now.duration_since(last_full_listing);
let elapsed = now.saturating_duration_since(last_full_listing);
elapsed >= self.config.full_file_listing_interval
} else {
// Never did full listing for this region, do it now

2
src/meta-srv/src/gc/tracker.rs
View File

@@ -92,7 +92,7 @@ impl GcScheduler {
if let Some(gc_info) = gc_tracker.get(&region_id) {
if let Some(last_full_listing) = gc_info.last_full_listing_time {
let elapsed = now.duration_since(last_full_listing);
let elapsed = now.saturating_duration_since(last_full_listing);
elapsed >= self.config.full_file_listing_interval
} else {
// Never did full listing for this region, do it now