Searched refs:recv_from (Results 1 - 9 of 9) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 161 /// let (size, sender) = socket.recv_from(buf.as_mut_slice())?;
166 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, net::SocketAddr)> { in recv_from() functions
167 self.inner.recv_from(buf) in recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_udp.rs | 162 /// Benchmark test for ylong udp function send_to() and recv_from().
167 /// 3. Receiver use recv_from() to receives message.
193 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await.unwrap(); in ylong_udp_send_to_recv_from()
205 /// Benchmark test for tokio udp function send_to() and recv_from().
210 /// 3. Receiver use recv_from() to receives message.
233 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await.unwrap(); in tokio_udp_send_to_recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | datagram.rs | 386 /// let (size, sender) = socket.recv_from(buf.as_mut_slice()).await?;
391 pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, net::SocketAddr)> {
393 .async_process(Interest::READABLE, || self.source.recv_from(buf))
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | udp_socket_test.rs | 78 /// SDV test cases for `send_to()` and `recv_from()`.
115 match receiver.recv_from(&mut recv_buf[..]) { in sdv_send_to_recv_from()
|
| H A D | uds_test.rs | 164 match receiver.recv_from(&mut recv_buf[..]) { in sdv_uds_send_recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 24 /// UdpSocket supports bind\connect\send\recv\send_to\recv_from\broadcast.
43 /// let (len, addr) = receiver.recv_from(&mut buf)?;
206 /// let (len, addr) = sock.recv_from(&mut recv_buf)?;
211 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from() functions
213 inner.recv_from(buf) in recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 129 /// let (number_of_bytes, src_addr) = socket.recv_from(&mut buf).expect("Didn't receive data");
132 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from() functions
133 self.state.try_io(|inner| inner.recv_from(buf), &self.inner) in recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 480 timeout(Duration::from_secs(2), receiver.recv_from(&mut buf[..])) in ut_sleep_drop()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | udp_test.rs | 60 /// SDV test cases for `send_to()` and `recv_from()`.
82 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await.unwrap(); in sdv_udp_send_to_recv_from()
|
Completed in 6 milliseconds