| /external/rust/crates/futures-task/src/ |
| D | lib.rs | 41 mod waker_ref;
43 pub use crate::waker_ref::{waker_ref, WakerRef};
|
| D | waker_ref.rs | 58 pub fn waker_ref<W>(wake: &Arc<W>) -> WakerRef<'_> in waker_ref() function
|
| /external/rust/crates/futures-util/src/stream/futures_unordered/ |
| D | task.rs | 6 use crate::task::{ArcWake, WakerRef, waker_ref};
73 pub(super) fn waker_ref(this: &Arc<Self>) -> WakerRef<'_> { in waker_ref() method
74 waker_ref(this) in waker_ref()
|
| D | mod.rs | 536 let waker = Task::waker_ref(bomb.task.as_ref().unwrap()); in poll_next()
|
| /external/rust/crates/tokio/tests/ |
| D | io_driver.rs | 8 use futures::task::{waker_ref, ArcWake};
71 let waker = waker_ref(&task); in test_drop_on_notify()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | harness.rs | 3 use crate::runtime::task::waker::waker_ref;
87 let waker_ref = waker_ref::<T, S>(self.header()); in poll_inner() localVariable
88 let cx = Context::from_waker(&*waker_ref); in poll_inner()
|
| D | waker.rs | 18 pub(super) fn waker_ref<T, S>(header: &Header) -> WakerRef<'_, S> in waker_ref() function
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 5 use futures_task::{waker_ref, ArcWake};
84 let waker = waker_ref(thread_notify); in run_executor()
113 let waker = waker_ref(thread_notify); in poll_executor()
|
| D | thread_pool.rs | 6 use futures_task::{ArcWake, waker_ref};
317 let waker = waker_ref(&wake_handle); in run()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | shell.rs | 7 use crate::util::{waker_ref, Wake};
107 let waker = waker_ref(&self.shell.unpark); in block_on()
|
| D | basic_scheduler.rs | 8 use crate::util::{waker_ref, Wake, WakerRef};
204 let waker = scheduler.spawner.waker_ref(); in block_on()
396 fn waker_ref(&self) -> WakerRef<'_> { in waker_ref() method
399 waker_ref(&self.shared) in waker_ref()
|
| /external/libchromeos-rs/src/sync/ |
| D | blocking.rs | 12 use futures::task::{waker_ref, ArcWake};
66 let waker = waker_ref(thread_waker); in block_on()
|
| D | mu.rs | 1019 use futures::task::{waker_ref, ArcWake};
1509 let waker = waker_ref(&arc_waker); in wake_all_readers()
1596 let waker = waker_ref(&arc_waker); in long_wait()
1654 let waker = waker_ref(&arc_waker); in cancel_long_wait_before_wake()
1701 let waker = waker_ref(&arc_waker); in cancel_long_wait_after_wake()
1754 let waker = waker_ref(&arc_waker); in designated_waker()
1824 let waker = waker_ref(&arc_waker); in cancel_designated_waker()
1855 let waker = waker_ref(&arc_waker); in cancel_before_wake()
1918 let waker = waker_ref(&arc_waker); in cancel_after_wake()
1987 let waker = waker_ref(&arc_waker); in timeout()
[all …]
|
| D | cv.rs | 490 use futures::task::{waker_ref, ArcWake};
975 let waker = waker_ref(&arc_waker); in wake_all_readers()
1018 let waker = waker_ref(&arc_waker); in cancel_before_notify()
1063 let waker = waker_ref(&arc_waker); in cancel_after_notify()
1107 let waker = waker_ref(&arc_waker); in cancel_after_transfer()
1162 let waker = waker_ref(&arc_waker); in cancel_after_transfer_and_wake()
1228 let waker = waker_ref(&arc_waker); in timed_wait()
|
| /external/crosvm/cros_async/src/sync/ |
| D | blocking.rs | 12 use futures::task::{waker_ref, ArcWake};
66 let waker = waker_ref(thread_waker); in block_on()
|
| D | mu.rs | 896 use futures::task::{waker_ref, ArcWake};
1388 let waker = waker_ref(&arc_waker); in wake_all_readers()
1476 let waker = waker_ref(&arc_waker); in long_wait()
1534 let waker = waker_ref(&arc_waker); in cancel_long_wait_before_wake()
1581 let waker = waker_ref(&arc_waker); in cancel_long_wait_after_wake()
1634 let waker = waker_ref(&arc_waker); in designated_waker()
1704 let waker = waker_ref(&arc_waker); in cancel_designated_waker()
1735 let waker = waker_ref(&arc_waker); in cancel_before_wake()
1798 let waker = waker_ref(&arc_waker); in cancel_after_wake()
1867 let waker = waker_ref(&arc_waker); in timeout()
[all …]
|
| D | cv.rs | 455 use futures::task::{waker_ref, ArcWake};
939 let waker = waker_ref(&arc_waker); in wake_all_readers()
982 let waker = waker_ref(&arc_waker); in cancel_before_notify()
1027 let waker = waker_ref(&arc_waker); in cancel_after_notify_one()
1071 let waker = waker_ref(&arc_waker); in cancel_after_notify_all()
1136 let waker = waker_ref(&arc_waker); in timed_wait()
|
| /external/rust/crates/grpcio/src/task/ |
| D | executor.rs | 16 use futures::task::{waker_ref, ArcWake, Context, Poll};
197 let waker = waker_ref(&task); in poll()
|
| /external/rust/crates/futures-util/src/task/ |
| D | mod.rs | 33 pub use futures_task::{waker_ref, WakerRef};
|
| /external/rust/crates/tokio/src/util/ |
| D | mod.rs | 23 pub(crate) use wake::{waker_ref, Wake};
|
| D | wake.rs | 32 pub(crate) fn waker_ref<W: Wake>(wake: &Arc<W>) -> WakerRef<'_> { in waker_ref() function
|
| /external/rust/crates/futures/tests/ |
| D | arc_wake.rs | 54 let w2 = task::waker_ref(&some_w); in ref_wake_same()
|
| D | sink.rs | 66 let waker = task::waker_ref(&flag); in flag_cx()
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | shared.rs | 1 use crate::task::{waker_ref, ArcWake};
262 let waker = waker_ref(&inner.notifier); in poll()
|