Home
last modified time | relevance | path

Searched refs:recv_from (Results 1 - 9 of 9) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Ddatagram.rs161 /// 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 Dylong_tokio_udp.rs162 /// 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 Ddatagram.rs386 /// 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 Dudp_socket_test.rs78 /// 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 Duds_test.rs164 match receiver.recv_from(&mut recv_buf[..]) { in sdv_uds_send_recv()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
H A Dudp_socket.rs24 /// 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 Dudp_socket.rs129 /// 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 Dwheel.rs480 timeout(Duration::from_secs(2), receiver.recv_from(&mut buf[..])) in ut_sleep_drop()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dudp_test.rs60 /// 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