summaryrefslogtreecommitdiffstats
path: root/tokio/src/sync/batch_semaphore.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tokio/src/sync/batch_semaphore.rs')
-rw-r--r--tokio/src/sync/batch_semaphore.rs4
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
);