diff --git a/libsabledb/src/replication/cluster_manager.rs b/libsabledb/src/replication/cluster_manager.rs index 3e8cb60..4dc17b5 100644 --- a/libsabledb/src/replication/cluster_manager.rs +++ b/libsabledb/src/replication/cluster_manager.rs @@ -73,8 +73,8 @@ static START: Once = Once::new(); impl ClusterManager { pub fn with_options(options: Arc>) -> Self { START.call_once(|| { - let mut rng = rand::thread_rng(); - let us = rng.gen_range(5000000..10_000000); + let mut rng = rand::rng(); + let us = rng.random_range(5000000..10_000000); CHECK_PRIMARY_ALIVE_INTERVAL.store(us, Ordering::Relaxed); tracing::info!( "Check primary interval is set to {} microseconds", diff --git a/libsabledb/src/server/worker.rs b/libsabledb/src/server/worker.rs index 579a41e..e71b645 100644 --- a/libsabledb/src/server/worker.rs +++ b/libsabledb/src/server/worker.rs @@ -161,12 +161,12 @@ impl Worker { // pick reporting interval for this worker to avoid all workers // contesting for the same lock - let mut rng = rand::thread_rng(); - let secs = rng.gen_range(1..3); - let nanos = rng.gen_range(0..u32::MAX); + let mut rng = rand::rng(); + let secs = rng.random_range(1..3); + let nanos = rng.random_range(0..u32::MAX); // Tick task should be triggered in a random time for every worker - let tick_interval_micros = rng.gen_range(100000..150000); + let tick_interval_micros = rng.random_range(100000..150000); // create the TLS acceptor for this thread let acceptor = if self diff --git a/libsabledb/src/utils/mod.rs b/libsabledb/src/utils/mod.rs index a57c9ad..b8cf1d9 100644 --- a/libsabledb/src/utils/mod.rs +++ b/libsabledb/src/utils/mod.rs @@ -624,7 +624,7 @@ pub fn choose_multiple_values( options: &[usize], allow_dups: bool, ) -> Result, SableError> { - let mut rng = rand::thread_rng(); + let mut rng = rand::rng(); let mut chosen = Vec::::new(); if allow_dups { for _ in 0..count { @@ -643,7 +643,7 @@ pub fn choose_multiple_values( break; } - let pos = rng.gen_range(0..unique_values.len()); + let pos = rng.random_range(0..unique_values.len()); let Some(val) = unique_values.get(pos) else { return Err(SableError::OtherError(format!( "Internal error: failed to read from vector (len: {}, pos: {})",