| /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()
75 pub struct Waker { struct
80 impl Waker { implementation
81 pub fn new(selector: &Selector, token: Token) -> io::Result<Waker> { in new()
94 pub use self::kqueue::Waker;
116 pub struct Waker { struct
117 sender: File,
[all …]
|
| /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()
|
| /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 | 171 pub(crate) fn register_by_ref(&self, waker: &Waker) { in register_by_ref()
313 pub(crate) fn take_waker(&self) -> Option<Waker> { in take_waker()
361 fn into_waker(self) -> Waker; in into_waker()
364 impl WakerRef for Waker { implementation
369 fn into_waker(self) -> Waker { in into_waker()
374 impl WakerRef for &Waker { implementation
379 fn into_waker(self) -> Waker { in into_waker()
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | waker.rs | 27 pub(crate) struct Waker { struct
35 impl Waker { argument
166 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()
|
| /external/rust/crates/futures-core/src/task/__internal/ |
| D | atomic_waker.rs | 210 impl AssertSync for Waker {} in new() implementation
265 pub fn register(&self, waker: &Waker) { in register()
372 pub fn take(&self) -> Option<Waker> { in take()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | atomic_waker.rs | 12 impl AssertSend for Waker {} implementation
13 impl AssertSync for Waker {} implementation
|
| /external/crosvm/cros_async/src/blocking/sys/unix/ |
| D | block_on.rs | 27 struct Waker(AtomicI32); struct
29 impl ArcWake for Waker { implementation
|
| /external/libchromeos-rs/src/sync/ |
| D | blocking.rs | 24 struct Waker(AtomicI32); struct
32 impl ArcWake for Waker { implementation
|
| /external/rust/crates/tokio/src/runtime/ |
| D | defer.rs | 14 pub(crate) fn defer(&mut self, waker: Waker) { in defer()
|
| D | park.rs | 246 pub(crate) fn waker(&self) -> Result<Waker, AccessError> { in waker()
298 pub(crate) fn into_waker(self) -> Waker { in into_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 | 45 fn deref(&self) -> &Waker { in deref()
|
| /external/rust/crates/futures-test/src/task/ |
| D | panic_waker.rs | 59 unsafe { &*(&PANIC_WAKER_INSTANCE.0 as *const RawWaker as *const Waker) } in panic_waker_ref() constant
|
| /external/rust/crates/tokio/src/util/ |
| D | wake_list.rs | 31 pub(crate) fn push(&mut self, val: Waker) { in push()
|
| D | wake.rs | 27 fn deref(&self) -> &Waker { in deref()
|
| /external/crosvm/cros_async/src/ |
| D | waker.rs | 64 pub(crate) fn new_waker<W: WeakWake>(w: Weak<W>) -> Waker { in new_waker()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | harness.rs | 273 pub(super) fn try_read_output(self, dst: &mut Poll<super::Result<T::Output>>, waker: &Waker) { in try_read_output()
411 waker: Waker, in set_join_waker()
|
| D | waker.rs | 41 fn deref(&self) -> &Waker { in deref()
|
| D | join.rs | 247 pub(crate) fn set_join_waker(&mut self, waker: &Waker) { in set_join_waker()
|
| D | raw.rs | 217 pub(super) unsafe fn try_read_output(self, dst: *mut (), waker: &Waker) { in try_read_output()
275 waker: &Waker, in try_read_output()
|
| /external/rust/crates/tokio/src/runtime/time/ |
| D | entry.rs | 211 unsafe fn fire(&self, result: TimerResult) -> Option<Waker> { in fire()
639 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()
|