diff options
Diffstat (limited to 'tokio/src/sync/batch_semaphore.rs')
-rw-r--r-- | tokio/src/sync/batch_semaphore.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tokio/src/sync/batch_semaphore.rs b/tokio/src/sync/batch_semaphore.rs index 0b50e4f7..8736971a 100644 --- a/tokio/src/sync/batch_semaphore.rs +++ b/tokio/src/sync/batch_semaphore.rs @@ -253,9 +253,9 @@ impl Semaphore { } if rem > 0 && is_empty { - let permits = rem << Self::PERMIT_SHIFT; + let permits = rem; assert!( - permits < Self::MAX_PERMITS, + permits <= Self::MAX_PERMITS, "cannot add more than MAX_PERMITS permits ({})", Self::MAX_PERMITS ); |