| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 44 conn_in.local_addr()?, in test_udp_conn_map_insert_remove()
45 conn_out.local_addr()?, in test_udp_conn_map_insert_remove()
52 conn_map.delete(&conn_in.local_addr()?).await?; in test_udp_conn_map_insert_remove()
83 conn_in.local_addr()?, in test_udp_conn_map_insert_0_remove()
84 conn_out.local_addr()?, in test_udp_conn_map_insert_0_remove()
122 let addr_in = conn_in.local_addr()?; in test_udp_conn_map_find_0()
123 let addr_out = conn_out.local_addr()?; in test_udp_conn_map_find_0()
158 let addr_in = conn_in1.local_addr()?; in test_udp_conn_map_insert_many_ips_with_same_port()
159 let addr_out = conn_out1.local_addr()?; in test_udp_conn_map_insert_many_ips_with_same_port()
169 let addr_in = conn_in2.local_addr()?; in test_udp_conn_map_insert_many_ips_with_same_port()
[all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | allocation_test.rs | 12 let relay_addr = relay_socket.local_addr()?; in test_has_permission()
50 let relay_addr = relay_socket.local_addr()?; in test_add_permission()
74 let relay_addr = relay_socket.local_addr()?; in test_remove_permission()
107 let relay_addr = relay_socket.local_addr()?; in test_add_channel_bind()
141 let relay_addr = relay_socket.local_addr()?; in test_get_channel_by_number()
177 let relay_addr = relay_socket.local_addr()?; in test_get_channel_by_addr()
209 let relay_addr = relay_socket.local_addr()?; in test_remove_channel_bind()
246 let relay_addr = relay_socket.local_addr()?; in test_allocation_refresh()
268 let relay_addr = relay_socket.local_addr()?; in test_allocation_close()
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 28 let addr = conn.local_addr()?; in insert()
37 let laddr = c.local_addr()?; in insert()
66 match c.local_addr() { in find()
86 let laddr = c.local_addr()?; in delete()
|
| H A D | net.rs | 325 mut local_addr: SocketAddr, in bind()
328 if !self.has_ipaddr(local_addr.ip()) { in bind()
332 if local_addr.port() == 0 { in bind()
334 local_addr.set_port(self.assign_port(local_addr.ip(), 5000, 5999).await?); in bind()
337 if vi.udp_conns.find(&local_addr).await.is_some() { in bind()
343 let conn = Arc::new(UdpConn::new(local_addr, None, v)); in bind()
548 let local_addr = SocketAddr::new(any_ip, 0); in dail() localVariable
550 let conn = UdpSocket::bind(local_addr).await?; in dail()
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp.rs | 27 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() method
28 Ok(self.local_addr()?) in local_addr()
|
| H A D | conn_disconnected_packet.rs | 50 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() method
51 self.pconn.local_addr() in local_addr()
|
| H A D | conn_udp_listener.rs | 72 self.pconn.local_addr() in addr()
280 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() method
281 self.pconn.local_addr() in local_addr()
|
| H A D | mod.rs | 33 fn local_addr(&self) -> Result<SocketAddr>; in local_addr() method
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 26 pub local_addr: SocketAddr, field
232 fn local_addr(&self) -> SocketAddr { in local_addr() method
233 self.params.local_addr in local_addr()
283 let normalized_target = normalize_socket_addr(&target, &self.inner.params.local_addr); in send_to()
292 fn local_addr(&self) -> ConnResult<SocketAddr> { in local_addr() method
293 Ok(self.inner.local_addr()) in local_addr()
|
| H A D | udp_mux_test.rs | 65 let addr = udp_socket.local_addr()?; in test_udp_mux()
173 remote_connection.local_addr().unwrap(), in test_mux_connection()
193 let remote_connection_addr = remote_connection.local_addr()?; in test_mux_connection()
|
| H A D | mod.rs | 108 let local_addr = self.params.conn.local_addr()?; in create_muxed_conn() localVariable
111 local_addr, in create_muxed_conn()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport_test.rs | 73 let result = disconnected_conn.local_addr(); in test_remote_local_addr()
92 let a_laddr = ca.local_addr()?; in test_remote_local_addr()
93 let b_laddr = cb.local_addr()?; in test_remote_local_addr()
|
| H A D | agent_gather.rs | 296 let port = match conn.local_addr() { in gather_candidates_local()
430 let port = conn.local_addr()?.port(); in gather_candidates_local_udp_mux()
502 let laddr = conn.local_addr()?; in gather_candidates_srflx_mapped()
661 let laddr = conn.local_addr()?; in gather_candidates_srflx()
768 let local_addr = loc_conn.local_addr()?; in gather_candidates_relay() localVariable
769 let rel_addr = local_addr.ip().to_string(); in gather_candidates_relay()
770 let rel_port = local_addr.port(); in gather_candidates_relay()
833 let raddr = relay_conn.local_addr()?; in gather_candidates_relay()
|
| /webrtc/turn/src/relay/ |
| H A D | relay_range.rs | 63 let mut relay_addr = conn.local_addr()?; in allocate_conn()
79 let mut relay_addr = conn.local_addr()?; in allocate_conn()
|
| H A D | relay_none.rs | 36 let relay_addr = conn.local_addr()?; in allocate_conn()
|
| H A D | relay_static.rs | 42 let mut relay_addr = conn.local_addr()?; in allocate_conn()
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 47 let server_port = conn.local_addr()?.port(); in test_server_simple()
280 let local_addr = conn.local_addr()?; in test_server_vnet_echo_via_relay() localVariable
282 log::debug!("laddr: {}", conn.local_addr()?); in test_server_vnet_echo_via_relay()
285 let echo_addr = echo_conn.local_addr()?; in test_server_vnet_echo_via_relay()
308 assert_eq!(local_addr.to_string(), from.to_string(), "should match"); in test_server_vnet_echo_via_relay()
|
| H A D | request.rs | 299 dst_addr: self.conn.local_addr()?, in handle_allocate_request()
568 dst_addr: self.conn.local_addr()?, in handle_refresh_request()
602 dst_addr: self.conn.local_addr()?, in handle_create_permission_request()
669 dst_addr: self.conn.local_addr()?, in handle_send_indication()
710 dst_addr: self.conn.local_addr()?, in handle_channel_bind_request()
779 dst_addr: self.conn.local_addr()?, in handle_channel_data()
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 61 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() method
62 self.next_conn.local_addr() in local_addr()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 62 let laddr = conn.local_addr()?; in test_net_native_bind()
79 let laddr = conn.local_addr()?; in test_net_native_dail()
97 let laddr = conn.local_addr()?; in test_net_native_loopback()
412 let laddr = conn.local_addr()?; in test_net_virtual_loopback1()
433 let laddr = conn.local_addr()?; in test_net_virtual_bind_specific_port()
451 let laddr = conn.local_addr()?; in test_net_virtual_dail_lo0()
483 let laddr = conn.local_addr()?; in test_net_virtual_dail_eth0()
529 let laddr = conn.local_addr()?; in test_net_virtual_resolver()
558 let laddr = conn.local_addr()?; in test_net_virtual_loopback2()
761 let n = conn1.send_to(b"Hello!", conn2.local_addr()?).await?; in test_net_virtual_end2end()
[all …]
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 53 let src_addr = client_listener.local_addr()?; in test_packet_handler()
73 dst_addr: turn_socket.local_addr()?, in test_packet_handler()
88 peer_listener2.local_addr()?, in test_packet_handler()
93 a.add_permission(Permission::new(peer_listener1.local_addr()?)) in test_packet_handler()
99 a.relay_socket.local_addr()?.port() in test_packet_handler()
404 let server_port = conn.local_addr()?.port(); in create_server()
|
| /webrtc/util/ |
| H A D | CHANGELOG.md | 12 - `local_addr`;
|
| /webrtc/turn/src/client/ |
| H A D | mod.rs | 169 let local_addr = config.conn.local_addr()?; in new() localVariable
171 .resolve_addr(local_addr.is_ipv4(), &config.stun_serv_addr) in new()
181 let local_addr = config.conn.local_addr()?; in new() localVariable
183 .resolve_addr(local_addr.is_ipv4(), &config.turn_serv_addr) in new()
|
| /webrtc/turn/examples/ |
| H A D | turn_client_udp.rs | 105 println!("relayed-address={}", relay_conn.local_addr()?); in main()
135 let relay_addr = relay_conn.local_addr()?; in do_ping_test()
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 43 println!("Local address: {}", conn.local_addr()?); in main()
|