| /webrtc/dtls/src/conn/ |
| H A D | conn_test.rs | 48 ca, in pipe_conn()
156 ca.close().await?; in test_routine_leak_on_close()
159 drop(ca); in test_routine_leak_on_close()
223 drop(ca); in test_sequence_number_overflow_on_application_data()
257 if let Err(err) = ca in test_sequence_number_overflow_on_handshake()
288 ca.close().await?; in test_sequence_number_overflow_on_handshake()
291 drop(ca); in test_sequence_number_overflow_on_handshake()
399 let (ca, _cb) = pipe(); in test_export_keying_material()
593 let (ca, cb) = pipe(); in test_psk_hint_fail()
2398 let ca: Arc<dyn Conn + Send + Sync> = Arc::new(ca); in test_renegotation_info() localVariable
[all …]
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport_test.rs | 79 let (ca, cb) = pipe_with_vnet( in test_remote_local_addr()
92 let a_laddr = ca.local_addr()?; in test_remote_local_addr()
111 let (ca, cb, _, _) = pipe(None, None).await?; in test_conn_stats()
112 let na = ca.send(&[0u8; 10]).await?; in test_conn_stats()
|
| /webrtc/webrtc/src/mux/ |
| H A D | mux_test.rs | 13 let (ca, cb) = pipe(); in pipe_memory()
16 conn: Arc::new(ca), in pipe_memory()
30 let (ca, _) = pipe(); in test_no_endpoints()
33 conn: Arc::new(ca), in test_no_endpoints()
|
| /webrtc/sctp/src/association/ |
| H A D | association_test.rs | 21 ca: Arc<dyn Conn + Send + Sync>, in create_new_association_pair()
34 net_conn: ca, in create_new_association_pair()
247 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_simple()
322 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_ordered_reordered()
417 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_ordered_fragmented_then_defragmented()
484 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_unordered_fragmented_then_defragmented()
551 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_unordered_ordered()
641 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_retransmission()
718 let (br, ca, cb) = Bridge::new(0, None, None); in test_assoc_reliable_short_buffer()
1436 Arc::new(ca), in test_assoc_congestion_control_congestion_avoidance()
[all …]
|
| /webrtc/data/src/data_channel/ |
| H A D | data_channel_test.rs | 26 ca: Arc<dyn Conn + Send + Sync>, in create_new_association_pair()
37 net_conn: ca, in create_new_association_pair()
177 let (br, ca, cb) = Bridge::new(0, None, None); in pr_ordered_unordered_test()
179 let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?; in pr_ordered_unordered_test()
264 let (br, ca, cb) = Bridge::new(0, None, None); in test_data_channel_channel_type_reliable_ordered()
266 let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?; in test_data_channel_channel_type_reliable_ordered()
327 let (br, ca, cb) = Bridge::new(0, None, None); in test_data_channel_channel_type_reliable_unordered()
329 let (a0, a1) = create_new_association_pair(&br, Arc::new(ca), Arc::new(cb)).await?; in test_data_channel_channel_type_reliable_unordered()
427 let (br, ca, cb) = Bridge::new(0, None, None); in test_data_channel_buffered_amount()
531 let (br, ca, cb) = Bridge::new(0, None, None); in test_stats()
[all …]
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtcp_test.rs | 15 let ca = Config { in build_session_srtcp_pair() localVariable
67 let sa = Session::new(Arc::new(ua), ca, false).await?; in build_session_srtcp_pair()
|
| H A D | session_rtp_test.rs | 19 let ca = Config { in build_session_srtp_pair() localVariable
71 let sa = Session::new(Arc::new(ua), ca, true).await?; in build_session_srtp_pair()
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener_test.rs | 54 let (listener, ca, _) = pipe().await?; in test_listener_close_timeout()
59 ca.close().await?; in test_listener_close_timeout()
|