Searched refs:fut1 (Results 1 – 8 of 8) sorted by relevance
| /external/libchromeos-rs/src/sync/ |
| D | cv.rs | 1021 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_before_notify() localVariable
1024 if let Poll::Ready(()) = fut1.as_mut().poll(&mut cx) { in cancel_before_notify()
1034 mem::drop(fut1); in cancel_before_notify()
1066 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify() localVariable
1069 if let Poll::Ready(()) = fut1.as_mut().poll(&mut cx) { in cancel_after_notify()
1081 mem::drop(fut1); in cancel_after_notify()
1110 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer() localVariable
1113 if let Poll::Ready(()) = fut1.as_mut().poll(&mut cx) { in cancel_after_transfer()
1131 mem::drop(fut1); in cancel_after_transfer()
1165 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer_and_wake() localVariable
[all …]
|
| D | mu.rs | 1850 let mut fut1 = Box::pin(inc(mu.clone())); in cancel_before_wake() localVariable
1863 match fut1.as_mut().poll(&mut cx) { in cancel_before_wake()
1879 mem::drop(fut1); in cancel_before_wake()
1913 let mut fut1 = Box::pin(inc(mu.clone())); in cancel_after_wake() localVariable
1926 match fut1.as_mut().poll(&mut cx) { in cancel_after_wake()
1945 mem::drop(fut1); in cancel_after_wake()
|
| /external/rust/crates/tokio/src/signal/ |
| D | reusable_box.rs | 185 let fut1 = async move { 10 }; in test_different_sizes() localVariable
190 assert_eq!(Layout::for_value(&fut1).size(), 1); in test_different_sizes()
194 let mut b = ReusableBoxFuture::new(fut1); in test_different_sizes()
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 985 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_before_notify() localVariable
988 if let Poll::Ready(()) = fut1.as_mut().poll(&mut cx) { in cancel_before_notify()
998 mem::drop(fut1); in cancel_before_notify()
1030 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify_one() localVariable
1033 if let Poll::Ready(()) = fut1.as_mut().poll(&mut cx) { in cancel_after_notify_one()
1045 mem::drop(fut1); in cancel_after_notify_one()
1074 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify_all() localVariable
1077 if let Poll::Ready(()) = fut1.as_mut().poll(&mut cx) { in cancel_after_notify_all()
1094 mem::drop(fut1); in cancel_after_notify_all()
|
| D | mu.rs | 1730 let mut fut1 = Box::pin(inc(mu.clone())); in cancel_before_wake() localVariable
1743 match fut1.as_mut().poll(&mut cx) { in cancel_before_wake()
1759 mem::drop(fut1); in cancel_before_wake()
1793 let mut fut1 = Box::pin(inc(mu.clone())); in cancel_after_wake() localVariable
1806 match fut1.as_mut().poll(&mut cx) { in cancel_after_wake()
1825 mem::drop(fut1); in cancel_after_wake()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_rwlock.rs | 160 let fut1 = rwlock.write().map(|mut guard| guard.push(1)); in write_order() localVariable
161 fut1.await; in write_order()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 742 fut1 = self.new_future(self.loop)
746 await fut1
754 self.assertIs(t._fut_waiter, fut1) # White-box test.
755 fut1.set_result(None)
765 fut1 = self.new_future(self.loop)
770 await fut1
780 self.assertIs(t._fut_waiter, fut1) # White-box test.
781 fut1.set_result(None)
2033 fut1 = self.new_future(self.loop)
2038 await fut1
[all …]
|
| D | test_proactor_events.py | 426 fut1 = self.loop.create_future()
427 self.loop._proactor.send.return_value = fut1
|