| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | addr.rs | 25 F: FnMut(SocketAddr) -> io::Result<T>, in each_addr()
47 type Iter: Iterator<Item = SocketAddr>;
82 impl ToSocketAddrs for SocketAddr { implementation
83 type Iter = option::IntoIter<SocketAddr>;
91 type Iter = option::IntoIter<SocketAddr>;
99 type Iter = option::IntoIter<SocketAddr>;
107 type Iter = option::IntoIter<SocketAddr>;
119 type Iter = option::IntoIter<SocketAddr>;
137 type Iter = vec::IntoIter<SocketAddr>;
162 type Iter = vec::IntoIter<SocketAddr>;
[all …]
|
| H A D | udp.rs | 17 use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr};
202 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
274 pub fn try_send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in try_send_to()
311 target: SocketAddr, in poll_send_to() argument
345 pub async fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from() argument
381 pub fn try_recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_recv_from() argument
433 pub fn try_peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_peek_from() argument
472 ) -> Poll<io::Result<SocketAddr>> { in poll_peek_from() argument
572 ) -> Poll<io::Result<SocketAddr>> { in poll_recv_from() argument
791 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | resolver.rs | 19 use std::net::{SocketAddr, ToSocketAddrs};
27 pub type Addrs = Box<dyn Iterator<Item = SocketAddr> + Sync + Send>;
43 iter: IntoIter<SocketAddr>,
47 pub(super) fn new(iter: IntoIter<SocketAddr>) -> Self { in new()
52 pub(super) fn split_preferred_addrs(self) -> (Vec<SocketAddr>, Vec<SocketAddr>) { in split_preferred_addrs() argument
58 .map(SocketAddr::is_ipv6) in split_preferred_addrs()
66 type Item = SocketAddr;
|
| H A D | happy_eyeballs.rs | 20 use std::net::SocketAddr;
52 addrs: Vec<SocketAddr>,
56 iter: core::slice::Iter<'a, SocketAddr>,
60 pub(crate) fn new(addrs: Vec<SocketAddr>) -> Self { in new()
72 type Item = &'a SocketAddr;
80 type Target = core::slice::Iter<'a, SocketAddr>;
106 fn new(addrs: Vec<SocketAddr>, timeout: Option<Duration>) -> Self { in new() argument
133 pub(crate) fn new(socket_addr: Vec<SocketAddr>, config: EyeBallConfig) -> Self { in new() argument
235 addr: &SocketAddr, in connect() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | socket_addr.rs | 65 pub struct SocketAddr { struct
70 impl SocketAddr { argument
71 pub(crate) fn from_parts(sockaddr: libc::sockaddr_un, socklen: libc::socklen_t) -> SocketAddr { in from_parts() argument
72 SocketAddr { sockaddr, socklen } in from_parts()
76 impl fmt::Debug for SocketAddr { implementation
108 use crate::SocketAddr;
122 let addr = SocketAddr::from_parts(sock_addr, 10); in ut_uds_socket_addr_debug_info()
|
| H A D | listener.rs | 23 use crate::sys::unix::SocketAddr;
61 pub fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept() argument
93 SocketAddr::from_parts(addr, socklen), in accept()
142 pub fn local_addr(&self) -> io::Result<net::SocketAddr> { in local_addr() argument
|
| H A D | datagram.rs | 130 pub fn local_addr(&self) -> io::Result<net::SocketAddr> { in local_addr() argument
146 pub fn peer_addr(&self) -> io::Result<net::SocketAddr> { in peer_addr() argument
166 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, net::SocketAddr)> { in recv_from() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | listener.rs | 16 use std::net::{self, SocketAddr};
37 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind()
56 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
105 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
162 ) -> io::Result<SocketAddr> { in trans_addr_2_socket() argument
164 libc::AF_INET => Ok(SocketAddr::V4(*(storage.cast::<sockaddr_in>().cast::<_>()))), in trans_addr_2_socket()
165 libc::AF_INET6 => Ok(SocketAddr::V6( in trans_addr_2_socket()
|
| H A D | socket.rs | 16 use std::net::{self, SocketAddr};
35 pub(crate) fn new_socket(addr: SocketAddr) -> io::Result<TcpSocket> { in new_socket()
65 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind()
78 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect()
|
| H A D | stream.rs | 15 use std::net::{self, Shutdown, SocketAddr};
33 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
66 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
86 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() argument
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/interceptor/ |
| H A D | mod.rs | 16 use std::net::SocketAddr;
41 pub(crate) local: SocketAddr,
43 pub(crate) peer: SocketAddr,
57 pub fn local(&self) -> SocketAddr { in local() argument
62 pub fn peer(&self) -> SocketAddr { in peer() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 15 use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr};
88 pub fn bind(addr: SocketAddr) -> io::Result<UdpSocket> { in bind()
119 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
178 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
211 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from() argument
232 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from() argument
261 pub fn connect(self, addr: SocketAddr) -> io::Result<ConnectedUdpSocket> { in connect()
432 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
460 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() argument
|
| H A D | socket.rs | 14 use std::net::SocketAddr;
29 pub(crate) fn new_socket(addr: SocketAddr) -> io::Result<UdpSock> { in new_socket()
44 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<UdpSocket> { in bind()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 15 use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr};
42 pub fn bind(addr: SocketAddr) -> io::Result<UdpSocket> { in bind()
62 pub fn connect(self, addr: SocketAddr) -> io::Result<ConnectedUdpSocket> { in connect()
92 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
112 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
132 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from() argument
152 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from() argument
343 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
370 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() argument
|
| H A D | socket.rs | 14 use std::net::SocketAddr;
33 pub(crate) fn new_socket(addr: SocketAddr) -> io::Result<UdpSock> { in new_socket()
60 pub(crate) fn bind(self, addr: SocketAddr) -> io::Result<net::UdpSocket> { in bind()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | socket_addr.rs | 15 use std::net::SocketAddr;
32 pub(crate) fn socket_addr_trans(addr: &SocketAddr) -> (SocketAddrLibC, socklen_t) { in socket_addr_trans()
34 SocketAddr::V4(ref addr) => { in socket_addr_trans()
52 SocketAddr::V6(ref addr) => { in socket_addr_trans()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | socket_addr.rs | 15 use std::net::SocketAddr;
34 pub(crate) fn socket_addr_trans(addr: &SocketAddr) -> (SocketAddrWin, i32) { in socket_addr_trans()
36 SocketAddr::V4(ref addr) => { in socket_addr_trans()
56 SocketAddr::V6(ref addr) => { in socket_addr_trans()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | listener.rs | 15 use std::net::SocketAddr;
43 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind()
72 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
89 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
|
| H A D | socket.rs | 15 use std::net::SocketAddr;
35 pub(crate) fn new_socket(addr: SocketAddr) -> io::Result<TcpSocket> { in new_socket()
64 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind()
92 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<()> { in connect()
|
| H A D | stream.rs | 16 use std::net::{Shutdown, SocketAddr};
44 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
84 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
104 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_tcp.rs | 15 use std::net::SocketAddr;
24 async fn ylong_tcp_server(addr: SocketAddr) { in ylong_tcp_server() argument
37 async fn ylong_tcp_client(addr: SocketAddr) { in ylong_tcp_client() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_udp.rs | 26 use std::net::SocketAddr;
90 let sender_addr: SocketAddr = (basic_addr.to_owned() in ylong_udp_send_recv()
94 let receiver_addr: SocketAddr = (basic_addr.to_owned() in ylong_udp_send_recv()
177 let sender_addr: SocketAddr = (basic_addr.to_owned() in ylong_udp_send_to_recv_from()
181 let receiver_addr: SocketAddr = (basic_addr.to_owned() in ylong_udp_send_to_recv_from()
|
| H A D | ylong_tokio_tcp.rs | 77 pub async fn $server(addr: SocketAddr) {
90 pub async fn $client(addr: SocketAddr) {
133 use std::net::SocketAddr;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | listener.rs | 15 use std::net::SocketAddr;
99 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
124 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 15 use std::net::SocketAddr;
28 let addr: SocketAddr = "127.0.0.1:0".parse().unwrap(); in sdv_tcp_server()
98 let addr: SocketAddr = "127.0.0.1:0".parse().unwrap(); in sdv_tcp_server_vectored()
|