Searched defs:permit (Results 1 – 7 of 7) sorted by relevance
33 let permit = tx.reserve().await.unwrap(); in send_recv_with_buffer() localVariable269 let permit = assert_ready_ok!(p2.poll()); in send_recv_buffer_limited() localVariable367 let permit = tx.try_reserve().unwrap(); in try_reserve_fails() localVariable380 let permit = tx.try_reserve().unwrap(); in try_reserve_fails() localVariable394 let permit = assert_ok!(tx1.reserve().await); in drop_permit_releases_permit() localVariable510 let permit = assert_ok!(tx.reserve().await); in ready_close_cancel_bounded() localVariable
29 let permit = sem.acquire().await.unwrap(); in it_works() localVariable78 let permit = sem.acquire_many(4).await.unwrap(); in can_poll_different_amounts_of_permits() localVariable
33 var permit = false variable
154 let permit = ctx.sem.acquire().await; in try_recv() localVariable
417 public NettyServerBuilder permitKeepAliveWithoutCalls(boolean permit) { in permitKeepAliveWithoutCalls()
650 let permit = match crate::time::timeout(timeout, self.reserve()).await { in send_timeout() localVariable
161 int permit; /* 1 = permit, 0 = forbid */ member