Searched defs:Waker (Results 1 – 11 of 11) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | waker.rs | 21 pub struct Waker { struct
22 inner: WakerInner, argument
25 impl Waker { impl
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | atomic_waker.rs | 42 pub(crate) fn register_by_ref(&self, waker: &Waker) { in register_by_ref()
78 pub(crate) fn take_waker(&self) -> Option<Waker> { in take_waker()
|
| D | wake_list.rs | 62 pub fn remove(&self, key: usize) -> Result<Waker, SlotsError> { in remove()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | mod.rs | 102 pub(crate) fn take_waker(&mut self) -> Option<Waker> { in take_waker()
107 pub(crate) fn set_waker(&mut self, waker: Waker) { in set_waker()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | join_handle.rs | 78 pub(crate) fn set_waker(&mut self, waker: &Waker) { in set_waker()
81 if self.raw.set_waker(cur, waker as *const Waker as *const ()) { in set_waker() constant
|
| D | task_handle.rs | 156 fn set_waker_inner(&self, des_waker: Waker, cur_state: usize) -> Result<usize, usize> { in set_waker_inner()
|
| D | join_set.rs | 456 fn entry_into_waker<R>(entry: &Arc<JoinEntry<R>>) -> Waker { in entry_into_waker()
|
| D | raw.rs | 288 let waker = &*(waker as *const Waker); in set_waker() constant
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | block_on.rs | 65 pub(crate) fn waker(&self) -> Waker { in waker()
|
| D | current_thread.rs | 123 fn waker(&self) -> Waker { in waker()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 1422 fn wakeup_next_stream(waker_map: &mut HashMap<u32, Waker>) { in wakeup_next_stream() argument
|