| /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 | 232 let waker = get_waker(); in wake_dropped() localVariable
258 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/pigweed/pw_async2_epoll/public_overrides/pw_async2/ |
| D | dispatcher_native.h | 43 void NativeAddReadWakerForFileDescriptor(int fd, Waker&& waker) { in NativeAddReadWakerForFileDescriptor()
48 void NativeAddWriteWakerForFileDescriptor(int fd, Waker&& waker) { in NativeAddWriteWakerForFileDescriptor()
59 Waker waker; member
72 Waker&& waker) { in NativeAddWakerForFileDescriptor()
|
| /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/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
310 let waker = (*self.waker.get()).take().unwrap(); in register() localVariable
384 let waker = unsafe { (*self.waker.get()).take() }; in take() localVariable
|
| /external/pigweed/pw_channel/ |
| D | epoll_channel.cc | 80 async2::Waker waker = cx.GetWaker(async2::WaitReason::Unspecified()); in DoPendRead() local
98 async2::Waker waker = cx.GetWaker(async2::WaitReason::Unspecified()); in DoPendReadyToWrite() local
|
| /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/pigweed/pw_async2/ |
| D | dispatcher_base.cc | 37 void Task::AddWakerLocked(Waker& waker) { in AddWakerLocked()
43 void Task::RemoveWakerLocked(Waker& waker) { in RemoveWakerLocked()
88 Waker waker; in Clone() local
|
| D | pendable_as_task_test.cc | 56 Waker waker; in TEST() local
81 Waker waker; in TEST() local
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | wait_for_handle.rs | 37 waker: Option<Waker>, field
185 let mut waker = None; in process_wait_state_change() localVariable
222 let waker = process_wait_state_change( in wait_for_handle_waker() localVariable
276 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
|
| D | notify.rs | 37 let waker = in notify_clones_waker_before_lock() localVariable
66 let waker = futures::task::waker(Arc::new(PanickingWaker(notify.clone()))); in notify_waiters_handles_panicking_waker() localVariable
|
| /external/rust/crates/async-task/src/ |
| D | header.rs | 67 let waker = unsafe { (*self.awaiter.get()).take() }; in take() localVariable
128 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/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/tokio/src/runtime/task/ |
| D | waker.rs | 10 waker: ManuallyDrop<Waker>, field
28 let waker = unsafe { ManuallyDrop::new(Waker::from_raw(raw_waker(*header))) }; in waker_ref() 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/crosvm/cros_async/src/sync/ |
| D | mu.rs | 1281 waker: Arc<SpinLock<Option<Waker>>>, in rw_single_thread_async() field
1316 let waker = Arc::new(SpinLock::new(None)); in rw_single_thread_async() localVariable
1430 let waker = waker_ref(&arc_waker); in wake_all_readers() localVariable
1518 let waker = waker_ref(&arc_waker); in long_wait() localVariable
1576 let waker = waker_ref(&arc_waker); in cancel_long_wait_before_wake() localVariable
1623 let waker = waker_ref(&arc_waker); in cancel_long_wait_after_wake() localVariable
1676 let waker = waker_ref(&arc_waker); in designated_waker() localVariable
1746 let waker = waker_ref(&arc_waker); in cancel_designated_waker() localVariable
1777 let waker = waker_ref(&arc_waker); in cancel_before_wake() localVariable
1840 let waker = waker_ref(&arc_waker); in cancel_after_wake() localVariable
[all …]
|
| /external/rust/crates/hyper/src/ffi/ |
| D | task.rs | 73 waker: std::task::Waker, field
125 let waker = futures_util::task::waker_ref(&self.is_woken); in poll_next() localVariable
389 let waker = non_null!(&mut *cx ?= ptr::null_mut()).0.waker().clone(); localVariable
408 let waker = non_null!(Box::from_raw(waker) ?= ()); 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
|