| /external/rust/crates/mio/src/sys/unix/ |
| D | waker.rs | 17 pub struct Waker { struct
21 impl Waker { impl
22 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new() argument
29 .map(|()| Waker { fd: file }) in new()
62 pub use self::eventfd::Waker;
78 pub struct Waker { struct
83 impl Waker { impl
84 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new() argument
88 .map(|()| Waker { selector, token }) in new()
99 pub use self::kqueue::Waker; argument
[all …]
|
| /external/rust/crates/futures-task/src/ |
| D | waker_ref.rs | 7 use core::task::{Waker, RawWaker};
15 waker: ManuallyDrop<Waker>,
21 pub fn new(waker: &'a Waker) -> Self { in new()
37 pub fn new_unowned(waker: ManuallyDrop<Waker>) -> Self { in new_unowned()
46 type Target = Waker;
48 fn deref(&self) -> &Waker { in deref() argument
67 Waker::from_raw(RawWaker::new(ptr, waker_vtable::<W>())) in waker_ref()
|
| D | noop_waker.rs | 4 use core::task::{RawWaker, RawWakerVTable, Waker};
29 pub fn noop_waker() -> Waker { in noop_waker()
31 unsafe { Waker::from_raw(noop_raw_waker()) } in noop_waker()
45 pub fn noop_waker_ref() -> &'static Waker { in noop_waker_ref()
52 unsafe { &*(&NOOP_WAKER_INSTANCE.0 as *const RawWaker as *const Waker) } in noop_waker_ref() constant
|
| D | waker.rs | 3 use core::task::{Waker, RawWaker, RawWakerVTable};
19 pub fn waker<W>(wake: Arc<W>) -> Waker in waker()
26 Waker::from_raw(RawWaker::new(ptr, waker_vtable::<W>())) in waker()
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 8 use std::task::Waker;
27 waker: UnsafeCell<Option<Waker>>,
166 pub(crate) fn register_by_ref(&self, waker: &Waker) { in register_by_ref() argument
254 pub(crate) fn take_waker(&self) -> Option<Waker> { in take_waker() argument
302 fn into_waker(self) -> Waker; in into_waker() argument
305 impl WakerRef for Waker { implementation
310 fn into_waker(self) -> Waker { in into_waker() argument
315 impl WakerRef for &Waker { implementation
320 fn into_waker(self) -> Waker { in into_waker() argument
|
| /external/rust/crates/mio/src/ |
| D | waker.rs | 78 pub struct Waker { struct
79 inner: sys::Waker, argument
82 impl Waker { impl
84 pub fn new(registry: &Registry, token: Token) -> io::Result<Waker> { in new() argument
87 sys::Waker::new(poll::selector(®istry), token).map(|inner| Waker { inner }) in new()
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | waker.rs | 10 pub struct Waker { struct
15 impl Waker { impl
16 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new() argument
17 Ok(Waker { in new()
|
| /external/rust/crates/async-task/src/ |
| D | header.rs | 4 use core::task::Waker;
22 pub(crate) awaiter: UnsafeCell<Option<Waker>>,
36 pub(crate) fn notify(&self, current: Option<&Waker>) { in notify() argument
46 pub(crate) fn take(&self, current: Option<&Waker>) -> Option<Waker> { in take() argument
76 pub(crate) fn register(&self, waker: &Waker) { in register() argument
|
| /external/rust/crates/futures-core/src/task/__internal/ |
| D | atomic_waker.rs | 5 use core::task::Waker;
91 waker: UnsafeCell<Option<Waker>>,
203 impl AssertSync for Waker {} in new() implementation
261 pub fn register(&self, waker: &Waker) { in register() argument
371 pub fn take(&self) -> Option<Waker> { in take() argument
|
| /external/rust/crates/futures/tests/ |
| D | arc_wake.rs | 2 use futures::task::{self, ArcWake, Waker};
32 let w1: Waker = task::waker(some_w.clone()); in create_from_arc()
53 let w1: Waker = task::waker(some_w.clone()); in ref_wake_same()
64 use futures::task::{self, ArcWake, Waker}; in proper_refcount_on_wake_panic()
77 let w1: Waker = task::waker(some_w.clone()); in proper_refcount_on_wake_panic()
|
| /external/rust/crates/tokio/src/util/ |
| D | wake.rs | 5 use std::task::{RawWaker, RawWakerVTable, Waker};
19 waker: ManuallyDrop<Waker>,
24 type Target = Waker;
26 fn deref(&self) -> &Waker { in deref() argument
35 let waker = unsafe { Waker::from_raw(RawWaker::new(ptr, waker_vtable::<W>())) }; in waker_ref()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | waker.rs | 9 use std::task::{RawWaker, RawWakerVTable, Waker};
12 waker: ManuallyDrop<Waker>,
31 let waker = unsafe { ManuallyDrop::new(Waker::from_raw(raw_waker::<T, S>(header))) }; in waker_ref()
40 type Target = Waker;
42 fn deref(&self) -> &Waker { in deref() argument
|
| D | raw.rs | 5 use std::task::{Poll, Waker};
20 pub(super) try_read_output: unsafe fn(NonNull<Header>, *mut (), &Waker),
78 pub(super) unsafe fn try_read_output(self, dst: *mut (), waker: &Waker) { in try_read_output() argument
115 waker: &Waker, in try_read_output() argument
|
| D | core.rs | 21 use std::task::{Context, Poll, Waker};
82 pub(super) waker: UnsafeCell<Option<Waker>>,
308 pub(crate) unsafe fn set_waker(&self, waker: Option<Waker>) { in set_waker() argument
314 pub(crate) unsafe fn will_wake(&self, waker: &Waker) -> bool { in will_wake()
|
| /external/rust/crates/mio/src/sys/shell/ |
| D | waker.rs | 6 pub struct Waker {} struct
8 impl Waker { impl
9 pub fn new(_: &Selector, _: Token) -> io::Result<Waker> { in new() argument
|
| /external/libchromeos-rs/src/sync/ |
| D | blocking.rs | 21 thread_local!(static PER_THREAD_WAKER: Arc<Waker> = Arc::new(Waker(AtomicI32::new(WAITING))));
24 struct Waker(AtomicI32); struct
32 impl ArcWake for Waker { implementation
114 use std::task::{Context, Poll, Waker};
122 waker: Option<Waker>,
|
| /external/crosvm/cros_async/src/sync/ |
| D | blocking.rs | 21 thread_local!(static PER_THREAD_WAKER: Arc<Waker> = Arc::new(Waker(AtomicI32::new(WAITING))));
24 struct Waker(AtomicI32); struct
32 impl ArcWake for Waker { implementation
114 use std::task::{Context, Poll, Waker};
122 waker: Option<Waker>,
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | atomic_waker.rs | 4 use std::task::Waker;
12 impl AssertSend for Waker {} implementation
13 impl AssertSync for Waker {} implementation
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | waker.rs | 26 pub struct Waker { struct
34 impl Waker { impl
38 Waker { in new()
167 impl Drop for Waker { implementation
180 inner: Spinlock<Waker>,
191 inner: Spinlock::new(Waker::new()), in new()
|
| /external/crosvm/cros_async/src/ |
| D | waker.rs | 7 use std::task::{RawWaker, RawWakerVTable, Waker};
61 pub(crate) fn new_waker<W: WeakWake>(w: Weak<W>) -> Waker { in new_waker() argument
63 Waker::from_raw(RawWaker::new( in new_waker()
|
| /external/rust/crates/tokio/src/sync/ |
| D | oneshot.rs | 65 use std::task::{Context, Poll, Waker};
188 struct Task(UnsafeCell<MaybeUninit<Waker>>);
197 F: FnOnce(&Waker) -> R, in with_task()
200 let waker: *const Waker = (&*ptr).as_ptr(); in with_task() constant
207 let ptr: *mut Waker = (&mut *ptr).as_mut_ptr(); in drop_task()
214 let ptr: *mut Waker = (&mut *ptr).as_mut_ptr(); in set_task()
718 self.rx_task.with_task(Waker::wake_by_ref); in complete()
794 self.tx_task.with_task(Waker::wake_by_ref); in close()
|
| /external/rust/crates/futures-util/src/lock/ |
| D | bilock.rs | 5 use futures_core::task::{Context, Poll, Waker};
103 let mut prev = Box::from_raw(n as *mut Waker); in poll_lock()
110 let me: Box<Waker> = waker.take().unwrap_or_else(||Box::new(cx.waker().clone())); in poll_lock()
122 waker = Some(Box::from_raw(me as *mut Waker)); in poll_lock()
183 Box::from_raw(n as *mut Waker).wake(); in unlock()
|
| /external/rust/crates/futures-executor/benches/ |
| D | thread_notify.rs | 8 use futures::task::{Context, Poll, Waker};
76 let (tx, rx) = mpsc::sync_channel::<Waker>(10_000); in thread_yield_multi_thread()
80 tx: mpsc::SyncSender<Waker>, in thread_yield_multi_thread()
|
| /external/rust/crates/async-trait/tests/executor/ |
| D | mod.rs | 4 use std::task::{Context, Poll, RawWaker, RawWakerVTable, Waker};
26 let waker = unsafe { Waker::from_raw(raw_waker) }; in block_on_simple()
|
| /external/rust/crates/tokio/src/io/util/ |
| D | mem.rs | 10 task::{self, Poll, Waker},
63 read_waker: Option<Waker>,
66 write_waker: Option<Waker>,
|