| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_udp.rs | 108 let mut recv_buf = [0_u8; 12]; in ylong_udp_send_recv() variables
109 let len = connected_receiver.recv(&mut recv_buf[..]).await.unwrap(); in ylong_udp_send_recv()
111 assert_eq!(&recv_buf[..len], b"Hello"); in ylong_udp_send_recv()
149 let mut recv_buf = [0_u8; 12]; in tokio_udp_send_recv() variables
150 let len = receiver.recv(&mut recv_buf[..]).await.unwrap(); in tokio_udp_send_recv()
152 assert_eq!(&recv_buf[..len], b"Hello"); in tokio_udp_send_recv()
192 let mut recv_buf = [0_u8; 12]; in ylong_udp_send_to_recv_from() variables
193 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await.unwrap(); in ylong_udp_send_to_recv_from()
194 assert_eq!(&recv_buf[..len], b"Hello"); in ylong_udp_send_to_recv_from()
232 let mut recv_buf in tokio_udp_send_to_recv_from() variables
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | udp_socket_test.rs | 66 let mut recv_buf = [0_u8; 12]; in sdv_send_recv() variables
68 match connected_receiver.recv(&mut recv_buf[..]) { in sdv_send_recv()
75 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_send_recv()
113 let mut recv_buf = [0_u8; 12]; in sdv_send_to_recv_from() variables
115 match receiver.recv_from(&mut recv_buf[..]) { in sdv_send_to_recv_from()
121 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_send_to_recv_from()
|
| H A D | uds_test.rs | 160 let mut recv_buf = [0_u8; 12]; in sdv_uds_send_recv() variables
164 match receiver.recv_from(&mut recv_buf[..]) { in sdv_uds_send_recv()
179 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_uds_send_recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | udp_test.rs | 52 let mut recv_buf = [0_u8; 12]; in sdv_udp_send_recv() variables
53 let len = connected_receiver.recv(&mut recv_buf[..]).await.unwrap(); in sdv_udp_send_recv()
55 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_udp_send_recv()
81 let mut recv_buf = [0_u8; 12]; in sdv_udp_send_to_recv_from() variables
82 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await.unwrap(); in sdv_udp_send_to_recv_from()
83 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_udp_send_to_recv_from()
124 let mut recv_buf = [0_u8; 12]; in sdv_udp_recv() variables
125 let len = connected_receiver.recv(&mut recv_buf[..]).await.unwrap(); in sdv_udp_recv()
126 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_udp_recv()
162 let mut recv_buf in sdv_udp_try_recv_from() variables
219 let mut recv_buf = [0_u8; 12]; sdv_udp_try_recv() variables
257 let mut recv_buf = [0_u8; 12]; sdv_udp_block_on_try_recv() variables
293 let mut recv_buf = [0_u8; 12]; sdv_udp_send_recv_poll() variables
397 let mut recv_buf = [0_u8; 12]; sdv_udp_send_to_recv_from_poll() variables
430 let mut recv_buf = [0_u8; 12]; sdv_udp_send_to_peek_from_poll() variables
[all...] |
| H A D | tcp_test.rs | 209 let mut recv_buf = [0_u8; 12]; in sdv_tcp_global_runtime() variables
211 .read(&mut recv_buf) in sdv_tcp_global_runtime()
215 std::str::from_utf8(&recv_buf).unwrap(), in sdv_tcp_global_runtime()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| H A D | ylong_runtime_tcp_client_perf.rs | 30 let mut recv_buf = [1_u8; 1024]; in main() variables
32 match stream.write(&recv_buf).await { in main()
41 match stream.read(&mut recv_buf).await { in main()
|
| H A D | ylong_tokio_tcp_perf.rs | 34 let mut recv_buf = [0_u8; 12]; in ylong_create_client() variables
48 match client.read(&mut recv_buf).await { in ylong_create_client()
51 std::str::from_utf8(&recv_buf).unwrap(), in ylong_create_client()
68 let mut recv_buf = [0_u8; 12]; in tokio_create_client() variables
84 match client.read(&mut recv_buf).await { in tokio_create_client()
87 std::str::from_utf8(&recv_buf).unwrap(), in tokio_create_client()
|
| H A D | ylong_runtime_tcp_server_perf.rs | 31 let mut recv_buf = [0_u8; 1024]; in main() variables
40 match stream.read(&mut recv_buf).await { in main()
50 match stream.write(&recv_buf).await { in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 339 /// let mut recv_buf = [0_u8; 12];
340 /// let (len, addr) = sock.recv_from(&mut recv_buf).await?;
376 /// let mut recv_buf = [0_u8; 12];
377 /// let (len, addr) = sock.try_recv_from(&mut recv_buf)?;
461 /// let mut recv_buf = [0_u8; 12];
462 /// let mut read = ReadBuf::new(&mut recv_buf);
561 /// let mut recv_buf = [0_u8; 12];
562 /// let mut read = ReadBuf::new(&mut recv_buf);
1071 /// let mut recv_buf = [0_u8; 12]; in poll_send()
1072 /// let n = connected_sock.recv(&mut recv_buf[ in poll_send()
1609 let mut recv_buf = [0_u8; 12]; ut_send_recv_poll() variables
1641 let mut recv_buf = [0_u8; 12]; ut_send_to_recv_from_poll() variables
1813 let mut recv_buf = [0_u8; 12]; ut_send_to_peek_from_poll() variables
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | io_manager.rs | 42 recv_buf: [u8; UPD_RECV_BUF_SIZE],
60 recv_buf: [0u8; UPD_RECV_BUF_SIZE],
83 let mut buf = ReadBuf::new(&mut self.recv_buf); in poll_io_recv()
|