| /webrtc/stun/src/xoraddr/ |
| H A D | xoraddr_test.rs | 47 addr.get_from(&m)?; in test_xormapped_address_get_from()
49 addr.ip.to_string(), in test_xormapped_address_get_from()
52 addr.ip in test_xormapped_address_get_from()
54 assert_eq!(addr.port, 48583, "bad Port {} != 48583", addr.port); in test_xormapped_address_get_from()
118 addr.ip = expected_ip; in test_xormapped_address_get_from_invalid()
120 addr.add_to(&mut m)?; in test_xormapped_address_get_from_invalid()
145 addr.add_to(&mut m)?; in test_xormapped_address_add_to()
150 addr.get_from(&m_res)?; in test_xormapped_address_add_to()
152 addr.ip, expected_ip, in test_xormapped_address_add_to()
154 addr.ip, expected_ip in test_xormapped_address_add_to()
[all …]
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 28 let addr = conn.local_addr()?; in insert() localVariable
31 if let Some(conns) = port_map.get(&addr.port()) { in insert()
32 if addr.ip().is_unspecified() { in insert()
47 port_map.insert(addr.port(), vec![conn]); in insert()
54 if let Some(conns) = port_map.get(&addr.port()) { in find()
55 if addr.ip().is_unspecified() { in find()
83 if let Some(conns) = port_map.get(&addr.port()) { in delete()
84 if !addr.ip().is_unspecified() { in delete()
92 if laddr.ip() == addr.ip() { in delete()
103 port_map.remove(&addr.port()); in delete()
[all …]
|
| H A D | interface.rs | 17 pub fn add_addr(&mut self, addr: IpNet) { in add_addr()
18 self.addrs.push(addr); in add_addr()
28 pub fn convert(addr: SocketAddr, mask: Option<SocketAddr>) -> Result<IpNet> { in convert()
30 match (addr, mask) { in convert()
56 let s = format!("{}/{}", addr.ip(), prefix); in convert()
|
| H A D | net.rs | 101 return Some(ipnet.addr()); in determine_source_ip()
133 for addr in addrs { in add_addrs_to_interface()
134 ifc.add_addr(*addr); in add_addrs_to_interface()
143 for addr in addrs { in add_addrs_to_interface()
144 ifc.add_addr(*addr); in add_addrs_to_interface()
189 if (ipv6 && ipnet.addr().is_ipv6()) || (!ipv6 && ipnet.addr().is_ipv4()) { in get_all_ipaddrs()
190 ips.push(ipnet.addr()); in get_all_ipaddrs()
202 let loc_ip = ipnet.addr(); in has_ipaddr()
454 if let Some(addr) = iface.addr { in new()
459 } else if let Some(addr) = iface.addr { in new()
[all …]
|
| H A D | chunk.rs | 213 let addr = SocketAddr::from_str(address)?; in set_source_addr() localVariable
214 self.chunk_ip.source_ip = addr.ip(); in set_source_addr()
215 self.source_port = addr.port(); in set_source_addr()
220 let addr = SocketAddr::from_str(address)?; in set_destination_addr() localVariable
221 self.chunk_ip.destination_ip = addr.ip(); in set_destination_addr()
222 self.destination_port = addr.port(); in set_destination_addr()
321 let addr = SocketAddr::from_str(address)?; in set_source_addr() localVariable
322 self.chunk_ip.source_ip = addr.ip(); in set_source_addr()
323 self.source_port = addr.port(); in set_source_addr()
329 self.chunk_ip.destination_ip = addr.ip(); in set_destination_addr()
[all …]
|
| H A D | conn.rs | 22 async fn on_closed(&self, addr: SocketAddr); in on_closed()
64 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect()
65 self.rem_addr.write().replace(addr); in connect()
88 let addr = chunk.source_addr(); in recv_from() localVariable
91 if &addr != rem_addr { in recv_from()
96 return Ok((n, addr)); in recv_from()
|
| /webrtc/stun/src/addr/ |
| H A D | addr_test.rs | 7 let addr = MappedAddress { in test_mapped_address() localVariable
11 assert_eq!(addr.to_string(), "122.12.34.5:5412", "bad string {addr}"); in test_mapped_address()
15 addr.add_to(&mut m)?; in test_mapped_address()
21 assert_eq!(got.ip, addr.ip, "got bad IP: {}", got.ip); in test_mapped_address()
69 let addr = MappedAddress { in test_mapped_address_v6() localVariable
76 addr.add_to(&mut m)?; in test_mapped_address_v6()
82 assert_eq!(got.ip, addr.ip, "got bad IP: {}", got.ip); in test_mapped_address_v6()
108 let addr = MappedAddress { in test_alternate_server() localVariable
115 addr.add_to(&mut m)?; in test_alternate_server()
148 let addr = OtherAddress { in test_other_address() localVariable
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | binding.rs | 28 pub(crate) addr: SocketAddr, field
78 pub(crate) fn create(&mut self, addr: SocketAddr) -> Option<&Binding> { in create()
82 addr, in create()
86 self.chan_map.insert(b.number, b.addr.to_string()); in create()
87 self.addr_map.insert(b.addr.to_string(), b); in create()
88 self.addr_map.get(&addr.to_string()) in create()
91 pub(crate) fn find_by_addr(&self, addr: &SocketAddr) -> Option<&Binding> { in find_by_addr()
92 self.addr_map.get(&addr.to_string()) in find_by_addr()
96 self.addr_map.get_mut(&addr.to_string()) in get_by_addr()
115 pub(crate) fn delete_by_addr(&mut self, addr: &SocketAddr) -> bool { in delete_by_addr()
[all …]
|
| H A D | permission.rs | 50 pub(crate) fn insert(&mut self, addr: &SocketAddr, p: Arc<Permission>) { in insert()
51 self.perm_map.insert(addr.ip().to_string(), p); in insert()
54 pub(crate) fn find(&self, addr: &SocketAddr) -> Option<&Arc<Permission>> { in find()
55 self.perm_map.get(&addr.ip().to_string()) in find()
58 pub(crate) fn delete(&mut self, addr: &SocketAddr) { in delete()
59 self.perm_map.remove(&addr.ip().to_string()); in delete()
|
| H A D | relay_conn.rs | 163 match relay_conn.send_to(p, addr).await { in send_to()
214 let perm = if let Some(perm) = self.perm_map.find(&addr) { in send_to()
218 self.perm_map.insert(&addr, Arc::clone(&perm)); in send_to()
224 result = self.create_perm(&perm, addr).await; in send_to()
240 .create(addr) in send_to()
243 (b.state(), b.refreshed_at(), b.number, b.addr) in send_to()
293 let peer_addr = socket_addr2peer_address(&addr); in send_to()
370 self.perm_map.delete(&addr); in create_perm()
399 for addr in addrs { in create_permissions()
625 ip: addr.ip(), in socket_addr2peer_address()
[all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | allocation_test.rs | 60 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_add_permission() localVariable
61 let p = Permission::new(addr); in test_add_permission()
64 let found_p = a.has_permission(&addr).await; in test_add_permission()
84 let addr = SocketAddr::from_str("127.0.0.1:3478")?; in test_remove_permission() localVariable
86 let p = Permission::new(addr); in test_remove_permission()
89 let found_p = a.has_permission(&addr).await; in test_remove_permission()
92 a.remove_permission(&addr).await; in test_remove_permission()
160 assert_eq!(addr, exist_channel_addr); in test_get_channel_by_number()
221 let c = ChannelBind::new(number, addr); in test_remove_channel_bind()
284 let c = ChannelBind::new(number, addr); in test_allocation_close()
[all …]
|
| H A D | permission.rs | 13 pub(crate) addr: SocketAddr, field
21 pub fn new(addr: SocketAddr) -> Self { in new()
23 addr, in new()
35 let addr = self.addr; in start() localVariable
48 p.remove(&addr2ipfingerprint(&addr)); in start()
|
| H A D | mod.rs | 89 fn addr2ipfingerprint(addr: &SocketAddr) -> String { in addr2ipfingerprint()
90 addr.ip().to_string() in addr2ipfingerprint()
123 pub async fn has_permission(&self, addr: &SocketAddr) -> bool { in has_permission()
125 permissions.get(&addr2ipfingerprint(addr)).is_some() in has_permission()
130 let fingerprint = addr2ipfingerprint(&p.addr); in add_permission()
150 pub async fn remove_permission(&self, addr: &SocketAddr) -> bool { in remove_permission()
152 permissions.remove(&addr2ipfingerprint(addr)).is_some() in remove_permission()
159 if let Some(addr) = self.get_channel_addr(&c.number).await { in add_channel_bind()
160 if addr != c.peer { in add_channel_bind()
214 pub async fn get_channel_number(&self, addr: &SocketAddr) -> Option<ChannelNumber> { in get_channel_number()
[all …]
|
| /webrtc/util/src/ifaces/ffi/unix/ |
| H A D | mod.rs | 105 (addr & 0x000000FF) as u8, in nix_socketaddr_to_sockaddr()
119 addr[0] as u16, in nix_socketaddr_to_sockaddr()
120 addr[1] as u16, in nix_socketaddr_to_sockaddr()
121 addr[2] as u16, in nix_socketaddr_to_sockaddr()
122 addr[3] as u16, in nix_socketaddr_to_sockaddr()
123 addr[4] as u16, in nix_socketaddr_to_sockaddr()
124 addr[5] as u16, in nix_socketaddr_to_sockaddr()
125 addr[6] as u16, in nix_socketaddr_to_sockaddr()
126 addr[7] as u16, in nix_socketaddr_to_sockaddr()
133 Some(net::SocketAddr::new(addr, port)) in nix_socketaddr_to_sockaddr()
[all …]
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 89 let len = addr.encode(&mut buffer[offset + 2..])?; in write_packet()
120 pub async fn add_address(&self, addr: SocketAddr) { in add_address()
121 self.inner.add_address(addr); in add_address()
123 mux.register_conn_for_address(self, addr).await; in add_address()
128 pub fn remove_address(&self, addr: &SocketAddr) { in remove_address()
129 self.inner.remove_address(addr) in remove_address()
134 self.inner.contains_address(addr) in contains_address()
191 Ok((data_len, addr)) in recv_from()
246 addresses.insert(addr); in add_address()
253 addresses.remove(addr); in remove_address()
[all …]
|
| H A D | mod.rs | 119 async fn conn_from_stun_message(&self, buffer: &[u8], addr: &SocketAddr) -> Option<UDPMuxConn> { in conn_from_stun_message()
128 log::warn!("Failed to handle decode ICE from {}: {}", addr, err); in conn_from_stun_message()
134 log::warn!("No username attribute in STUN message from {}", &addr); in conn_from_stun_message()
174 Ok((len, addr)) => { in start_conn_worker()
181 address_map.get(&addr).map(Clone::clone) in start_conn_worker()
188 loop_self.conn_from_stun_message(&buffer, &addr).await in start_conn_worker()
196 log::trace!("Dropping packet from {}", &addr); in start_conn_worker()
308 async fn register_conn_for_address(&self, conn: &UDPMuxConn, addr: SocketAddr) { in register_conn_for_address()
318 .entry(addr) in register_conn_for_address()
321 e.remove_address(&addr); in register_conn_for_address()
[all …]
|
| H A D | socket_addr_ext.rs | 35 V4(addr) => { in encode()
37 let ip: [u8; 4] = addr.ip().octets(); in encode()
38 let port: u16 = addr.port(); in encode()
46 V6(addr) => { in encode()
48 let ip: [u8; 16] = addr.ip().octets(); in encode()
49 let port: u16 = addr.port(); in encode()
50 let flowinfo = addr.flowinfo(); in encode()
51 let scope_id = addr.scope_id(); in encode()
|
| /webrtc/turn/src/client/binding/ |
| H A D | binding_test.rs | 33 let addr = SocketAddr::V4(SocketAddrV4::new(lo, 10000 + i)); in test_binding_manager_method() localVariable
35 let b = m.create(addr); in test_binding_manager_method()
38 let b1 = m.find_by_addr(&addr); in test_binding_manager_method()
51 let addr = SocketAddr::V4(SocketAddrV4::new(lo, 10000 + i)); in test_binding_manager_method() localVariable
53 assert!(m.delete_by_addr(&addr), "should return true"); in test_binding_manager_method()
71 let addr = SocketAddr::V4(SocketAddrV4::new(ipv4, 7777)); in test_binding_manager_failure() localVariable
73 let b = m.find_by_addr(&addr); in test_binding_manager_failure()
77 let ok = m.delete_by_addr(&addr); in test_binding_manager_failure()
|
| /webrtc/util/src/conn/ |
| H A D | conn_disconnected_packet.rs | 27 async fn connect(&self, addr: SocketAddr) -> Result<()> { in connect()
28 self.pconn.connect(addr).await in connect()
32 let (n, addr) = self.pconn.recv_from(buf).await?; in recv()
33 *self.raddr.write() = addr; in recv()
42 let addr = *self.raddr.read(); in send() localVariable
43 self.pconn.send_to(buf, addr).await in send()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 46 addr: SocketAddr, field
66 socket.bind(&SockAddr::from(addr))?; in server()
201 return Ok((res.answer, res.addr)); in query()
267 Ok((len, addr)) => { in start()
269 src = addr; in start()
318 Some(addr) => addr, in run()
320 Ok(addr) => { in run()
321 interface_addr.replace(addr); in run()
322 addr in run()
373 addr: src, in run()
[all …]
|
| /webrtc/turn/src/relay/ |
| H A D | relay_range.rs | 58 let addr = self in allocate_conn() localVariable
62 let conn = self.net.bind(addr).await?; in allocate_conn()
70 let addr = self in allocate_conn() localVariable
74 let conn = match self.net.bind(addr).await { in allocate_conn()
|
| H A D | relay_none.rs | 31 let addr = self in allocate_conn() localVariable
35 let conn = self.net.bind(addr).await?; in allocate_conn()
|
| /webrtc/turn/src/allocation/channel_bind/ |
| H A D | channel_bind_test.rs | 23 let addr = SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0); in create_channel_bind() localVariable
24 let c = ChannelBind::new(ChannelNumber(MIN_CHANNEL_NUMBER), addr); in create_channel_bind()
36 if let Some(addr) = result { in test_channel_bind()
37 assert_eq!(addr.ip().to_string(), "0.0.0.0"); in test_channel_bind()
|
| /webrtc/ice/src/mdns/ |
| H A D | mod.rs | 51 let addr = if dest_addr.is_empty() { in create_multicast_dns() localVariable
61 log::info!("mDNS is using {} as dest_addr", addr); in create_multicast_dns()
64 addr, in create_multicast_dns()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 54 let mut addr = XorMappedAddress::default(); in get_xormapped_addr() localVariable
55 addr.get_from(&resp)?; in get_xormapped_addr()
56 Ok(addr) in get_xormapped_addr()
74 Ok((n, addr)) => (n, addr), in stun_request()
117 let ipaddr = ipnet.addr(); in local_interfaces()
|