| /external/rust/crates/mio/src/sys/unix/ |
| D | waker.rs | 17 pub struct Waker { struct
18 fd: File,
21 impl Waker { implementation
22 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new()
78 pub struct Waker { struct
83 impl Waker { impl
84 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new()
99 pub use self::kqueue::Waker;
121 pub struct Waker { struct
122 sender: File,
[all …]
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | waker.rs | 10 pub struct Waker { struct
15 impl Waker { implementation
16 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new()
|
| /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()
|
| /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()
|
| /external/rust/crates/tokio/src/sync/task/ |
| D | atomic_waker.rs | 166 pub(crate) fn register_by_ref(&self, waker: &Waker) { in register_by_ref()
254 pub(crate) fn take_waker(&self) -> Option<Waker> { in take_waker()
302 fn into_waker(self) -> Waker; in into_waker()
305 impl WakerRef for Waker { implementation
310 fn into_waker(self) -> Waker { in into_waker()
315 impl WakerRef for &Waker { implementation
320 fn into_waker(self) -> Waker { in into_waker()
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | waker.rs | 26 pub struct Waker { struct
34 impl Waker { implementation
167 impl Drop for Waker { implementation
|
| /external/rust/crates/async-task/src/ |
| D | header.rs | 36 pub(crate) fn notify(&self, current: Option<&Waker>) { in notify()
46 pub(crate) fn take(&self, current: Option<&Waker>) -> Option<Waker> { in take()
76 pub(crate) fn register(&self, waker: &Waker) { in register()
|
| D | runnable.rs | 335 pub fn waker(&self) -> Waker { in waker()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | atomic_waker.rs | 12 impl AssertSend for Waker {} implementation
13 impl AssertSync for Waker {} implementation
|
| /external/rust/crates/futures-core/src/task/__internal/ |
| D | atomic_waker.rs | 203 impl AssertSync for Waker {} in new() implementation
261 pub fn register(&self, waker: &Waker) { in register()
371 pub fn take(&self) -> Option<Waker> { in take()
|
| /external/libchromeos-rs/src/sync/ |
| D | blocking.rs | 24 struct Waker(AtomicI32); struct
32 impl ArcWake for Waker { implementation
|
| /external/crosvm/cros_async/src/sync/ |
| D | blocking.rs | 24 struct Waker(AtomicI32); struct
32 impl ArcWake for Waker { implementation
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | raw.rs | 78 pub(super) unsafe fn try_read_output(self, dst: *mut (), waker: &Waker) { in try_read_output()
115 waker: &Waker, in try_read_output()
|
| D | harness.rs | 108 pub(super) fn try_read_output(self, dst: &mut Poll<super::Result<T::Output>>, waker: &Waker) { in try_read_output()
352 waker: Waker, in set_join_waker()
|
| D | waker.rs | 42 fn deref(&self) -> &Waker { in deref()
|
| D | core.rs | 308 pub(crate) unsafe fn set_waker(&self, waker: Option<Waker>) { in set_waker()
|
| /external/rust/crates/futures-task/src/ |
| D | noop_waker.rs | 52 unsafe { &*(&NOOP_WAKER_INSTANCE.0 as *const RawWaker as *const Waker) } in noop_waker_ref() constant
|
| D | waker_ref.rs | 48 fn deref(&self) -> &Waker { in deref()
|
| /external/crosvm/cros_async/src/ |
| D | waker.rs | 61 pub(crate) fn new_waker<W: WeakWake>(w: Weak<W>) -> Waker { in new_waker()
|
| /external/rust/crates/tokio/src/util/ |
| D | wake.rs | 26 fn deref(&self) -> &Waker { in deref()
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | entry.rs | 205 unsafe fn fire(&self, result: TimerResult) -> Option<Waker> { in fire()
615 pub(super) unsafe fn fire(self, completed_state: TimerResult) -> Option<Waker> { in fire()
|
| /external/rust/crates/grpcio/src/task/ |
| D | mod.rs | 44 fn set_result(&mut self, res: Result<T>) -> Option<Waker> { in set_result()
|
| /external/rust/crates/tokio-test/src/ |
| D | task.rs | 161 fn waker(&self) -> Waker { in waker()
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 296 pub(crate) fn into_waker(self) -> Waker { in into_waker()
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 463 fn notify_locked(waiters: &mut WaitList, state: &AtomicUsize, curr: usize) -> Option<Waker> { in notify_locked()
|