| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 174 if let Some(cb) = channel_bindings.get(&c.number) { in add_channel_bind()
175 cb.refresh(lifetime).await; in add_channel_bind()
178 self.add_permission(Permission::new(cb.peer)).await; in add_channel_bind()
210 channel_bindings.get(number).map(|cb| cb.peer) in get_channel_addr()
216 for cb in channel_bindings.values() { in get_channel_number()
217 if cb.peer == *addr { in get_channel_number()
218 return Some(cb.number); in get_channel_number()
382 for cb in cbs.values() { in packet_handler()
383 if cb.peer == src_addr { in packet_handler()
384 cb_number = Some(cb.number); in packet_handler()
|
| H A D | channel_bind.rs | 51 let mut cb = cbs.lock().await; in start() localVariable
52 if cb.remove(&number).is_none() { in start()
|
| /webrtc/dtls/src/conn/ |
| H A D | conn_test.rs | 62 cb, in pipe_conn()
155 cb.close().await?; in test_routine_leak_on_close()
160 drop(cb); in test_routine_leak_on_close()
211 cb.close().await?; in test_sequence_number_overflow_on_application_data()
224 drop(cb); in test_sequence_number_overflow_on_application_data()
287 cb.close().await?; in test_sequence_number_overflow_on_handshake()
292 drop(cb); in test_sequence_number_overflow_on_handshake()
355 let (ca, cb) = pipe(); in test_handshake_with_alert()
593 let (ca, cb) = pipe(); in test_psk_hint_fail()
1869 let (ca, cb) = pipe(); in test_server_timeout()
[all …]
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport_test.rs | 79 let (ca, cb) = pipe_with_vnet( in test_remote_local_addr()
93 let b_laddr = cb.local_addr()?; in test_remote_local_addr()
111 let (ca, cb, _, _) = pipe(None, None).await?; in test_conn_stats()
121 let nb = cb.recv(&mut buf).await?; in test_conn_stats()
|
| H A D | agent_internal.rs | 1063 if let (Some(cb), Some(p)) = ( in start_on_connection_state_change_routine()
1067 let mut f = cb.lock().await; in start_on_connection_state_change_routine()
|
| H A D | agent_test.rs | 192 let cb: OnSelectedCandidatePairChangeHdlrFn = Box::new(move |_, _| { in test_on_selected_candidate_pair_change() localVariable
199 a.on_selected_candidate_pair_change(cb); in test_on_selected_candidate_pair_change()
|
| /webrtc/sctp/src/association/ |
| H A D | association_test.rs | 22 cb: Arc<dyn Conn + Send + Sync>, in create_new_association_pair()
50 net_conn: cb, 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()
1437 Arc::new(cb), in test_assoc_congestion_control_congestion_avoidance()
[all …]
|
| /webrtc/data/src/data_channel/ |
| H A D | data_channel_test.rs | 27 cb: Arc<dyn Conn + Send + Sync>, in create_new_association_pair()
53 net_conn: cb, 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/webrtc/src/mux/ |
| H A D | mux_test.rs | 13 let (ca, cb) = pipe(); in pipe_memory()
24 (e, cb) in pipe_memory()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtcp_test.rs | 41 let cb = Config { in build_session_srtcp_pair() localVariable
68 let sb = Session::new(Arc::new(ub), cb, false).await?; in build_session_srtcp_pair()
|
| H A D | session_rtp_test.rs | 45 let cb = Config { in build_session_srtp_pair() localVariable
72 let sb = Session::new(Arc::new(ub), cb, true).await?; in build_session_srtp_pair()
|