Searched refs:fut2 (Results 1 – 7 of 7) sorted by relevance
1022 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_before_notify() localVariable1027 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_before_notify()1040 if let Poll::Pending = fut2.as_mut().poll(&mut cx) { in cancel_before_notify()1067 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify() localVariable1072 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_after_notify()1084 if let Poll::Pending = fut2.as_mut().poll(&mut cx) { in cancel_after_notify()1111 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer() localVariable1116 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_after_transfer()1133 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_after_transfer()1139 if let Poll::Pending = fut2.as_mut().poll(&mut cx) { in cancel_after_transfer()[all …]
1852 let mut fut2 = Box::pin(inc(mu.clone())); in cancel_before_wake() localVariable1868 match fut2.as_mut().poll(&mut cx) { in cancel_before_wake()1887 match fut2.as_mut().poll(&mut cx) { in cancel_before_wake()1895 match fut2.as_mut().poll(&mut cx) { in cancel_before_wake()1915 let mut fut2 = Box::pin(inc(mu.clone())); in cancel_after_wake() localVariable1931 match fut2.as_mut().poll(&mut cx) { in cancel_after_wake()1957 match fut2.as_mut().poll(&mut cx) { in cancel_after_wake()
187 let fut2 = async move { val[0] }; in test_different_sizes() localVariable191 assert_eq!(Layout::for_value(&fut2).size(), 4004); in test_different_sizes()196 b.set(fut2); in test_different_sizes()
986 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_before_notify() localVariable991 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_before_notify()1004 if fut2.as_mut().poll(&mut cx).is_pending() { in cancel_before_notify()1031 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify_one() localVariable1036 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_after_notify_one()1048 if fut2.as_mut().poll(&mut cx).is_pending() { in cancel_after_notify_one()1075 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify_all() localVariable1080 if let Poll::Ready(()) = fut2.as_mut().poll(&mut cx) { in cancel_after_notify_all()1096 if fut2.as_mut().poll(&mut cx).is_pending() { in cancel_after_notify_all()
1732 let mut fut2 = Box::pin(inc(mu.clone())); in cancel_before_wake() localVariable1748 match fut2.as_mut().poll(&mut cx) { in cancel_before_wake()1767 match fut2.as_mut().poll(&mut cx) { in cancel_before_wake()1775 match fut2.as_mut().poll(&mut cx) { in cancel_before_wake()1795 let mut fut2 = Box::pin(inc(mu.clone())); in cancel_after_wake() localVariable1811 match fut2.as_mut().poll(&mut cx) { in cancel_after_wake()1837 match fut2.as_mut().poll(&mut cx) { in cancel_after_wake()
159 let fut2 = rwlock.write().map(|mut guard| guard.push(2)); in write_order() localVariable162 fut2.await; in write_order()
743 fut2 = self.new_future(self.loop)748 await fut2757 self.assertIs(t._fut_waiter, fut2) # White-box test.759 self.assertTrue(fut2.cancelled())766 fut2 = self.new_future(self.loop)772 await fut2783 self.assertIs(t._fut_waiter, fut2) # White-box test.785 self.assertTrue(fut2.cancelled())2034 fut2 = self.new_future(self.loop)2040 fut2.set_result(True)[all …]