Home
last modified time | relevance | path

Searched refs:turn_socket (Results 1 – 5 of 5) sorted by relevance

/webrtc/turn/src/allocation/
H A Dallocation_test.rs11 let relay_socket = Arc::clone(&turn_socket); in test_has_permission()
14 turn_socket, in test_has_permission()
49 let relay_socket = Arc::clone(&turn_socket); in test_add_permission()
52 turn_socket, in test_add_permission()
76 turn_socket, in test_remove_permission()
109 turn_socket, in test_add_channel_bind()
143 turn_socket, in test_get_channel_by_number()
179 turn_socket, in test_get_channel_by_addr()
211 turn_socket, in test_remove_channel_bind()
248 turn_socket, in test_allocation_refresh()
[all …]
H A Dmod.rs73 turn_socket: Arc<dyn Conn + Send + Sync>, field
96 turn_socket: Arc<dyn Conn + Send + Sync>, in new()
105 turn_socket, in new()
249 let _ = self.turn_socket.close().await; in close()
340 let turn_socket = Arc::clone(&self.turn_socket); in packet_handler() localVariable
399 if let Err(err) = turn_socket in packet_handler()
448 turn_socket.send_to(&msg.raw, five_tuple.src_addr).await in packet_handler()
H A Dallocation_manager.rs85 turn_socket: Arc<dyn Conn + Send + Sync>, in create_allocation()
103 turn_socket, in create_allocation()
/webrtc/turn/src/allocation/allocation_manager/
H A Dallocation_manager_test.rs73 dst_addr: turn_socket.local_addr()?, in test_packet_handler()
76 Arc::new(turn_socket), in test_packet_handler()
181 Arc::clone(&turn_socket), in test_create_allocation_duplicate_five_tuple()
191 Arc::clone(&turn_socket), in test_create_allocation_duplicate_five_tuple()
216 Arc::clone(&turn_socket), in test_delete_allocation()
256 Arc::clone(&turn_socket), in test_allocation_timeout()
305 Arc::clone(&turn_socket), in test_manager_close()
316 Arc::clone(&turn_socket), in test_manager_close()
353 Arc::clone(&turn_socket), in test_delete_allocation_by_username()
362 Arc::clone(&turn_socket), in test_delete_allocation_by_username()
[all …]
/webrtc/turn/src/allocation/channel_bind/
H A Dchannel_bind_test.rs11 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in create_channel_bind() localVariable
12 let relay_socket = Arc::clone(&turn_socket); in create_channel_bind()
15 turn_socket, in create_channel_bind()