Searched defs:waker (Results 1 – 16 of 16) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | atomic_waker.rs | 22 waker: RefCell<Option<Waker>>, field
57 let waker = self.waker.borrow_mut().take().unwrap(); in register_by_ref() localVariable
81 let waker = self.waker.borrow_mut().take(); in take_waker() localVariable
|
| D | oneshot.rs | 418 waker: AtomicWaker, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | task_handle.rs | 105 let waker = WakerRefHeader::<'_>::new::<T>(self.header()); in run() localVariable
161 let waker = self.inner().waker.get(); in set_waker_inner() localVariable
167 let waker = self.inner().waker.get(); in set_waker_inner() localVariable
177 let waker = self.inner().waker.get(); in set_waker() localVariable
300 let waker = WakerRefHeader::<'_>::new::<T>(self.header()); in ffrt_run() localVariable
|
| D | waker.rs | 72 waker: ManuallyDrop<Waker>, field
81 let waker = unsafe { ManuallyDrop::new(Waker::from_raw(raw_waker::<T>(header))) }; in new() localVariable
|
| D | join_set.rs | 66 waker: Option<Waker>, field
183 let waker = entry_into_waker(&entry); in spawn_inner() localVariable
305 let waker = entry_into_waker(&entry); in poll_join_next() localVariable
|
| D | raw.rs | 139 pub(crate) waker: UnsafeCell<Option<Waker>>, field
221 let waker = self.waker.get(); in wake_join() localVariable
288 let waker = &*(waker as *const Waker); in set_waker() localVariable
|
| D | mod.rs | 22 mod waker; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | lib.rs | 35 mod waker; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/ |
| D | mod.rs | 45 mod waker; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | mod.rs | 43 mod waker; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | block_on.rs | 65 pub(crate) fn waker(&self) -> Waker { in waker() method
100 let waker = parker.waker(); in block_on() localVariable
|
| D | current_thread.rs | 123 fn waker(&self) -> Waker { in waker() method
150 let waker = self.waker(); in block_on() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | mod.rs | 54 waker: Option<Waker>, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | driver.rs | 72 pub(crate) waker: ylong_io::Waker, field
190 let waker = in initialize() localVariable
|
| D | schedule_io.rs | 63 waker: Option<Waker>, field
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 225 waker: HashMap<u32, Waker>, field
|