Searched refs:try_io (Results 1 – 9 of 9) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 272 self.state.try_io(|mut inner| inner.read(buf), &self.inner)
276 self.state.try_io(|mut inner| inner.read_vectored(bufs), &self.inner)
282 self.state.try_io(|mut inner| inner.write(buf), &self.inner)
286 self.state.try_io(|mut inner| inner.write_vectored(bufs), &self.inner)
290 self.state.try_io(|mut inner| inner.flush(), &self.inner)
|
| H A D | listener.rs | 74 .try_io(|inner| inner.accept(), &self.inner) in accept()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 114 .try_io(|inner| inner.send_to(buf, target), &self.inner) in send_to()
133 self.state.try_io(|inner| inner.recv_from(buf), &self.inner) in recv_from()
153 self.state.try_io(|inner| inner.peek_from(buf), &self.inner) in peek_from()
432 self.state.try_io(|inner| inner.send(buf), &self.inner) in send()
457 self.state.try_io(|inner| inner.recv(buf), &self.inner) in recv()
483 self.state.try_io(|inner| inner.peek(buf), &self.inner) in peek()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 276 .try_io(Interest::WRITABLE, || self.source.send_to(buf, target)) in try_send_to()
383 .try_io(Interest::READABLE, || self.source.recv_from(buf)) in try_recv_from()
435 .try_io(Interest::READABLE, || self.source.peek_from(buf)) in try_peek_from()
999 .try_io(Interest::WRITABLE, || self.source.send(buf)) in try_send()
1124 .try_io(Interest::READABLE, || self.source.recv(buf)) in try_recv()
1246 .try_io(Interest::READABLE, || self.source.peek(buf)) in try_peek()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | datagram.rs | 170 .try_io(Interest::READABLE, || (*self.source).recv(buf)) in try_recv()
238 .try_io(Interest::WRITABLE, || (*self.source).send(buf)) in try_send()
|
| H A D | stream.rs | 240 .try_io(Interest::READABLE, || (&*self.source).read(buf)) in try_read()
308 .try_io(Interest::WRITABLE, || (&*self.source).write(buf)) in try_write()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 191 .try_io(Interest::READABLE, || (&*self.source).read(buf)) in try_read()
256 .try_io(Interest::WRITABLE, || (&*self.source).write(buf)) in try_write()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | net.rs | 77 pub(crate) fn try_io<T, F, R>(&self, task: F, io: &T) -> io::Result<R> in try_io() method
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 137 pub(crate) fn try_io<R> (
|