Searched refs:ai (Results 1 – 8 of 8) sorted by relevance
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 282 ai.close().await in close()
296 let ai = AssociationInternal::new( in new() localVariable
306 let name = ai.name.clone(); in new()
307 let state = Arc::clone(&ai.state); in new()
313 initial_tsn: ai.my_next_tsn, in new()
339 ai.t1init = Some(RtxTimer::new( in new()
354 ai.t3rtx = Some(RtxTimer::new( in new()
396 ai.stored_init = Some(init); in new()
397 ai.send_init()?; in new()
398 let rto = ai.rto_mgr.get_rto(); in new()
[all …]
|
| H A D | association_test.rs | 100 let mut ai = client.association_internal.lock().await; in create_new_association_pair() localVariable
101 ai.ack_mode = ack_mode; in create_new_association_pair()
104 let mut ai = server.association_internal.lock().await; in create_new_association_pair() localVariable
105 ai.ack_mode = ack_mode; in create_new_association_pair()
|
| /webrtc/ice/src/agent/ |
| H A D | mod.rs | 141 let (mut ai, chan_receivers) = AgentInternal::new(&config); in new()
148 config.init_with_defaults(&mut ai); in new()
156 if ai.lite.load(Ordering::SeqCst) in new()
194 internal: Arc::new(ai), in new()
281 let ai = Arc::clone(&self.internal); in add_remote_candidate() localVariable
289 ai.add_remote_candidate(&candidate).await; in add_remote_candidate()
294 let ai = Arc::clone(&self.internal); in add_remote_candidate() localVariable
297 ai.add_remote_candidate(&candidate).await; in add_remote_candidate()
|
| H A D | agent_internal.rs | 94 let ai = AgentInternal { in new() localVariable
165 (ai, chan_receivers) in new()
259 let ai = Arc::clone(self); in connectivity_checks() localVariable
1041 let ai = Arc::clone(self); in start_candidate() localVariable
1043 let _ = ai in start_candidate()
1058 let ai = Arc::clone(self); in start_on_connection_state_change_routine() localVariable
1064 &*ai.on_selected_candidate_pair_change_hdlr.load(), in start_on_connection_state_change_routine()
1065 &*ai.agent_conn.selected_pair.load(), in start_on_connection_state_change_routine()
1073 let ai = Arc::clone(self); in start_on_connection_state_change_routine() localVariable
1085 if let Some(handler) = &*ai.on_candidate_hdlr.load() { in start_on_connection_state_change_routine()
[all …]
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_range_constraint/ |
| H A D | tests.rs | 131 validate: |$ai:ident, $ei:ident| $b:block
134 let closure = |$ai, $ei| $b;
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_sequence_constraint/ |
| H A D | tests.rs | 131 validate: |$ai:ident, $ei:ident| $b:block
134 let closure = |$ai, $ei| $b;
|
| /webrtc/constraints/src/algorithms/fitness_distance/value_constraint/ |
| H A D | tests.rs | 131 validate: |$ai:ident, $ei:ident| $b:block
134 let closure = |$ai, $ei| $b;
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 484 .for_each(|(_, ai)| match ai.username.as_str() { in test_get_allocations_info()
485 "user1" => assert_eq!(ai.relayed_bytes, 1), in test_get_allocations_info()
486 "user2" => assert_eq!(ai.relayed_bytes, 2), in test_get_allocations_info()
487 "user3" => assert_eq!(ai.relayed_bytes, 3), in test_get_allocations_info()
|