Check the boundary condition correctly.

2022-10-19 12:22:20 -07:00 · 2022-10-19 12:22:20 -07:00 · 03f4204297
parent ab85ab7a5b
commit 03f4204297
1 changed files with 1 additions and 1 deletions
--- a/tpu-client/src/quic_client.rs
+++ b/tpu-client/src/quic_client.rs
@ -51,7 +51,7 @@ impl AsyncTaskSemaphore {
    fn acquire(&self) -> MutexGuard<u64> {
        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