diff --git a/tpu-client/src/quic_client.rs b/tpu-client/src/quic_client.rs index d0a8cd1bdb..f11b7f32b7 100644 --- a/tpu-client/src/quic_client.rs +++ b/tpu-client/src/quic_client.rs @@ -51,7 +51,7 @@ impl AsyncTaskSemaphore { fn acquire(&self) -> MutexGuard { let mut count = self.counter.lock().unwrap(); *count += 1; - while *count >= self.permits { + while *count > self.permits { count = self.cond_var.wait(count).unwrap(); } count