Skip to content
This repository was archived by the owner on Oct 22, 2024. It is now read-only.

Commit

Permalink
🔊 Fix value of retention duration log
Browse files Browse the repository at this point in the history
  • Loading branch information
TilBlechschmidt committed Mar 18, 2021
1 parent fcc1cfc commit 428c661
Showing 1 changed file with 20 additions and 6 deletions.
26 changes: 20 additions & 6 deletions core/src/services/gc/jobs/garbage_collector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -28,12 +28,7 @@ impl Job for GarbageCollectorJob {
manager.ready().await;
yield_now().await;

info!(
"Retaining session metadata for {}D {}H {}M",
self.session_retention_duration.num_days(),
self.session_retention_duration.num_hours(),
self.session_retention_duration.num_minutes()
);
self.log_retention_duration();

let mut interval = interval(Duration::from_secs(600));

Expand Down Expand Up @@ -62,6 +57,25 @@ impl GarbageCollectorJob {
}
}

fn log_retention_duration(&self) {
let days = self.session_retention_duration.num_days();
let hours = self.session_retention_duration.num_hours();
let minutes = self.session_retention_duration.num_minutes();

if days > 0 {
info!("Retaining session metadata for {} days", days);
} else if hours > 0 {
info!("Retaining session metadata for {} hours", hours);
} else if minutes > 0 {
info!("Retaining session metadata for {} minutes", minutes);
} else {
info!(
"Retaining session metadata for {} seconds",
self.session_retention_duration.num_seconds()
);
}
}

async fn terminate_dead_sessions(&self, manager: TaskManager<Context>) -> Result<usize> {
// Fetch active sessions
let mut con = with_shared_redis_resource!(manager);
Expand Down

0 comments on commit 428c661

Please sign in to comment.