| /webrtc/turn/src/allocation/five_tuple/ |
| H A D | five_tuple_test.rs | 38 src_addr: src_addr1, in test_five_tuple_equal()
43 src_addr: src_addr1, in test_five_tuple_equal()
52 src_addr: src_addr1, in test_five_tuple_equal()
57 src_addr: src_addr1, in test_five_tuple_equal()
66 src_addr: src_addr1, in test_five_tuple_equal()
71 src_addr: src_addr2, in test_five_tuple_equal()
80 src_addr: src_addr1, in test_five_tuple_equal()
85 src_addr: src_addr1, in test_five_tuple_equal()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 52 pub src_addr: SocketAddr, field
74 src_addr, in new()
206 self.src_addr, in authenticate_request()
266 let (ip, port) = (self.src_addr.ip(), self.src_addr.port()); in handle_binding_request()
298 src_addr: self.src_addr, in handle_allocate_request()
514 let (src_ip, src_port) = (self.src_addr.ip(), self.src_addr.port()); in handle_allocate_request()
567 src_addr: self.src_addr, in handle_refresh_request()
601 src_addr: self.src_addr, in handle_create_permission_request()
668 src_addr: self.src_addr, in handle_send_indication()
709 src_addr: self.src_addr, in handle_channel_bind_request()
[all …]
|
| H A D | mod.rs | 203 src_addr: addr, in read_loop()
|
| /webrtc/turn/src/allocation/ |
| H A D | five_tuple.rs | 18 pub src_addr: SocketAddr, field
26 src_addr: SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0), in default()
34 write!(f, "{}_{}_{}", self.protocol, self.src_addr, self.dst_addr) in fmt()
42 .field("src_addr", &self.src_addr) in fmt()
|
| H A D | mod.rs | 353 let (n, src_addr) = tokio::select! { in packet_handler()
356 Ok((n, src_addr)) => (n, src_addr), in packet_handler()
376 src_addr in packet_handler()
383 if cb.peer == src_addr { in packet_handler()
405 src_addr, in packet_handler()
418 ip: src_addr.ip(), in packet_handler()
432 src_addr, in packet_handler()
444 src_addr, in packet_handler()
445 five_tuple.src_addr in packet_handler()
452 src_addr, in packet_handler()
[all …]
|
| /webrtc/turn/src/auth/ |
| H A D | mod.rs | 13 fn auth_handle(&self, username: &str, realm: &str, src_addr: SocketAddr) -> Result<Vec<u8>>; in auth_handle()
50 fn auth_handle(&self, username: &str, realm: &str, src_addr: SocketAddr) -> Result<Vec<u8>> { in auth_handle()
55 src_addr in auth_handle()
|
| /webrtc/util/src/vnet/ |
| H A D | chunk.rs | 228 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr) -> Self { in new()
232 source_ip: src_addr.ip(), in new()
236 source_port: src_addr.port(), in new()
336 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr, flags: TcpFlag) -> Self { in new()
340 source_ip: src_addr.ip(), in new()
344 source_port: src_addr.port(), in new()
|
| H A D | conn.rs | 122 let src_addr = SocketAddr::new(src_ip, self.loc_addr.port()); in send_to() localVariable
124 let mut chunk = ChunkUdp::new(src_addr, target); in send_to()
|
| H A D | nat.rs | 165 let src_addr = from.source_addr(); in translate_outbound() localVariable
166 if let Some(src_ip) = self.get_paired_mapped_ip(&src_addr.ip()) { in translate_outbound()
167 to.set_source_addr(&format!("{}:{}", src_ip, src_addr.port()))?; in translate_outbound()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 57 let src_addr = SocketAddr::from_str("127.0.0.1:1234")?; in test_udp_conn_send_to_recv_from() localVariable
64 let conn = Arc::new(UdpConn::new(src_addr, None, obs)); in test_udp_conn_send_to_recv_from()
144 let src_addr = SocketAddr::from_str("127.0.0.1:1234")?; in test_udp_conn_send_recv() localVariable
151 let conn = Arc::new(UdpConn::new(src_addr, Some(dst_addr), obs)); in test_udp_conn_send_recv()
|
| /webrtc/turn/src/server/request/ |
| H A D | request_test.rs | 83 src_addr: r.src_addr, in test_allocation_lifetime_deletion_zero_lifetime()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_internal.rs | 1131 let mut src_addr; in recv_loop() localVariable
1138 src_addr = src; in recv_loop()
1146 self.handle_inbound_candidate_msg(&candidate, &buffer[..n], src_addr, addr) in recv_loop()
1155 src_addr: SocketAddr, in handle_inbound_candidate_msg()
1171 src_addr, in handle_inbound_candidate_msg()
1175 self.handle_inbound(&mut m, c, src_addr).await; in handle_inbound_candidate_msg()
1177 } else if !self.validate_non_stun_traffic(c, src_addr).await { in handle_inbound_candidate_msg()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 38 src_addr: SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), rand::random()), in random_five_tuple()
53 let src_addr = client_listener.local_addr()?; in test_packet_handler() localVariable
72 src_addr, in test_packet_handler()
|