Searched refs:ready (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | ready.rs | 33 pub(crate) ready: Ready,
51 let mut ready = Ready::EMPTY; variables
54 ready |= Ready::READABLE;
58 ready |= Ready::WRITABLE;
62 ready |= Ready::READ_CLOSED;
66 ready |= Ready::WRITE_CLOSED;
68 ready
100 let mut ready = Ready::EMPTY; variables
103 ready |= Ready::READABLE;
104 ready |
196 let mut ready = Ready::EMPTY; global() variables
[all...] |
| H A D | schedule_io.rs | 136 let ready = Ready::from_usize(curr_bit.get_by_mask(READINESS)).intersection(interest);
138 if ready.is_empty() {
147 // Check one more time to see if any event is ready
149 if !waiters.is_shutdown && ready_event.ready.is_empty() {
156 Poll::Ready(ReadyEvent::new(tick, ready))
163 let ready = Ready::from_usize(status_bit.get_by_mask(READINESS)).intersection(interest);
165 ReadyEvent::new(tick, ready)
183 pub(crate) fn clear_readiness(&self, ready: ReadyEvent) {
184 let mask_no_closed = ready.get_ready() - Ready::READ_CLOSED - Ready::WRITE_CLOSED;
185 let _ = self.set_readiness(None, Tick::Clear(ready
[all...] |
| H A D | async_source.rs | 83 let ready = self.entry.readiness(interest).await?;
86 self.entry.clear_readiness(ready);
110 let ready = self.entry.poll_readiness(cx, interest);
111 let x = match ready {
126 let ready = poll_ready!(self.poll_ready(cx, interest))?;
130 self.entry.clear_readiness(ready);
144 if event.ready.is_empty() {
|
| H A D | driver.rs | 53 /// Stores every IO source that is ready
167 fn dispatch(&mut self, token: Token, ready: Ready) { in dispatch()
183 .set_readiness(Some(token.0), Tick::Set(self.tick), |curr| curr | ready) in dispatch()
190 io.wake(ready) in dispatch()
273 let ready = Ready::from_event(event);
274 self.dispatch(token, ready);
333 extern "C" fn ffrt_dispatch_event(data: *const c_void, ready: c_uint, new_tick: c_uchar) { in ffrt_dispatch_event()
346 let ready = crate::net::ready::from_event_inner(ready a in ffrt_dispatch_event()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 119 /// Waits for any of the requested ready states.
133 /// let ready = stream
134 /// .ready(Interest::READABLE | Interest::WRITABLE)
137 /// if ready.is_readable() {
152 /// if ready.is_writable() {
168 pub async fn ready(&self, interest: Interest) -> Result<Ready> {
170 Ok(event.ready)
173 /// Waits for `Interest::READABLE` requested ready states.
203 self.ready(Interest::READABLE).await?;
243 /// Waits for `Interest::WRITABLE` requested ready state
[all...] |
| H A D | datagram.rs | 49 /// Waits for any of the requested ready states.
63 /// let ready = stream
64 /// .ready(Interest::READABLE | Interest::WRITABLE)
67 /// if ready.is_readable() {
82 /// if ready.is_writable() {
98 pub async fn ready(&self, interest: Interest) -> Result<Ready> {
100 Ok(event.ready)
103 /// Waits for `Interest::READABLE` requested ready states.
133 self.ready(Interest::READABLE).await?;
173 /// Waits for `Interest::WRITABLE` requested ready state
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/ |
| H A D | split.rs | 25 macro_rules! ready { macros
76 let mut guard = ready!(self.inner.get_lock(cx)); in poll_read()
87 let mut inner = ready!(self.inner.get_lock(cx)); in poll_write()
96 let mut inner = ready!(self.inner.get_lock(cx)); in poll_write_vectored()
105 let mut inner = ready!(self.inner.get_lock(cx)); in poll_flush()
110 let mut inner = ready!(self.inner.get_lock(cx)); in poll_shutdown()
|
Completed in 3 milliseconds