| /webrtc/turn/src/allocation/five_tuple/ |
| H A D | five_tuple_test.rs | 39 dst_addr: dst_addr1, in test_five_tuple_equal()
44 dst_addr: dst_addr1, in test_five_tuple_equal()
53 dst_addr: dst_addr1, in test_five_tuple_equal()
58 dst_addr: dst_addr1, in test_five_tuple_equal()
67 dst_addr: dst_addr1, in test_five_tuple_equal()
72 dst_addr: dst_addr1, in test_five_tuple_equal()
81 dst_addr: dst_addr1, in test_five_tuple_equal()
86 dst_addr: dst_addr2, in test_five_tuple_equal()
|
| /webrtc/turn/src/allocation/ |
| H A D | five_tuple.rs | 19 pub dst_addr: SocketAddr, field
27 dst_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()
43 .field("dst_addr", &self.dst_addr) in fmt()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 30 dst_addr: SocketAddr, field
103 let dst_addr: SocketAddr = DEFAULT_DEST_ADDR.parse()?; in server() localVariable
118 dst_addr, in server()
132 dst_addr, in server()
238 if let Err(err) = self.socket.send_to(&raw_query, self.dst_addr).await { in send_question()
248 dst_addr: SocketAddr, in start()
287 run(&mut p, &socket, &local_names, src, dst_addr, &queries).await in start()
297 dst_addr: SocketAddr, in run()
342 send_answer(socket, &interface_addr, &q.name.data, src.ip(), dst_addr).await in run()
387 dst_addr: SocketAddr, in send_answer()
[all …]
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 58 let dst_addr = SocketAddr::from_str("127.0.0.1:5678")?; in test_udp_conn_send_to_recv_from() localVariable
92 log::debug!("dst_addr {} vs add {}", dst_addr, addr); in test_udp_conn_send_to_recv_from()
93 assert_eq!(dst_addr.to_string(), addr.to_string(), "should match"); in test_udp_conn_send_to_recv_from()
100 let n = conn.send_to(&data, dst_addr).await.unwrap(); in test_udp_conn_send_to_recv_from()
145 let dst_addr = SocketAddr::from_str("127.0.0.1:5678")?; 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/util/src/vnet/ |
| H A D | chunk.rs | 228 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr) -> Self { in new()
233 destination_ip: dst_addr.ip(), in new()
237 destination_port: dst_addr.port(), in new()
336 pub(crate) fn new(src_addr: SocketAddr, dst_addr: SocketAddr, flags: TcpFlag) -> Self { in new()
341 destination_ip: dst_addr.ip(), in new()
345 destination_port: dst_addr.port(), in new()
|
| H A D | nat.rs | 296 let dst_addr = from.destination_addr(); in translate_inbound() localVariable
297 if let Some(dst_ip) = self.get_paired_local_ip(&dst_addr.ip()) { in translate_inbound()
|
| /webrtc/turn/src/server/ |
| 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/turn/src/server/request/ |
| H A D | request_test.rs | 84 dst_addr: r.conn.local_addr()?, in test_allocation_lifetime_deletion_zero_lifetime()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 39 dst_addr: SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), rand::random()), in random_five_tuple()
73 dst_addr: turn_socket.local_addr()?, in test_packet_handler()
|