| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | udp_test.rs | 18 use ylong_runtime::net::UdpSocket;
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()
382 let sender = UdpSocket::bind(ADDR) in sdv_udp_send_to_recv_from_poll()
385 let receiver = UdpSocket::bind(ADDR) in sdv_udp_send_to_recv_from_poll()
461 let sender = UdpSocket::bind(ADDR).await.unwrap(); in sdv_set_get_broadcast()
462 let receiver = UdpSocket::bind(ADDR).await.unwrap(); in sdv_set_get_broadcast()
486 let sender = UdpSocket::bind(ADDR).await.unwrap(); in sdv_udp_basic_v4()
487 let receiver = UdpSocket::bind(ADDR).await.unwrap(); in sdv_udp_basic_v4()
549 let sender = UdpSocket::bind(addr).await.unwrap(); in sdv_udp_basic_v6()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 67 pub struct UdpSocket { struct
68 pub(crate) source: AsyncSource<ylong_io::UdpSocket>,
76 impl Debug for UdpSocket { implementation
88 impl UdpSocket { impl
117 .map(UdpSocket::new) in bind()
126 Ok(UdpSocket { source }) in new()
1409 impl AsRawSocket for UdpSocket { implementation
1429 impl AsRawFd for UdpSocket { implementation
1449 use crate::net::{ConnectedUdpSocket, UdpSocket};
1461 F: FnMut(&UdpSocket), in udp_try_bind_connect() argument
[all …]
|
| H A D | mod.rs | 20 pub use udp::{ConnectedUdpSocket, UdpSocket};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 25 pub struct UdpSocket { struct
26 pub(crate) inner: net::UdpSocket,
31 impl UdpSocket { impl
42 pub fn bind(addr: SocketAddr) -> io::Result<UdpSocket> { in bind() argument
44 sock.bind(addr).map(UdpSocket::from_std) in bind()
69 pub fn from_std(socket: net::UdpSocket) -> UdpSocket { in from_std() argument
70 UdpSocket { in from_std()
307 pub(crate) inner: net::UdpSocket,
624 impl fmt::Debug for UdpSocket { implementation
636 impl Source for UdpSocket { implementation
[all …]
|
| H A D | socket.rs | 60 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<net::UdpSocket> { in bind() argument
61 let socket = unsafe { net::UdpSocket::from_raw_socket(self.socket as raw::SOCKET) }; in bind()
|
| H A D | mod.rs | 18 pub use udp_socket::{ConnectedUdpSocket, UdpSocket};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 65 pub struct UdpSocket { struct
66 pub(crate) inner: net::UdpSocket,
69 impl UdpSocket { implementation
88 pub fn bind(addr: SocketAddr) -> io::Result<UdpSocket> { in bind() argument
99 pub fn from_std(socket: net::UdpSocket) -> UdpSocket { in from_std() argument
100 UdpSocket { inner: socket } in from_std()
395 pub(crate) inner: net::UdpSocket,
405 pub fn from_std(socket: net::UdpSocket) -> ConnectedUdpSocket { in from_std()
744 impl fmt::Debug for UdpSocket { implementation
756 impl Source for UdpSocket { implementation
|
| H A D | socket.rs | 22 use crate::UdpSocket;
44 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<UdpSocket> { in bind() argument
45 let udp_socket = UdpSocket { in bind()
46 inner: unsafe { net::UdpSocket::from_raw_fd(self.socket) }, in bind()
|
| H A D | mod.rs | 20 pub use udp_socket::{ConnectedUdpSocket, UdpSocket};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | udp_socket_test.rs | 16 use ylong_io::UdpSocket;
30 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_recv()
37 let receiver = match UdpSocket::bind(receiver_addr) { in sdv_send_recv()
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()
|
| /ohos5.0/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()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | mod.rs | 32 TcpListener, TcpStream, ToSocketAddrs, UdpSocket,
|
| /ohos5.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()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | lib.rs | 24 pub use sys::{ConnectedUdpSocket, UdpSocket};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | mod.rs | 34 pub use self::udp::{UdpSocket, ConnectedUdpSocket};
|
| /ohos5.0/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")); in init()
|