itsscb/tower
1
0
Fork 0
mirror of https://github.com/tower-rs/tower.git synced 2025-09-27 13:00:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bump rand to v0.9 (#811)

Browse Source
This commit is contained in:
Paolo Barbolini 2025-07-03 09:52:53 +02:00 committed by GitHub
parent 50d839d3b0
commit fe3156587c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Cargo.toml
View File

@ -16,7 +16,7 @@ http = "1"
indexmap = "2.0.2"
pin-project-lite = "0.2.7"
quickcheck = "1"
rand = "0.8"
rand = "0.9"
slab = "0.4.9"
sync_wrapper = "1"
tokio = "1.6.2"

2
examples/Cargo.toml
View File

@ -10,7 +10,7 @@ edition = "2018"
tower = { version = "0.4", path = "../tower", features = ["full"] }
tower-service = "0.3"
tokio = { version = "1.0", features = ["full"] }
rand = "0.8"
rand = "0.9"
pin-project = "1.0"
futures = "0.3.22"
tracing = "0.1"

3
tower/examples/tower-balance.rs
View File

@ -4,7 +4,6 @@ use futures_core::{Stream, TryStream};
use futures_util::{stream, stream::StreamExt, stream::TryStreamExt};
use hdrhistogram::Histogram;
use pin_project_lite::pin_project;
use rand::{self, Rng};
use std::hash::Hash;
use std::time::Duration;
use std::{
@ -124,7 +123,7 @@ fn gen_disco() -> impl Discover<
let maxms = u64::from(latency.subsec_millis())
.saturating_add(latency.as_secs().saturating_mul(1_000));
let latency = Duration::from_millis(rand::thread_rng().gen_range(0..maxms));
let latency = Duration::from_millis(rand::random_range(0..maxms));
async move {
time::sleep_until(start + latency).await;

9
tower/tests/balance/main.rs
View File

@ -28,7 +28,7 @@ impl Service<Req> for Mock {
impl tower::load::Load for Mock {
type Metric = usize;
fn load(&self) -> Self::Metric {
rand::random()
rand::random_range(usize::MIN..=usize::MAX)
}
}
@ -43,7 +43,7 @@ fn stress() {
let mut services = slab::Slab::<(mock::Handle<Req, Req>, bool)>::new();
let mut retired = Vec::<mock::Handle<Req, Req>>::new();
for _ in 0..100_000 {
for _ in 0..(rand::random::<u8>() % 8) {
for _ in 0..rand::random_range(0u8..8) {
if !services.is_empty() && rand::random() {
if nready == 0 || rand::random::<u8>() > u8::MAX / 4 {
// ready a service
@ -114,8 +114,7 @@ fn stress() {
} else {
// remove
while !services.is_empty() {
let k =
rand::random::<usize>() % (services.iter().next_back().unwrap().0 + 1);
let k = rand::random_range(0..=services.iter().next_back().unwrap().0);
if services.contains(k) {
let (handle, ready) = services.remove(k);
if ready {
@ -130,7 +129,7 @@ fn stress() {
} else {
// fail a service
while !services.is_empty() {
let k = rand::random::<usize>() % (services.iter().next_back().unwrap().0 + 1);
let k = rand::random_range(0..=services.iter().next_back().unwrap().0);
if services.contains(k) {
let (mut handle, ready) = services.remove(k);
if ready {