Searched refs:peer_addr (Results 1 - 13 of 13) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | stream.rs | 82 /// stream.peer_addr().unwrap(),
86 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() functions
87 self.inner.peer_addr() in peer_addr()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 142 /// let addr = socket.peer_addr().expect("get peer_addr() fail");
146 pub fn peer_addr(&self) -> io::Result<net::SocketAddr> { in peer_addr() functions
147 self.inner.peer_addr() in peer_addr()
322 let addr = receiver.peer_addr().unwrap(); in ut_uds_datagram_pair()
|
| H A D | stream.rs | 117 /// let addr = socket.peer_addr().expect("get peer_addr() fail");
121 pub fn peer_addr(&self) -> io::Result<net::SocketAddr> { in peer_addr() functions
122 self.inner.peer_addr() in peer_addr()
274 let addr = receiver.peer_addr().unwrap(); in ut_uds_stream_pair()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 100 /// stream.peer_addr().unwrap(),
104 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() functions
105 self.inner.peer_addr() in peer_addr()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 301 /// stream.peer_addr().unwrap(), in fmt()
307 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in fmt() functions
308 self.source.peer_addr() in fmt()
679 /// 3. Call peer_addr(), local_addr(), set_ttl(), ttl(), set_nodelay(),
694 assert_eq!(stream.peer_addr().unwrap(), addr); in ut_tcp_stream_basic()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 448 /// let peer_addr = "127.0.0.1:8081".parse().unwrap();
450 /// let connected_sock = match sock.connect(peer_addr) {
456 /// assert_eq!(connected_sock.peer_addr()?, peer_addr);
460 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() functions
461 self.inner.peer_addr() in peer_addr()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 366 /// connected_sender.peer_addr().unwrap(),
370 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() functions
371 self.inner.peer_addr() in peer_addr()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 180 .peer_addr() in connect()
256 let peer = stream.peer_addr().map_err(|e| { in connect()
297 let peer = udp_socket.peer_addr().map_err(|e| { in connect()
374 .peer_addr()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 807 /// let peer_addr = "127.0.0.1:8081";
809 /// let connected_sock = match sock.connect(peer_addr).await {
815 /// assert_eq!(connected_sock.peer_addr()?, peer_addr.parse().unwrap());
819 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr() functions
820 self.source.peer_addr() in peer_addr()
836 /// let peer_addr = "127.0.0.1:8081";
838 /// let connected_sock = match socket.connect(peer_addr).await {
866 /// let peer_addr = "127.0.0.1:8081";
868 /// let connected_sock = match socket.connect(peer_addr)
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 144 let addr = sender.peer_addr().unwrap(); in sdv_uds_send_recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | udp_test.rs | 172 let (len, peer_addr) = ret.unwrap(); in sdv_udp_try_recv_from()
174 assert_eq!(peer_addr, sender_addr); in sdv_udp_try_recv_from()
|
| H A D | tcp_test.rs | 111 /// 3. Call peer_addr(), local_addr(), set_ttl(), ttl(), set_nodelay(),
127 assert_eq!(stream.peer_addr().unwrap(), addr); in sdv_tcp_stream_basic()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | happy_eyeballs.rs | 325 let stream_addr_family = if stream.peer_addr().unwrap().is_ipv4() { in ut_happy_eyeballs_connect()
|
Completed in 10 milliseconds