| /external/rust/crates/async-task/tests/ |
| D | waker_pending.rs | 101 let waker = get_waker(); in wake_during_run() localVariable
145 let waker = get_waker(); in cancel_during_run() localVariable
187 let waker = get_waker(); in wake_and_cancel_during_run() localVariable
236 let waker = get_waker(); in cancel_and_wake_during_run() localVariable
285 let waker = get_waker(); in drop_last_waker() localVariable
|
| D | waker_panic.rs | 114 let waker = get_waker(); in wake_during_run() localVariable
157 let waker = get_waker(); in cancel_during_run() localVariable
199 let waker = get_waker(); in wake_and_cancel_during_run() localVariable
248 let waker = get_waker(); in cancel_and_wake_during_run() localVariable
|
| D | waker_ready.rs | 231 let waker = get_waker(); in wake_dropped() localVariable
257 let waker = get_waker(); in wake_completed() localVariable
|
| D | basic.rs | 285 fn waker() { in waker() function
291 let waker = runnable.waker(); in waker() localVariable
|
| /external/rust/crates/futures-task/src/ |
| D | waker_ref.rs | 15 waker: ManuallyDrop<Waker>, field
24 let waker = ManuallyDrop::new(unsafe { core::ptr::read(waker) }); in new() localVariable
66 let waker = ManuallyDrop::new(unsafe { in waker_ref() localVariable
|
| D | noop_waker.rs | 60 let waker = std::thread::spawn(super::noop_waker_ref).join().unwrap(); in issue_2091_cross_thread_segfault() localVariable
|
| /external/rust/crates/futures-util/benches_disabled/ |
| D | bilock.rs | 59 let waker = notify_noop(); in contended() localVariable
61 let mut waker = task::Context::new(&mut map, &waker, &mut exec); in contended() localVariable
98 let waker = notify_noop(); in lock_unlock() localVariable
100 let mut waker = task::Context::new(&mut map, &waker, &mut exec); in lock_unlock() localVariable
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | atomic_waker.rs | 17 let mut waker = task::spawn(AtomicWaker::new()); in basic_usage() localVariable
27 let mut waker = task::spawn(AtomicWaker::new()); in wake_without_register() localVariable
|
| /external/rust/crates/tokio-test/src/ |
| D | task.rs | 34 waker: Arc<ThreadWaker>, field
142 let waker = self.waker(); in enter() localVariable
161 fn waker(&self) -> Waker { in waker() method
230 let waker = from_raw(raw); in clone() localVariable
239 let waker = from_raw(raw); in wake() localVariable
244 let waker = from_raw(raw); in wake_by_ref() localVariable
|
| /external/rust/crates/futures-core/src/task/__internal/ |
| D | atomic_waker.rs | 91 waker: UnsafeCell<Option<Waker>>, field
302 let waker = (*self.waker.get()).take().unwrap(); in register() localVariable
378 let waker = unsafe { (*self.waker.get()).take() }; in take() localVariable
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 27 waker: UnsafeCell<Option<Waker>>, field
206 let waker = self.waker.with_mut(|t| (*t).take()).unwrap(); in do_register() localVariable
261 let waker = unsafe { self.waker.with_mut(|t| (*t).take()) }; in take_waker() localVariable
|
| /external/rust/crates/futures-util/src/compat/ |
| D | compat03as01.rs | 222 let waker = current.as_waker(); in with_context() localVariable
234 let waker = current.as_waker(); in with_sink_context() localVariable
259 let waker = current.as_waker(); in read() localVariable
280 let waker = current.as_waker(); in write() localVariable
287 let waker = current.as_waker(); in flush() localVariable
296 let waker = current.as_waker(); in shutdown() localVariable
|
| /external/rust/crates/async-task/src/ |
| D | header.rs | 53 let waker = unsafe { (*self.awaiter.get()).take() }; in take() localVariable
114 let mut waker = None; in register() localVariable
|
| /external/rust/crates/futures-util/src/io/ |
| D | write_all_vectored.rs | 123 let waker = noop_waker(); in test_writer_read_from_one_buf() localVariable
146 let waker = noop_waker(); in test_writer_read_from_multiple_bufs() localVariable
169 let waker = noop_waker(); in test_write_all_vectored() localVariable
|
| /external/rust/crates/futures/tests/ |
| D | fuse.rs | 8 let waker = panic_waker(); in fuse() localVariable
|
| /external/rust/crates/tokio/src/util/ |
| D | wake.rs | 19 waker: ManuallyDrop<Waker>, field
35 let waker = unsafe { Waker::from_raw(RawWaker::new(ptr, waker_vtable::<W>())) }; in waker_ref() localVariable
|
| /external/rust/crates/mio/src/sys/shell/ |
| D | mod.rs | 10 mod waker; module
|
| /external/libchromeos-rs/src/sync/ |
| D | mu.rs | 1362 waker: Arc<SpinLock<Option<Waker>>>, in rw_single_thread_async() field
1395 let waker = Arc::new(SpinLock::new(None)); in rw_single_thread_async() localVariable
1509 let waker = waker_ref(&arc_waker); in wake_all_readers() localVariable
1596 let waker = waker_ref(&arc_waker); in long_wait() localVariable
1654 let waker = waker_ref(&arc_waker); in cancel_long_wait_before_wake() localVariable
1701 let waker = waker_ref(&arc_waker); in cancel_long_wait_after_wake() localVariable
1754 let waker = waker_ref(&arc_waker); in designated_waker() localVariable
1824 let waker = waker_ref(&arc_waker); in cancel_designated_waker() localVariable
1855 let waker = waker_ref(&arc_waker); in cancel_before_wake() localVariable
1918 let waker = waker_ref(&arc_waker); in cancel_after_wake() localVariable
[all …]
|
| D | blocking.rs | 66 let waker = waker_ref(thread_waker); in block_on() localVariable
122 waker: Option<Waker>, field
|
| /external/crosvm/cros_async/src/sync/ |
| D | mu.rs | 1239 waker: Arc<SpinLock<Option<Waker>>>, in rw_single_thread_async() field
1274 let waker = Arc::new(SpinLock::new(None)); in rw_single_thread_async() localVariable
1388 let waker = waker_ref(&arc_waker); in wake_all_readers() localVariable
1476 let waker = waker_ref(&arc_waker); in long_wait() localVariable
1534 let waker = waker_ref(&arc_waker); in cancel_long_wait_before_wake() localVariable
1581 let waker = waker_ref(&arc_waker); in cancel_long_wait_after_wake() localVariable
1634 let waker = waker_ref(&arc_waker); in designated_waker() localVariable
1704 let waker = waker_ref(&arc_waker); in cancel_designated_waker() localVariable
1735 let waker = waker_ref(&arc_waker); in cancel_before_wake() localVariable
1798 let waker = waker_ref(&arc_waker); in cancel_after_wake() localVariable
[all …]
|
| D | blocking.rs | 66 let waker = waker_ref(thread_waker); in block_on() localVariable
122 waker: Option<Waker>, field
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | waker.rs | 12 waker: ManuallyDrop<Waker>, field
31 let waker = unsafe { ManuallyDrop::new(Waker::from_raw(raw_waker::<T, S>(header))) }; in waker_ref() localVariable
|
| /external/rust/crates/mio/src/ |
| D | lib.rs | 52 mod waker; module
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | mod.rs | 39 mod waker; module
|
| /external/rust/crates/async-trait/tests/executor/ |
| D | mod.rs | 26 let waker = unsafe { Waker::from_raw(raw_waker) }; in block_on_simple() localVariable
|