| /external/rust/crates/futures/tests/ |
| D | arc_wake.rs | 22 fn wake_by_ref(arc_self: &Arc<Self>) { in wake_by_ref() method
34 w1.wake_by_ref(); in create_from_arc()
40 w2.wake_by_ref(); in create_from_arc()
70 fn wake_by_ref(_arc_self: &Arc<Self>) { in proper_refcount_on_wake_panic() method
78 …assert_eq!("WAKE UP", *std::panic::catch_unwind(|| w1.wake_by_ref()).unwrap_err().downcast::<&str>… in proper_refcount_on_wake_panic()
|
| /external/crosvm/cros_async/src/ |
| D | waker.rs | 15 fn wake_by_ref(weak_self: &Weak<Self>); in wake_by_ref() method
18 Self::wake_by_ref(&weak_self) in wake()
54 WeakWake::wake_by_ref(&weak) in wake_by_ref_weak_raw()
|
| /external/rust/crates/futures-task/src/ |
| D | arc_wake.rs | 32 Self::wake_by_ref(&self) in wake()
48 fn wake_by_ref(arc_self: &Arc<Self>); in wake_by_ref() method
|
| D | noop_waker.rs | 61 waker.wake_by_ref(); in issue_2091_cross_thread_segfault()
|
| D | waker.rs | 56 ArcWake::wake_by_ref(&arc); in wake_by_ref_arc_raw()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | waker.rs | 78 unsafe fn wake_by_ref<T, S>(ptr: *const ()) in wake_by_ref() function
85 harness.wake_by_ref(); in wake_by_ref()
97 wake_by_ref::<T, S>, in raw_waker()
|
| /external/rust/crates/async-trait/tests/executor/ |
| D | mod.rs | 17 unsafe fn wake_by_ref(_null: *const ()) { in block_on_simple() function
24 let vtable = &RawWakerVTable::new(clone, wake, wake_by_ref, drop); in block_on_simple()
|
| /external/rust/crates/tokio/src/util/ |
| D | wake.rs | 13 fn wake_by_ref(arc_self: &Arc<Self>); in wake_by_ref() method
78 Wake::wake_by_ref(&arc); in wake_by_ref_arc_raw()
|
| /external/rust/crates/futures-executor/benches/ |
| D | thread_notify.rs | 27 cx.waker().wake_by_ref(); in thread_yield_single_thread_one_wait()
55 cx.waker().wake_by_ref(); in thread_yield_single_thread_many_wait()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | shell.rs | 87 Wake::wake_by_ref(&self); in wake()
91 fn wake_by_ref(arc_self: &Arc<Self>) { in wake_by_ref() method
|
| /external/rust/crates/async-task/tests/ |
| D | waker_ready.rs | 140 fn wake_by_ref() { in wake_by_ref() function
155 get_waker().wake_by_ref(); in wake_by_ref()
170 get_waker().wake_by_ref(); in wake_by_ref()
233 waker.wake_by_ref(); in wake_dropped()
|
| D | waker_pending.rs | 102 waker.wake_by_ref(); in wake_during_run()
117 waker.wake_by_ref(); in wake_during_run()
188 waker.wake_by_ref(); in wake_and_cancel_during_run()
237 waker.wake_by_ref(); in cancel_and_wake_during_run()
|
| D | waker_panic.rs | 115 waker.wake_by_ref(); in wake_during_run()
200 waker.wake_by_ref(); in wake_and_cancel_during_run()
249 waker.wake_by_ref(); in cancel_and_wake_during_run()
|
| /external/rust/crates/tokio/src/task/ |
| D | yield_now.rs | 31 cx.waker().wake_by_ref();
|
| /external/rust/crates/tokio-test/src/ |
| D | task.rs | 219 static VTABLE: RawWakerVTable = RawWakerVTable::new(clone, wake, wake_by_ref, drop_waker);
243 unsafe fn wake_by_ref(raw: *const ()) { in wake_by_ref() function
|
| /external/rust/crates/tokio-stream/src/ |
| D | iter.rs | 54 cx.waker().wake_by_ref(); in poll_next()
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | select_next_some.rs | 38 cx.waker().wake_by_ref(); in poll()
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 318 &RawWakerVTable::new(clone, wake, wake_by_ref, drop_waker), in unparker_to_raw_waker()
340 unsafe fn wake_by_ref(raw: *const ()) { in wake_by_ref() function
|
| /external/rust/crates/tokio-stream/src/stream_ext/ |
| D | any.rs | 48 cx.waker().wake_by_ref(); in poll()
|
| D | all.rs | 48 cx.waker().wake_by_ref(); in poll()
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc-close.rs | 204 cx.waker().wake_by_ref(); in stress_try_send_as_receiver_closes()
211 cx.waker().wake_by_ref(); in stress_try_send_as_receiver_closes()
|
| /external/rust/crates/futures-util/src/stream/futures_unordered/ |
| D | task.rs | 45 fn wake_by_ref(arc_self: &Arc<Self>) { in wake_by_ref() method
|
| /external/rust/crates/async-task/src/ |
| D | raw.rs | 91 Self::wake_by_ref,
186 Self::wake_by_ref(ptr); in wake()
248 unsafe fn wake_by_ref(ptr: *const ()) { in wake_by_ref() function
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_pool.rs | 324 waker.wake_by_ref(); in gated2()
329 waker.wake_by_ref(); in gated2()
|
| /external/rust/crates/tokio/tests/ |
| D | io_driver.rs | 20 fn wake_by_ref(_: &Arc<Self>) { in wake_by_ref() method
|