| /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
253 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
25 let waker = ManuallyDrop::new(unsafe { core::ptr::read(waker) }); in new() localVariable
63 let waker = in waker_ref() localVariable
|
| D | lib.rs | 30 mod waker; module
|
| /external/rust/crates/futures-util/benches_disabled/ |
| D | bilock.rs | 55 let waker = notify_noop(); in contended() localVariable
57 let mut waker = task::Context::new(&mut map, &waker, &mut exec); in contended() localVariable
94 let waker = notify_noop(); in lock_unlock() localVariable
96 let mut waker = task::Context::new(&mut map, &waker, &mut exec); in lock_unlock() 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 | 98 waker: UnsafeCell<Option<Waker>>, field
305 let waker = (*self.waker.get()).take().unwrap(); in register() localVariable
379 let waker = unsafe { (*self.waker.get()).take() }; in take() localVariable
|
| /external/rust/crates/futures-util/src/compat/ |
| D | compat03as01.rs | 198 let waker = current.as_waker(); in with_context() localVariable
210 let waker = current.as_waker(); in with_sink_context() localVariable
233 let waker = current.as_waker(); in read() localVariable
244 let waker = current.as_waker(); in write() localVariable
251 let waker = current.as_waker(); in flush() localVariable
260 let waker = current.as_waker(); in shutdown() localVariable
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | wait_for_handle.rs | 37 waker: Option<Waker>, field
181 let mut waker = None; in process_wait_state_change() localVariable
218 let waker = process_wait_state_change( in wait_for_handle_waker() localVariable
272 let waker = new_waker(Arc::downgrade(&fake_waker)); in test_unsignaled_event() localVariable
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | atomic_waker.rs | 20 let mut waker = task::spawn(AtomicWaker::new()); in basic_usage() localVariable
30 let mut waker = task::spawn(AtomicWaker::new()); in wake_without_register() 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/tokio/src/sync/task/ |
| D | atomic_waker.rs | 29 waker: UnsafeCell<Option<Waker>>, field
237 let mut waker = self.waker.with_mut(|t| (*t).take()); in do_register() localVariable
320 let waker = unsafe { self.waker.with_mut(|t| (*t).take()) }; in take_waker() localVariable
|
| /external/rust/crates/futures-util/src/io/ |
| D | write_all_vectored.rs | 118 let waker = noop_waker(); in test_writer_read_from_one_buf() localVariable
141 let waker = noop_waker(); in test_writer_read_from_multiple_bufs() localVariable
160 let waker = noop_waker(); in test_write_all_vectored() localVariable
|
| /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 | 1257 waker: Arc<SpinLock<Option<Waker>>>, in rw_single_thread_async() field
1292 let waker = Arc::new(SpinLock::new(None)); in rw_single_thread_async() localVariable
1406 let waker = waker_ref(&arc_waker); in wake_all_readers() localVariable
1494 let waker = waker_ref(&arc_waker); in long_wait() localVariable
1552 let waker = waker_ref(&arc_waker); in cancel_long_wait_before_wake() localVariable
1599 let waker = waker_ref(&arc_waker); in cancel_long_wait_after_wake() localVariable
1652 let waker = waker_ref(&arc_waker); in designated_waker() localVariable
1722 let waker = waker_ref(&arc_waker); in cancel_designated_waker() localVariable
1753 let waker = waker_ref(&arc_waker); in cancel_before_wake() localVariable
1816 let waker = waker_ref(&arc_waker); in cancel_after_wake() localVariable
[all …]
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | waker.rs | 11 waker: ManuallyDrop<Waker>, field
30 let waker = unsafe { ManuallyDrop::new(Waker::from_raw(raw_waker(*header))) }; in waker_ref() localVariable
|
| /external/rust/crates/tokio/src/util/ |
| D | wake.rs | 20 waker: ManuallyDrop<Waker>, field
36 let waker = unsafe { Waker::from_raw(RawWaker::new(ptr, waker_vtable::<W>())) }; in waker_ref() localVariable
|
| /external/rust/crates/futures/tests/ |
| D | future_fuse.rs | 8 let waker = panic_waker(); in fuse() localVariable
|
| /external/rust/crates/mio/src/sys/shell/ |
| D | mod.rs | 11 mod waker; module
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_local.rs | 37 let waker = recv.recv(); in wake_during_shutdown() localVariable
|
| /external/crosvm/cros_async/src/blocking/sys/unix/ |
| D | block_on.rs | 64 let waker = waker_ref(thread_waker); in block_on() localVariable
122 waker: Option<Waker>, field
|
| /external/rust/crates/mio/src/ |
| D | lib.rs | 52 mod waker; module
|