| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 26 /// Asynchronous UdpSocket.
33 /// use ylong_runtime::net::UdpSocket;
38 /// let mut sender = UdpSocket::bind(sender_addr).await?;
39 /// let mut receiver = UdpSocket::bind(sender_addr).await?;
67 pub struct UdpSocket { structure names
68 pub(crate) source: AsyncSource<ylong_io::UdpSocket>,
71 /// A connected asynchronous UdpSocket.
76 impl Debug for UdpSocket {
88 impl UdpSocket { impls
106 /// use ylong_runtime::net::UdpSocket;
[all...] |
| H A D | mod.rs | 20 pub use udp::{ConnectedUdpSocket, UdpSocket};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | udp_test.rs | 18 use ylong_runtime::net::UdpSocket;
25 /// 1. Create UdpSocket and connect to the remote address.
32 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv()
33 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_recv()
63 /// 1. Create UdpSocket.
70 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from()
71 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_send_to_recv_from()
100 let receiver = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_recv()
101 let sender = UdpSocket::bind(ADDR).await.expect("Bind Socket Failed"); in sdv_udp_recv()
136 /// 1. Create UdpSocket
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 25 pub struct UdpSocket { structure names
26 pub(crate) inner: net::UdpSocket,
31 impl UdpSocket { impls
32 /// Binds a new UdpSocket to the specific address.
37 /// use ylong_io::UdpSocket;
40 /// let sender = UdpSocket::bind(sender_addr).expect("UdpSocket bind fail!");
42 pub fn bind(addr: SocketAddr) -> io::Result<UdpSocket> { in bind()
44 sock.bind(addr).map(UdpSocket::from_std) in bind()
52 /// use ylong_io::UdpSocket;
[all...] |
| H A D | mod.rs | 18 pub use udp_socket::{ConnectedUdpSocket, UdpSocket};
|
| H A D | socket.rs | 59 /// System call gets net::UdpSocket
60 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<net::UdpSocket> {
61 let socket = unsafe { net::UdpSocket::from_raw_socket(self.socket as raw::SOCKET) };
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | udp_socket_test.rs | 16 use ylong_io::UdpSocket;
21 /// 1. Create UdpSocket and connect to the remote address.
30 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_recv()
37 let receiver = match UdpSocket::bind(receiver_addr) { in sdv_send_recv()
81 /// 1. Create UdpSocket.
90 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_to_recv_from()
97 let receiver = match UdpSocket::bind(receiver_addr) { in sdv_send_to_recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | socket.rs | 22 use crate::UdpSocket;
44 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<UdpSocket> {
45 let udp_socket = UdpSocket {
46 inner: unsafe { net::UdpSocket::from_raw_fd(self.socket) },
|
| H A D | udp_socket.rs | 23 /// UdpSocket. The bottom layer uses std::net::UdpSocket。
24 /// UdpSocket supports bind\connect\send\recv\send_to\recv_from\broadcast.
31 /// use ylong_io::UdpSocket;
36 /// let mut sender = UdpSocket::bind(sender_addr)?;
37 /// let mut receiver = UdpSocket::bind(receiver_addr)?;
65 pub struct UdpSocket { structure names
66 pub(crate) inner: net::UdpSocket,
69 impl UdpSocket { impls
78 /// use ylong_io::UdpSocket;
[all...] |
| H A D | mod.rs | 20 pub use udp_socket::{ConnectedUdpSocket, UdpSocket};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_udp.rs | 29 use tokio::net::UdpSocket as tokioUdpSocket;
30 use ylong_runtime::net::UdpSocket;
46 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_connect()
99 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_recv()
100 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_recv()
186 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_to_recv_from()
187 let receiver = UdpSocket::bind(receiver_addr).await.unwrap(); in ylong_udp_send_to_recv_from()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | lib.rs | 24 pub use sys::{ConnectedUdpSocket, UdpSocket};
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | mod.rs | 34 pub use self::udp::{UdpSocket, ConnectedUdpSocket};
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | mod.rs | 73 pub use self::udp::{UdpSocket, ConnectedUdpSocket};
|
| H A D | net.rs | 26 drop(net::UdpSocket::bind("127.0.0.1:0"));
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 435 use crate::net::UdpSocket;
467 let sender = UdpSocket::bind(ADDR).await.unwrap(); in ut_sleep_drop()
475 let receiver = UdpSocket::bind(ADDR).await.unwrap(); in ut_sleep_drop()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 26 use ylong_runtime::net::{ConnectedUdpSocket, UdpSocket};
136 let sock = UdpSocket::bind(local_addr)
|