diff --git a/cli/src/main.rs b/cli/src/main.rs index 8206eaf..801bd19 100644 --- a/cli/src/main.rs +++ b/cli/src/main.rs @@ -1830,8 +1830,7 @@ fn fuzz( Ok(()) } - let distr = - WeightedAliasIndex::new(vec![550u32, 450, 40000, 20000, 20000, 30000, 100, 10]).unwrap(); + let distr = WeightedAliasIndex::new(vec![550u32, 450]).unwrap(); let entry_size_distr = LogNormal::from_mean_cv(f64::from(mean_size), f64::from(cv_size)).unwrap(); let mut rng = Xoshiro256PlusPlus::seed_from_u64(seed); diff --git a/server/src/reactor.rs b/server/src/reactor.rs index 07bc15b..0b1cd3c 100644 --- a/server/src/reactor.rs +++ b/server/src/reactor.rs @@ -485,7 +485,7 @@ pub fn run(allocator: &mut Allocator) -> Result<(), CliError> { } // TODO pending closes: https://github.com/axboe/liburing/issues/1193 - if pending_accept && clients.pending_closes == 0 { + if pending_accept { info!("Restoring ability to accept new clients."); pending_entries.push(accept.clone()); pending_accept = false;