Searched refs:raddr (Results 1 – 8 of 8) sorted by relevance
| /webrtc/util/src/conn/ |
| H A D | conn_disconnected_packet.rs | 12 raddr: RwLock<SocketAddr>, field
19 raddr: RwLock::new(SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0)), in new()
33 *self.raddr.write() = addr; in recv()
42 let addr = *self.raddr.read(); in send()
55 let raddr = *self.raddr.read(); in remote_addr() localVariable
56 Some(raddr) in remote_addr()
|
| H A D | conn_udp_listener.rs | 42 let raddr = c.raddr; in accept() localVariable
43 Ok((c, raddr)) in accept()
157 Ok((n, raddr)) => { in read_loop()
164 raddr, in read_loop()
193 raddr: SocketAddr, in get_udp_conn()
238 raddr: SocketAddr, field
246 raddr: SocketAddr, in new()
251 raddr, in new()
269 Ok((n, self.raddr)) in recv_from()
273 self.pconn.send_to(buf, self.raddr).await in send()
[all …]
|
| H A D | conn_udp_listener_test.rs | 29 let (l_conn, raddr) = listener.accept().await?; in pipe()
30 assert_eq!(daddr, raddr, "remote address should be match"); in pipe()
32 let raddr = l_conn.remote_addr(); in pipe() localVariable
33 if let Some(raddr) = raddr { in pipe()
34 assert_eq!(daddr, raddr, "remote address should be match"); in pipe()
121 Ok((c, raddr)) => (c, raddr), in test_listener_accept_filter()
|
| /webrtc/dtls/src/ |
| H A D | listener.rs | 75 let (conn, raddr) = self.parent.accept().await?; in accept()
79 Ok((Arc::new(dtls_conn), raddr)) in accept()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 104 let (n, raddr) = conn.recv_from(&mut buf).await?; in test_net_native_loopback()
107 assert_eq!(laddr, raddr, "should match addr {laddr}"); in test_net_native_loopback()
419 let (n, raddr) = conn.recv_from(&mut buf).await?; in test_net_virtual_loopback1()
422 assert_eq!(laddr, raddr, "should match addr {laddr}"); in test_net_virtual_loopback1()
524 let (conn, raddr) = { in test_net_virtual_resolver()
525 let raddr = nw.resolve_addr(true, "test.webrtc.rs:1234").await?; in test_net_virtual_resolver() localVariable
526 (nw.dail(true, "test.webrtc.rs:1234").await?, raddr) in test_net_virtual_resolver()
538 raddr.to_string(), in test_net_virtual_resolver()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport.rs | 188 if let Some(raddr) = self.remote_addr() { in recv_from()
190 Ok((n, raddr)) in recv_from()
|
| H A D | agent_gather.rs | 833 let raddr = relay_conn.local_addr()?; in gather_candidates_relay() localVariable
837 address: raddr.ip().to_string(), in gather_candidates_relay()
838 port: raddr.port(), in gather_candidates_relay()
857 raddr, in gather_candidates_relay()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 117 if let Some(raddr) = self.conn.remote_addr() { in recv_from()
119 Ok((n, raddr)) in recv_from()
|