diff options
Diffstat (limited to 'crates/daemon/src/api/control.rs')
| -rw-r--r-- | crates/daemon/src/api/control.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/crates/daemon/src/api/control.rs b/crates/daemon/src/api/control.rs index 8277f434..16b4bd94 100644 --- a/crates/daemon/src/api/control.rs +++ b/crates/daemon/src/api/control.rs @@ -1,7 +1,7 @@ use std::time::Duration; use eyre::Result; -use rand::Rng; +use rand::RngExt; use tokio::time::{self, MissedTickBehavior}; use tonic::{Request, Response, Status}; use tracing::{Level, instrument}; @@ -149,7 +149,7 @@ async fn sync_loop(handle: DaemonHandle) { let history_store = HistoryStore::new(handle.store().clone(), host_id, encryption_key); // Don't backoff by more than 30 mins (with a random jitter of up to 1 min) - let max_interval: f64 = 60.0f64.mul_add(30.0, rand::thread_rng().gen_range(0.0..60.0)); + let max_interval: f64 = 60.0f64.mul_add(30.0, rand::rng().random_range(0.0..60.0)); let mut ticker = time::interval(Duration::from_secs(settings.daemon.sync_frequency)); @@ -242,8 +242,8 @@ async fn do_sync_tick( }); // Exponential backoff - let mut rng = rand::thread_rng(); - let mut new_interval = ticker.period().as_secs_f64() * rng.gen_range(2.0..2.2); + let mut rng = rand::rng(); + let mut new_interval = ticker.period().as_secs_f64() * rng.random_range(2.0..2.2); if new_interval > max_interval { new_interval = max_interval; |