Searched refs:async_io (Results 1 – 7 of 7) sorted by relevance
| /external/rust/crates/tokio/src/net/ |
| D | udp.rs | 466 .async_io(Interest::WRITABLE, || self.io.send(buf)) in send()
639 .async_io(Interest::READABLE, || self.io.recv(buf)) in recv()
997 .async_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in send_to_addr()
1029 .async_io(Interest::READABLE, || self.io.recv_from(buf)) in recv_from()
1159 .async_io(Interest::READABLE, || self.io.peek_from(buf)) in peek_from()
|
| /external/rust/crates/tokio/src/net/unix/datagram/ |
| D | socket.rs | 520 .async_io(Interest::WRITABLE, || self.io.send(buf)) in send()
643 .async_io(Interest::READABLE, || self.io.recv(buf)) in recv()
860 .async_io(Interest::WRITABLE, || self.io.send_to(buf, target.as_ref())) in send_to()
901 .async_io(Interest::READABLE, || self.io.recv_from(buf)) in recv_from()
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | listener.rs | 135 .async_io(Interest::READABLE, || self.io.accept()) in accept()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | listener.rs | 153 .async_io(Interest::READABLE, || self.io.accept()) in accept()
|
| D | stream.rs | 818 .async_io(Interest::READABLE, || self.io.peek(buf)) in peek()
|
| /external/rust/crates/tokio/src/io/driver/ |
| D | registration.rs | 248 …pub(crate) async fn async_io<R>(&self, interest: Interest, mut f: impl FnMut() -> io::Result<R>) -…
|
| /external/libiio/src/iiod/ |
| D | ops.c | 135 static ssize_t async_io(struct parser_pdata *pdata, void *buf, size_t len, in async_io() function
219 return async_io(pdata, dest, len, true); in readfd_aio()
227 return async_io(pdata, (void *)dest, len, false); in writefd_aio()
|