Lines Matching refs:acquire

10     assert_ready_ok!(task::spawn(s.acquire(1)).poll());  in poll_acquire_one_available()
20 assert_ready_ok!(task::spawn(s.acquire(5)).poll()); in poll_acquire_many_available()
23 assert_ready_ok!(task::spawn(s.acquire(5)).poll()); in poll_acquire_many_available()
56 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_one_unavailable()
59 let mut acquire_2 = task::spawn(s.acquire(1)); in poll_acquire_one_unavailable()
80 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_many_unavailable()
84 let mut acquire_2 = task::spawn(s.acquire(5)); in poll_acquire_many_unavailable()
89 let mut acquire_3 = task::spawn(s.acquire(3)); in poll_acquire_many_unavailable()
159 let mut acquire = task::spawn(s.acquire(1)); in poll_acquire_one_zero_permits() localVariable
160 assert_pending!(acquire.poll()); in poll_acquire_one_zero_permits()
164 assert!(acquire.is_woken()); in poll_acquire_one_zero_permits()
165 assert_ready_ok!(acquire.poll()); in poll_acquire_one_zero_permits()
182 assert_ready_err!(task::spawn(s.acquire(1)).poll()); in close_semaphore_prevents_acquire()
185 assert_ready_err!(task::spawn(s.acquire(1)).poll()); in close_semaphore_prevents_acquire()
192 let mut acquire = task::spawn(s.acquire(1)); in close_semaphore_notifies_permit1() localVariable
194 assert_pending!(acquire.poll()); in close_semaphore_notifies_permit1()
198 assert!(acquire.is_woken()); in close_semaphore_notifies_permit1()
199 assert_ready_err!(acquire.poll()); in close_semaphore_notifies_permit1()
207 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in close_semaphore_notifies_permit2()
208 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in close_semaphore_notifies_permit2()
210 let mut acquire3 = task::spawn(s.acquire(1)); in close_semaphore_notifies_permit2()
211 let mut acquire4 = task::spawn(s.acquire(1)); in close_semaphore_notifies_permit2()
229 assert_ready_err!(task::spawn(s.acquire(1)).poll()); in close_semaphore_notifies_permit2()
242 let mut acquire = task::spawn(s.acquire(8)); in cancel_acquire_releases_permits() localVariable
243 assert_pending!(acquire.poll()); in cancel_acquire_releases_permits()
246 drop(acquire); in cancel_acquire_releases_permits()