Searched refs:WRITABLE (Results 1 – 12 of 12) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | interest.rs | 22 const WRITABLE: u8 = 0b0010; const
29 pub const WRITABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(WRITABLE) }); const
43 (self.0.get() & WRITABLE) != 0 in is_writable()
103 let interest = Interest::WRITABLE; in ut_interest_to_io_event()
107 let interest = Interest::READABLE | Interest::WRITABLE; in ut_interest_to_io_event()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | ready.rs | 19 const WRITABLE: usize = 0b0_10; const
41 pub const WRITABLE: Ready = Ready(WRITABLE); const
47 pub const ALL: Ready = Ready(READABLE | WRITABLE | READ_CLOSED | WRITE_CLOSED);
58 ready |= Ready::WRITABLE; in from_event()
80 (self & Ready::WRITABLE).0 != 0 || self.is_write_closed() in is_writable()
108 ready |= Ready::WRITABLE; in from_interest()
202 ready |= Ready::WRITABLE;
396 let interest = Interest::WRITABLE; in ut_ready_from_interest()
|
| H A D | async_source.rs | 66 let interest = interest.unwrap_or_else(|| Interest::READABLE | Interest::WRITABLE); in new()
172 self.poll_io(cx, Interest::WRITABLE, f)
|
| H A D | schedule_io.rs | 142 Interest::WRITABLE => waiters.writer = Some(cx.waker().clone()), in poll_readiness()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | datagram.rs | 202 self.ready(Interest::WRITABLE).await?; in writable()
238 .try_io(Interest::WRITABLE, || (*self.source).send(buf)) in try_send()
327 .async_process(Interest::WRITABLE, || self.source.send(buf)) in send()
349 .async_process(Interest::WRITABLE, || { in send_to()
|
| H A D | stream.rs | 61 Interest::WRITABLE, in connect()
272 self.ready(Interest::WRITABLE).await?; in writable()
308 .try_io(Interest::WRITABLE, || (&*self.source).write(buf)) in try_write()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | driver.rs | 59 Interest::READABLE | Interest::WRITABLE, in initialize()
82 Interest::READABLE | Interest::WRITABLE, in initialize()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 107 Interest::WRITABLE, in connect_inner()
222 self.source.entry.readiness(Interest::WRITABLE).await?; in writable()
256 .try_io(Interest::WRITABLE, || (&*self.source).write(buf)) in try_write()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 236 .async_process(Interest::WRITABLE, || self.source.send_to(buf, addr)) in send_to()
276 .try_io(Interest::WRITABLE, || self.source.send_to(buf, target)) in try_send_to()
533 self.source.entry.readiness(Interest::WRITABLE).await?; in writable()
959 .async_process(Interest::WRITABLE, || self.source.send(buf)) in send()
999 .try_io(Interest::WRITABLE, || self.source.send(buf)) in try_send()
1309 self.source.entry.readiness(Interest::WRITABLE).await?; in writable()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| H A D | ylong_io_tcp_server.rs | 48 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in main()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | epoll.rs | 183 let ret = selector.reregister(sock, Token::from_usize(0), Interest::WRITABLE); in ut_epoll_reregister()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 86 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in server()
|