| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener_test.rs | 56 listener.close().await?; in test_listener_close_timeout()
59 ca.close().await?; in test_listener_close_timeout()
79 conn.close().await?; in test_listener_close_unaccepted()
86 listener.close().await?; in test_listener_close_unaccepted()
129 c.close().await?; in test_listener_accept_filter()
150 conn.close().await?; in test_listener_accept_filter()
151 listener.close().await?; in test_listener_accept_filter()
173 conn.close().await?; in test_listener_concurrent()
191 conn.close().await?; in test_listener_concurrent()
200 conn.close().await?; in test_listener_concurrent()
[all …]
|
| H A D | conn_disconnected_packet.rs | 59 async fn close(&self) -> Result<()> { in close() method
60 self.pconn.close().await in close()
|
| H A D | mod.rs | 35 async fn close(&self) -> Result<()>; in close() method
47 async fn close(&self) -> Result<()>; in close() method
|
| /webrtc/mdns/src/conn/ |
| H A D | conn_test.rs | 13 server_a.close().await?; in test_multiple_close()
15 if let Err(err) = server_a.close().await { in test_multiple_close()
41 server_a.close().await?; in test_query_respect_timeout()
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 22 pub async fn close(&self) -> Result<()> { in close() method
23 self.buffer.close().await; in close()
69 async fn close(&self) -> Result<()> { in close() method
70 self.next_conn.close().await in close()
|
| H A D | mux_test.rs | 38 m.close().await; in test_no_endpoints()
91 async fn close(&self) -> Result<()> { in close() method
126 m.close().await; in test_non_fatal_read()
|
| /webrtc/examples/examples/data-channels-close/ |
| H A D | README.md | 1 # data-channels-close
2 data-channels-close is a variant of the data-channels example that allow playing with the life cycl…
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtp_test.rs | 113 sa.close().await?; in test_session_srtp_accept()
114 sb.close().await?; in test_session_srtp_accept()
148 sa.close().await?; in test_session_srtp_listen()
149 sb.close().await?; in test_session_srtp_listen()
193 sa.close().await?; in test_session_srtp_multi_ssrc()
194 sb.close().await?; in test_session_srtp_multi_ssrc()
299 sa.close().await?; in test_session_srtp_replay_protection()
300 sb.close().await?; in test_session_srtp_replay_protection()
|
| H A D | session_rtcp_test.rs | 106 sa.close().await?; in test_session_srtcp_accept()
107 sb.close().await?; in test_session_srtcp_accept()
138 sa.close().await?; in test_session_srtcp_listen()
139 sb.close().await?; in test_session_srtcp_listen()
230 sa.close().await?; in test_session_srtcp_replay_protection()
231 sb.close().await?; in test_session_srtcp_replay_protection()
|
| /webrtc/sctp/src/timer/ |
| H A D | rtx_timer.rs | 139 let mut close = self.close_tx.lock().await; in start() localVariable
140 if close.is_some() { in start()
145 *close = Some(close_tx); in start()
181 let mut close = close_tx.lock().await; in start() localVariable
182 *close = None; in start()
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 68 c.close().await?; in test_client_with_stun_send_binding_request()
100 c1.close().await?; in test_client_with_stun_send_binding_request_to_parallel()
116 c.close().await?; in test_client_with_stun_send_binding_request_to_timeout()
186 client.close().await?; in test_client_nonce_expiration()
187 server.close().await?; in test_client_nonce_expiration()
|
| H A D | periodic_timer.rs | 75 let mut close = self.close_tx.lock().await; in start() localVariable
76 *close = Some(close_tx); in start()
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 15 a.close()?; in test_agent_process_in_transaction()
40 a.close()?; in test_agent_process()
90 a.close()?; in test_agent_start()
165 a.close()?; in test_agent_stop()
167 let result = a.close(); in test_agent_stop()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_test.rs | 44 a.close().await?; in test_pair_search()
162 a.close().await?; in test_pair_priority()
238 a.close().await?; in test_on_selected_candidate_pair_change()
320 a.close().await?; in test_handle_peer_reflexive_udp_pflx_candidate()
379 a.close().await?; in test_handle_peer_reflexive_unknown_remote()
568 v.close().await?; in test_connectivity_lite()
908 a.close().await?; in test_invalid_agent_starts()
1041 a.close().await?; in test_invalid_gather()
1203 a.close().await?; in test_candidate_pair_stats()
1294 a.close().await?; in test_local_candidate_stats()
[all …]
|
| H A D | agent_gather_test.rs | 30 a.close().await?; in test_vnet_gather_no_local_ip_address()
66 a.close().await?; in test_vnet_gather_dynamic_ip_address()
108 a.close().await?; in test_vnet_gather_listen_udp()
231 a.close().await?; in test_vnet_gather_with_nat_1to1_as_host_candidates()
316 a.close().await?; in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
349 a.close().await?; in test_vnet_gather_with_interface_filter()
371 a.close().await?; in test_vnet_gather_with_interface_filter()
419 a_agent.close().await?; in test_vnet_gather_turn_connection_leak()
420 v.close().await?; in test_vnet_gather_turn_connection_leak()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_server_reflexive_test.rs | 84 a_agent.close().await?; in test_server_reflexive_only_connection()
85 b_agent.close().await?; in test_server_reflexive_only_connection()
86 server.close().await?; in test_server_reflexive_only_connection()
|
| H A D | candidate_relay_test.rs | 109 a_agent.close().await?; in test_relay_only_connection()
110 b_agent.close().await?; in test_relay_only_connection()
111 server.close().await?; in test_relay_only_connection()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 110 pub fn close(&self) { in close() method
111 self.inner.close(); in close()
210 fn close(self: &Arc<Self>) { in close() method
227 cloned_self.buffer.close().await; in close()
299 async fn close(&self) -> ConnResult<()> { in close() method
300 self.inner.close(); in close()
|
| /webrtc/ice/src/mdns/ |
| H A D | mdns_test.rs | 43 a_agent.close().await?; in test_multicast_dns_only_connection()
44 b_agent.close().await?; in test_multicast_dns_only_connection()
77 a_agent.close().await?; in test_multicast_dns_mixed_connection()
78 b_agent.close().await?; in test_multicast_dns_mixed_connection()
|
| /webrtc/mdns/examples/ |
| H A D | mdns_server_query.rs | 51 server_a.close().await.unwrap(); in main()
52 server_b.close().await.unwrap(); in main()
|
| /webrtc/data/src/data_channel/ |
| H A D | data_channel_test.rs | 116 client.close().await?; in close_association_pair()
250 dc0.close().await?; in pr_ordered_unordered_test()
251 dc1.close().await?; in pr_ordered_unordered_test()
313 dc0.close().await?; in test_data_channel_channel_type_reliable_ordered()
314 dc1.close().await?; in test_data_channel_channel_type_reliable_ordered()
385 dc0.close().await?; in test_data_channel_channel_type_reliable_unordered()
386 dc1.close().await?; in test_data_channel_channel_type_reliable_unordered()
510 dc0.close().await?; in test_data_channel_buffered_amount()
511 dc1.close().await?; in test_data_channel_buffered_amount()
611 dc0.close().await?; in test_stats()
[all …]
|
| /webrtc/media/src/io/h264_writer/ |
| H A D | h264_writer_test.rs | 86 h264writer.close()?; in test_write_rtp()
120 h264writer.close()?; in test_write_rtp_fu()
|
| /webrtc/turn/src/allocation/ |
| H A D | allocation_manager.rs | 40 pub async fn close(&self) -> Result<()> { in close() method
43 a.close().await?; in close()
130 if let Err(err) = a.close().await { in delete_allocation()
158 if let Err(err) = a.close().await { in delete_allocations_by_username()
|
| /webrtc/srtp/src/ |
| H A D | stream.rs | 82 pub async fn close(&self) -> Result<()> { in close() method
83 self.buffer.close().await; in close()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | receiver_test.rs | 55 stream.close().await?; in test_receiver_interceptor_before_any_packet()
118 stream.close().await?; in test_receiver_interceptor_after_rtp_packets()
201 stream.close().await?; in test_receiver_interceptor_after_rtp_and_rtcp_packets()
279 stream.close().await?; in test_receiver_interceptor_overflow()
379 stream.close().await?; in test_receiver_interceptor_overflow_five_pkts()
492 stream.close().await?; in test_receiver_interceptor_packet_loss()
562 stream.close().await?; in test_receiver_interceptor_overflow_and_packet_loss()
624 stream.close().await?; in test_receiver_interceptor_reordered_packets()
704 stream.close().await?; in test_receiver_interceptor_jitter()
769 stream.close().await?; in test_receiver_interceptor_delay()
|