| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | atomic_waker.rs | 22 waker: RefCell<Option<Waker>>, field
56 let waker = self.waker.borrow_mut().take().unwrap(); in register_by_ref() localVariable
79 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 | 118 let waker = self.inner().waker.get(); in set_waker_inner() localVariable
124 let waker = self.inner().waker.get(); in set_waker_inner() localVariable
135 let waker = self.inner().waker.get(); in set_waker() localVariable
186 let waker = WakerRefHeader::<'_>::new::<T>(self.header()); in run() localVariable
288 let waker = WakerRefHeader::<'_>::new::<T>(self.header()); in ffrt_run() localVariable
|
| D | waker.rs | 70 waker: ManuallyDrop<Waker>, field
79 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 | 187 pub(crate) waker: UnsafeCell<Option<Waker>>, field
269 let waker = self.waker.get(); in wake_join() localVariable
313 let waker = &*(waker.cast::<Waker>()); in set_waker() localVariable
|
| D | mod.rs | 22 mod waker; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | lib.rs | 43 mod waker; module
|
| D | waker.rs | 49 let waker = Waker::new(&poll, Token::from_usize(0)).unwrap(); in ut_waker_debug_info() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| D | mod.rs | 53 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 | 203 fn waker(parker: Arc<Parker>) -> Waker { in waker() function
279 let waker = waker(parker.clone()); in block_on() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | mod.rs | 45 mod waker; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/ |
| D | ffrt_timer.rs | 26 let waker = data as *mut Waker; in timer_register() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | sleep.rs | 145 let waker = Box::new(cx.waker().clone()); localVariable
|
| D | wheel.rs | 51 waker: Option<Waker>, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | driver.rs | 79 pub(crate) waker: ylong_io::Waker, field
199 let waker = ylong_io::Waker::new(&poll, WAKE_TOKEN) in initialize() localVariable
|
| D | schedule_io.rs | 63 waker: Option<Waker>, field
|