diff --git a/src/service/rate_limiting/mod.rs b/src/service/rate_limiting/mod.rs index bfe7746a..387a17fa 100644 --- a/src/service/rate_limiting/mod.rs +++ b/src/service/rate_limiting/mod.rs @@ -78,7 +78,7 @@ impl Service { tracing::info!(?limit); - let increment = 1_000_000_000u64 / limit.timeframe.nano_gap() * limit.weight.get(); + let increment = limit.timeframe.nano_gap() * limit.weight.get(); tracing::info!(?increment); let mut prev_expectation = self @@ -87,7 +87,7 @@ impl Service { .as_deref() .map(|n| n.load(Ordering::Acquire)) .unwrap_or_else(|| arrival + increment); - let weight = (increment * limit.burst_capacity.get()).max(1); + let weight = increment * limit.burst_capacity.get(); tracing::info!(?prev_expectation); tracing::info!(?weight);