From ef55529994c6e48cd69b9e513df52b8410c50122 Mon Sep 17 00:00:00 2001 From: Andrew Whitehead Date: Fri, 12 Aug 2022 15:58:48 -0700 Subject: [PATCH] update rand to 0.8 Signed-off-by: Andrew Whitehead --- Cargo.toml | 4 ++-- examples/stock_server.rs | 2 +- examples/task_ventilator.rs | 2 +- examples/weather_server.rs | 6 +++--- src/util.rs | 2 +- 5 files changed, 8 insertions(+), 8 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index ba54f0e..0e4709e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -21,7 +21,7 @@ futures = "0.3" futures-util = "0.3" async-trait = "0.1" parking_lot = "0.11" -rand = "0.7" +rand = "0.8" bytes = "1" tokio = { version = "1", features = ["full"], optional = true } tokio-util = { version = "0.6", features = ["compat"], optional = true } @@ -40,7 +40,7 @@ async-std = { version = "1", features = ["attributes"], optional = true } chrono = "0.4" criterion = "0.3" pretty_env_logger = "0.4" -zmq2= "0.5.0" +zmq2 = "0.5.0" hex = "0.4.3" diff --git a/examples/stock_server.rs b/examples/stock_server.rs index 483a6ad..01f5a6f 100644 --- a/examples/stock_server.rs +++ b/examples/stock_server.rs @@ -15,7 +15,7 @@ async fn main() -> Result<(), Box> { println!("Start sending loop"); loop { for stock in &stocks { - let price: u32 = rng.gen_range(1, 100); + let price: u32 = rng.gen_range(1..100); let mut m: ZmqMessage = ZmqMessage::from(*stock); m.push_back(price.to_ne_bytes().to_vec().into()); dbg!(m.clone()); diff --git a/examples/task_ventilator.rs b/examples/task_ventilator.rs index 71ef472..e268835 100644 --- a/examples/task_ventilator.rs +++ b/examples/task_ventilator.rs @@ -26,7 +26,7 @@ async fn main() -> Result<(), Box> { let mut rnd = rand::thread_rng(); let mut total_msec = 0; for _ in 0..100 { - let workload = rnd.gen_range(1, 100); + let workload = rnd.gen_range(1..100); sender.send(workload.to_string().into()).await?; total_msec += workload; } diff --git a/examples/weather_server.rs b/examples/weather_server.rs index fa71eb7..ef60c4a 100644 --- a/examples/weather_server.rs +++ b/examples/weather_server.rs @@ -14,9 +14,9 @@ async fn main() -> Result<(), Box> { println!("Start sending loop"); loop { - let zipcode = rng.gen_range(10000, 10010); - let temperature = rng.gen_range(-80, 135); - let relhumidity = rng.gen_range(10, 60); + let zipcode = rng.gen_range(10000..10010); + let temperature = rng.gen_range(-80..135); + let relhumidity = rng.gen_range(10..60); socket .send(format!("{} {} {}", zipcode, temperature, relhumidity).into()) .await?; diff --git a/src/util.rs b/src/util.rs index a5c3a3c..34dbb76 100644 --- a/src/util.rs +++ b/src/util.rs @@ -206,7 +206,7 @@ pub(crate) async fn connect_forever(endpoint: Endpoint) -> ZmqResult<(FramedIo, } let delay = { let mut rng = rand::thread_rng(); - std::f64::consts::E.pow(try_num as f64 / 3.0) + rng.gen_range(0.0f64, 0.1f64) + std::f64::consts::E.pow(try_num as f64 / 3.0) + rng.gen_range(0.0f64..0.1f64) }; async_rt::task::sleep(std::time::Duration::from_secs_f64(delay)).await; continue;