Searched refs:wake (Results 1 - 18 of 18) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | waker.rs | 42 /// In Linux, `eventfd` is used to implement asynchronous wake-up. It is a
44 /// ensure wake-up reliability.
64 pub(crate) fn wake(&self) -> io::Result<()> {
72 _ => self.wake(),
82 /// In MacOs, kqueue with `EVFILT_USER` is used to implement asynchronous wake-up.
96 pub(crate) fn wake(&self) -> io::Result<()> {
97 self.selector.wake(self.token)
|
| H A D | kqueue.rs | 136 /// before `Selector::wake`
150 pub fn wake(&self, token: Token) -> io::Result<()> { in wake() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | current_thread.rs | 99 let (mut park, mut wake) = (true, false); in park()
101 (park, wake) = self.park_on_driver(&mut driver); in park()
106 wake in park()
173 fn unpark(&self, wake: bool) { in unpark()
174 if wake { in unpark()
183 PARKED_ON_DRIVER => self.handle.wake(), in unpark()
196 PARKED_ON_DRIVER => self.handle.wake(), in unpark()
209 RawWakerVTable::new(clone, wake, wake_by_ref, drop);
221 fn wake(ptr: *const ()) { in wake() functions
285 let mut wake variables
[all...] |
| H A D | driver_handle.rs | 47 pub(crate) fn wake(&self) {
49 self.io.waker.wake().unwrap_or_else(|e| panic!("ylong_io wake failed, error: {e}"));
93 self.wake();
|
| H A D | block_on.rs | 21 RawWakerVTable::new(clone, wake, wake_by_ref, drop);
33 fn wake(ptr: *const ()) { in wake() functions
|
| H A D | parker.rs | 172 PARKED_ON_DRIVER => handle.wake(), in unpark()
|
| H A D | worker.rs | 48 waker.wake();
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | atomic_waker.rs | 58 waker.wake();
70 pub(crate) fn wake(&self) {
72 waker.wake();
|
| H A D | oneshot.rs | 177 self.channel.waker.wake(); in send()
218 self.channel.waker.wake(); in drop()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | waker.rs | 31 pub fn wake(&self) -> io::Result<()> { in wake() functions
32 self.inner.wake() in wake()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | waker.rs | 42 unsafe fn wake(ptr: *const ()) { in wake() functions
65 let raw_waker_ref = &RawWakerVTable::new(clone::<T>, wake, wake_by_ref, drop); in raw_waker()
|
| H A D | join_set.rs | 65 // Waker of JoinSet, a ready task will wake the JoinSet it belongs to
133 waker.wake(); in wake_by_ref()
|
| H A D | raw.rs | 345 task_handle.wake(); in schedule()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | waker.rs | 36 pub(crate) fn wake(&self) -> io::Result<()> {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | driver.rs | 83 .wake();
125 .wake();
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | array.rs | 112 self.rx_waker.wake();
193 self.rx_waker.wake(); in close()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 190 io.wake(ready) in dispatch()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | queue.rs | 147 self.rx_waker.wake(); in send_inner()
239 self.rx_waker.wake(); in close()
|
Completed in 7 milliseconds