| /webrtc/util/src/vnet/nat/ |
| H A D | nat_test.rs | 3 use std::net::SocketAddr;
67 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_full_cone_nat()
82 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_full_cone_nat()
91 SocketAddr::new(dst.ip(), 7777), in test_nat_mapping_behavior_full_cone_nat()
129 SocketAddr::from_str("5.6.7.9:9000")?, in test_nat_mapping_behavior_addr_restricted_cone_nat()
137 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_addr_restricted_cone_nat()
152 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_addr_restricted_cone_nat()
161 SocketAddr::new(dst.ip(), 7777), in test_nat_mapping_behavior_addr_restricted_cone_nat()
208 SocketAddr::from_str("5.6.7.9:9000")?, in test_nat_mapping_behavior_port_restricted_cone_nat()
216 SocketAddr::new(dst.ip(), dst.port()), in test_nat_mapping_behavior_port_restricted_cone_nat()
[all …]
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 2 use std::{collections::HashSet, io, net::SocketAddr, sync::Arc, sync::Weak};
26 pub local_addr: SocketAddr,
115 pub fn get_addresses(&self) -> Vec<SocketAddr> { in get_addresses() argument
120 pub async fn add_address(&self, addr: SocketAddr) { in add_address() argument
128 pub fn remove_address(&self, addr: &SocketAddr) { in remove_address() argument
145 addresses: Mutex<HashSet<SocketAddr>>,
232 fn local_addr(&self) -> SocketAddr { in local_addr() argument
237 pub(super) fn get_addresses(&self) -> Vec<SocketAddr> { in get_addresses() argument
250 pub(super) fn remove_address(&self, addr: &SocketAddr) { in remove_address() argument
292 fn local_addr(&self) -> ConnResult<SocketAddr> { in local_addr() argument
[all …]
|
| H A D | socket_addr_ext.rs | 3 use std::net::SocketAddr;
16 fn decode(buffer: &[u8]) -> Result<SocketAddr, Error>; in decode() argument
26 impl SocketAddrExt for SocketAddr { implementation
28 use std::net::SocketAddr::{V4, V6}; in encode()
112 Ok(SocketAddr::V6(SocketAddrV6::new( in decode()
139 let decoded = SocketAddr::decode(&buffer); in test_ipv4()
146 let ip = SocketAddr::V6(SocketAddrV6::new( in test_ipv6()
196 let decoded = SocketAddr::decode(&buffer); in test_ipv6()
214 let ip = SocketAddr::V6(SocketAddrV6::new( in test_encode_ipv6_with_short_buffer()
232 let result = SocketAddr::decode(&buffer); in test_decode_ipv4_with_short_buffer()
[all …]
|
| H A D | mod.rs | 1 use std::{collections::HashMap, io::ErrorKind, net::SocketAddr, sync::Arc, sync::Weak};
27 fn normalize_socket_addr(target: &SocketAddr, socket_addr: &SocketAddr) -> SocketAddr { in normalize_socket_addr() argument
29 (SocketAddr::V4(target_ipv4), SocketAddr::V6(_)) => { in normalize_socket_addr()
32 SocketAddr::new(std::net::IpAddr::V6(ipv6_mapped), target_ipv4.port()) in normalize_socket_addr()
75 address_map: RwLock<HashMap<SocketAddr, UDPMuxConn>>,
119 async fn conn_from_stun_message(&self, buffer: &[u8], addr: &SocketAddr) -> Option<UDPMuxConn> { in conn_from_stun_message()
308 async fn register_conn_for_address(&self, conn: &UDPMuxConn, addr: SocketAddr) { in register_conn_for_address() argument
331 async fn send_to(&self, buf: &[u8], target: &SocketAddr) -> Result<usize, Error> { in send_to()
|
| /webrtc/util/src/conn/ |
| H A D | mod.rs | 20 use std::net::SocketAddr;
28 async fn connect(&self, addr: SocketAddr) -> Result<()>; in connect()
30 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>; in recv_from() argument
32 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize>; in send_to()
33 fn local_addr(&self) -> Result<SocketAddr>; in local_addr() argument
34 fn remote_addr(&self) -> Option<SocketAddr>; in remote_addr() argument
43 async fn accept(&self) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)>; in accept() argument
50 async fn addr(&self) -> Result<SocketAddr>; in addr() argument
53 pub async fn lookup_host<T>(use_ipv4: bool, host: T) -> Result<SocketAddr> in lookup_host()
|
| H A D | conn_disconnected_packet.rs | 12 raddr: RwLock<SocketAddr>,
19 raddr: RwLock::new(SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0)), in new()
27 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect()
37 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
46 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to()
50 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
54 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr() argument
|
| H A D | conn_udp.rs | 7 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect()
15 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
23 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to()
27 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
31 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr() argument
|
| H A D | conn_pipe.rs | 31 async fn connect(&self, _addr: SocketAddr) -> Result<()> { in connect()
46 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
48 Ok((n, SocketAddr::from_str("0.0.0.0:0")?)) in recv_from()
60 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to()
64 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
68 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr() argument
|
| H A D | conn_udp_listener.rs | 36 async fn accept(&self) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)> { in accept() argument
71 async fn addr(&self) -> Result<SocketAddr> { in addr() argument
193 raddr: SocketAddr, in get_udp_conn() argument
238 raddr: SocketAddr,
246 raddr: SocketAddr, in new() argument
259 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect()
267 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
276 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to()
280 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
284 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr() argument
|
| /webrtc/turn/src/allocation/five_tuple/ |
| H A D | five_tuple_test.rs | 26 let src_addr1: SocketAddr = "0.0.0.0:3478".parse::<SocketAddr>()?; in test_five_tuple_equal()
27 let src_addr2: SocketAddr = "0.0.0.0:3479".parse::<SocketAddr>()?; in test_five_tuple_equal()
29 let dst_addr1: SocketAddr = "0.0.0.0:3480".parse::<SocketAddr>()?; in test_five_tuple_equal()
30 let dst_addr2: SocketAddr = "0.0.0.0:3481".parse::<SocketAddr>()?; in test_five_tuple_equal()
|
| /webrtc/util/src/vnet/ |
| H A D | interface.rs | 3 use std::net::SocketAddr;
28 pub fn convert(addr: SocketAddr, mask: Option<SocketAddr>) -> Result<IpNet> { in convert() argument
31 (SocketAddr::V4(_), SocketAddr::V4(mask)) => { in convert()
41 (SocketAddr::V6(_), SocketAddr::V6(mask)) => { in convert()
|
| H A D | chunk.rs | 8 use std::net::{IpAddr, SocketAddr};
101 fn source_addr(&self) -> SocketAddr; in source_addr() argument
102 fn destination_addr(&self) -> SocketAddr; in destination_addr() argument
182 fn source_addr(&self) -> SocketAddr { in source_addr() argument
186 fn destination_addr(&self) -> SocketAddr { in destination_addr() argument
213 let addr = SocketAddr::from_str(address)?; in set_source_addr()
220 let addr = SocketAddr::from_str(address)?; in set_destination_addr()
228 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr) -> Self { in new() argument
289 fn source_addr(&self) -> SocketAddr { in source_addr() argument
293 fn destination_addr(&self) -> SocketAddr { in destination_addr() argument
[all …]
|
| H A D | conn.rs | 9 use std::net::{IpAddr, SocketAddr};
22 async fn on_closed(&self, addr: SocketAddr); in on_closed() argument
31 loc_addr: SocketAddr,
32 rem_addr: RwLock<Option<SocketAddr>>,
41 loc_addr: SocketAddr, in new() argument
42 rem_addr: Option<SocketAddr>, in new() argument
64 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect()
81 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
122 let src_addr = SocketAddr::new(src_ip, self.loc_addr.port()); in send_to()
135 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
[all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | five_tuple.rs | 7 use std::net::{Ipv4Addr, SocketAddr};
18 pub src_addr: SocketAddr,
19 pub dst_addr: SocketAddr,
26 src_addr: SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0), in default()
27 dst_addr: SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0), in default()
|
| H A D | allocation_test.rs | 22 let addr1 = SocketAddr::from_str("127.0.0.1:3478")?; in test_has_permission()
23 let addr2 = SocketAddr::from_str("127.0.0.1:3479")?; in test_has_permission()
24 let addr3 = SocketAddr::from_str("127.0.0.2:3478")?; in test_has_permission()
60 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_add_permission()
84 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_remove_permission()
117 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_add_channel_bind()
129 let addr2 = SocketAddr::from_str("127.0.0.1:3479")?; in test_add_channel_bind()
151 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_get_channel_by_number()
187 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_get_channel_by_addr()
219 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_remove_channel_bind()
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | permission.rs | 2 use std::net::SocketAddr;
50 pub(crate) fn insert(&mut self, addr: &SocketAddr, p: Arc<Permission>) { in insert() argument
54 pub(crate) fn find(&self, addr: &SocketAddr) -> Option<&Arc<Permission>> { in find()
58 pub(crate) fn delete(&mut self, addr: &SocketAddr) { in delete() argument
62 pub(crate) fn addrs(&self) -> Vec<SocketAddr> { in addrs() argument
66 a.push(SocketAddr::new(ip, 0)); in addrs()
|
| H A D | binding.rs | 5 use std::net::SocketAddr;
28 pub(crate) addr: SocketAddr,
78 pub(crate) fn create(&mut self, addr: SocketAddr) -> Option<&Binding> { in create()
91 pub(crate) fn find_by_addr(&self, addr: &SocketAddr) -> Option<&Binding> { in find_by_addr()
95 pub(crate) fn get_by_addr(&mut self, addr: &SocketAddr) -> Option<&mut Binding> { in get_by_addr()
115 pub(crate) fn delete_by_addr(&mut self, addr: &SocketAddr) -> bool { in delete_by_addr()
|
| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 18 async fn on_closed(&self, _addr: SocketAddr) {} in on_closed() argument
33 SocketAddr::from_str("127.0.0.1:1234")?, in test_udp_conn_map_insert_remove()
72 SocketAddr::from_str("0.0.0.0:1234")?, in test_udp_conn_map_insert_0_remove()
111 SocketAddr::from_str("0.0.0.0:1234")?, in test_udp_conn_map_find_0()
140 SocketAddr::from_str("10.1.2.1:5678")?, in test_udp_conn_map_insert_many_ips_with_same_port()
146 SocketAddr::from_str("10.1.2.2:5678")?, in test_udp_conn_map_insert_many_ips_with_same_port()
187 SocketAddr::from_str("10.1.2.1:5678")?, in test_udp_conn_map_already_inuse_when_insert_0()
192 SocketAddr::from_str("0.0.0.0:5678")?, in test_udp_conn_map_already_inuse_when_insert_0()
212 SocketAddr::from_str("0.0.0.0:5678")?, in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
217 SocketAddr::from_str("192.168.0.1:5678")?, in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
[all …]
|
| /webrtc/util/src/ifaces/ |
| H A D | mod.rs | 6 Broadcast(::std::net::SocketAddr),
7 Destination(::std::net::SocketAddr),
23 pub addr: Option<::std::net::SocketAddr>,
24 pub mask: Option<::std::net::SocketAddr>,
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 7 use std::net::SocketAddr;
36 async fn connect(&self, _addr: SocketAddr) -> Result<()> { in connect()
48 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
57 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to()
61 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
65 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr() argument
|
| H A D | mux_test.rs | 5 use std::net::SocketAddr;
52 async fn connect(&self, _addr: SocketAddr) -> Result<()> { in connect()
71 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument
79 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to()
83 fn local_addr(&self) -> Result<SocketAddr> { in local_addr() argument
87 fn remote_addr(&self) -> Option<SocketAddr> { in remote_addr() argument
|
| /webrtc/ice/src/mdns/ |
| H A D | mod.rs | 9 use std::net::SocketAddr;
54 SocketAddr::from_str(DEFAULT_DEST_ADDR)? in create_multicast_dns()
56 SocketAddr::from_str("0.0.0.0:5353")? in create_multicast_dns()
59 SocketAddr::from_str(dest_addr)? in create_multicast_dns()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 6 use std::net::{IpAddr, Ipv4Addr, SocketAddr};
30 dst_addr: SocketAddr,
46 addr: SocketAddr,
78 if let Some(SocketAddr::V4(e)) = interface.addr { in server()
103 let dst_addr: SocketAddr = DEFAULT_DEST_ADDR.parse()?; in server()
167 ) -> Result<(ResourceHeader, SocketAddr)> { in query() argument
248 dst_addr: SocketAddr, in start() argument
296 src: SocketAddr, in run() argument
297 dst_addr: SocketAddr, in run() argument
384 interface_addr: &SocketAddr, in send_answer() argument
[all …]
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 9 use std::net::{IpAddr, SocketAddr};
15 pub fn create_addr(_network: NetworkType, ip: IpAddr, port: u16) -> SocketAddr { in create_addr() argument
21 SocketAddr::new(ip, port) in create_addr()
50 server_addr: SocketAddr, in get_xormapped_addr() argument
63 server_addr: SocketAddr, in stun_request() argument
138 laddr: SocketAddr, in listen_udp_in_port_range() argument
152 let laddr = SocketAddr::new(laddr.ip(), port_current); in listen_udp_in_port_range()
|
| /webrtc/turn/src/relay/ |
| H A D | mod.rs | 10 use std::net::SocketAddr;
25 ) -> Result<(Arc<dyn Conn + Send + Sync>, SocketAddr)>; in allocate_conn() argument
|