From 4290d68c935bc169c5234deab710f7a50f20a103 Mon Sep 17 00:00:00 2001 From: Mikail Bagishov Date: Tue, 18 Aug 2020 11:55:55 +0300 Subject: [PATCH] fix coop-related bug --- tokio/src/sync/mpsc/chan.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tokio/src/sync/mpsc/chan.rs b/tokio/src/sync/mpsc/chan.rs index e4f89b908f9..5eddbd3ad92 100644 --- a/tokio/src/sync/mpsc/chan.rs +++ b/tokio/src/sync/mpsc/chan.rs @@ -370,7 +370,7 @@ impl Semaphore for (crate::sync::batch_semaphore::Semaphore, usize) { let waker = crate::util::waker_ref(&waker); let mut noop_cx = std::task::Context::from_waker(&*waker); let mut permit = Permit::new(); - match self.poll_acquire(&mut noop_cx, &mut permit) { + match permit.poll_acquire(&mut noop_cx, 1, &self.0) { Poll::Ready(Err(_)) => true, Poll::Ready(Ok(())) => { permit.release(1, &self.0);