| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | waker.rs | 21 pub struct Waker { struct
25 impl Waker { impl
28 WakerInner::new(poll.selector(), token).map(|inner| Waker { inner }) in new()
46 use crate::{Poll, Token, Waker}; in ut_waker_debug_info()
49 let waker = Waker::new(&poll, Token::from_usize(0)).unwrap(); in ut_waker_debug_info()
|
| H A D | lib.rs | 44 pub use waker::Waker;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | atomic_waker.rs | 18 use std::task::Waker;
22 waker: RefCell<Option<Waker>>,
42 pub(crate) fn register_by_ref(&self, waker: &Waker) { in register_by_ref() argument
76 pub(crate) fn take_waker(&self) -> Option<Waker> { in take_waker() argument
|
| H A D | wake_list.rs | 18 use std::task::Waker;
28 wake_list: Slots<Waker>,
55 pub fn insert(&self, waker: Waker) -> usize { in insert()
62 pub fn remove(&self, key: usize) -> Result<Waker, SlotsError> { in remove() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/ |
| H A D | ffrt_timer.rs | 14 use std::task::Waker;
23 pub(crate) fn timer_register(waker: *mut Waker, dur: u64) -> Self { in timer_register() argument
26 let waker = data as *mut Waker; in timer_register()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | waker.rs | 19 use std::task::{RawWaker, RawWakerVTable, Waker};
70 waker: ManuallyDrop<Waker>,
79 let waker = unsafe { ManuallyDrop::new(Waker::from_raw(raw_waker::<T>(header))) }; in new()
89 type Target = Waker;
|
| H A D | join_handle.rs | 22 use std::task::{Context, Poll, Waker};
82 pub(crate) fn set_waker(&mut self, waker: &Waker) { in set_waker() argument
87 .set_waker(cur, (waker as *const Waker).cast::<()>()) in set_waker()
|
| H A D | join_set.rs | 22 use std::task::{Context, Poll, RawWaker, RawWakerVTable, Waker};
66 waker: Option<Waker>,
456 fn entry_into_waker<R>(entry: &Arc<JoinEntry<R>>) -> Waker { in entry_into_waker() argument
459 unsafe { Waker::from_raw(RawWaker::new(data, get_entry_waker_table::<R>())) } in entry_into_waker()
|
| H A D | task_handle.rs | 17 use std::task::{Context, Poll, Waker};
107 fn set_waker_inner(&self, des_waker: Waker, cur_state: usize) -> Result<usize, usize> { in set_waker_inner() argument
131 pub(crate) fn set_waker(self, cur: usize, des_waker: &Waker) -> bool { in set_waker()
|
| H A D | raw.rs | 20 use std::task::{Context, Poll, Waker};
187 pub(crate) waker: UnsafeCell<Option<Waker>>,
313 let waker = &*(waker.cast::<Waker>()); in set_waker()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | block_on.rs | 18 use std::task::{Context, Poll, RawWaker, RawWakerVTable, Waker};
65 pub(crate) fn waker(&self) -> Waker { in waker() argument
67 unsafe { Waker::from_raw(RawWaker::new(data, &BLOCK_ON_RAW_WAKER_VIRTUAL_TABLE)) } in waker()
|
| H A D | worker.rs | 17 use std::task::Waker;
128 pub(crate) yielded: RefCell<Vec<Waker>>,
|
| H A D | current_thread.rs | 23 use std::task::{Context, Poll, RawWaker, RawWakerVTable, Waker};
203 fn waker(parker: Arc<Parker>) -> Waker { in waker() argument
205 unsafe { Waker::from_raw(RawWaker::new(data, &CURRENT_THREAD_RAW_WAKER_VIRTUAL_TABLE)) } in waker()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | driver.rs | 19 use std::task::Waker;
66 waker_list: &mut [Option<Waker>; 32],
98 let mut waker_list: [Option<Waker>; 32] = Default::default(); in run()
|
| H A D | wheel.rs | 20 use std::task::Waker;
51 waker: Option<Waker>,
99 pub(crate) fn take_waker(&mut self) -> Option<Waker> { in take_waker() argument
104 pub(crate) fn set_waker(&mut self, waker: Waker) { in set_waker() argument
|
| H A D | sleep.rs | 81 use std::task::Waker;
87 waker: Option<*mut Waker>,
|
| /ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
| H A D | scheduler.rs | 29 use std::task::{ Context, Poll, Waker };
70 waker: Option<Waker>,
98 fn set_waker(&mut self, waker: &Waker) in set_waker() argument
318 fn dispatch_inner(&self, fd: RawFd, waker: &Waker) -> Option<(Arc<dyn IEpollHandler>, u32)> in dispatch_inner()
337 fn dispatch(&self, fd: RawFd, waker: &Waker) in dispatch() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | schedule_io.rs | 23 use std::task::{Context, Poll, Waker};
55 reader: Option<Waker>,
57 writer: Option<Waker>,
63 waker: Option<Waker>,
|
| H A D | driver.rs | 79 pub(crate) waker: ylong_io::Waker,
102 fn new(inner: Arc<Inner>, waker: ylong_io::Waker) -> Self { in new()
199 let waker = ylong_io::Waker::new(&poll, WAKE_TOKEN) in initialize()
|