Searched refs:association_internal (Results 1 – 2 of 2) sorted by relevance
4 mod association_internal; module40 use association_internal::*;281 let mut ai = self.association_internal.lock().await; in close()331 let association_internal = Arc::new(Mutex::new(ai)); in new() localVariable338 let mut ai = association_internal.lock().await; in new()394 let mut ai = association_internal.lock().await; in new()417 association_internal, in new()428 association_internal: Arc<Mutex<AssociationInternal>>, in read_loop()469 let mut ai = association_internal.lock().await; in read_loop()555 let mut ai = association_internal.lock().await; in write_loop()[all …]
170 client.association_internal.lock().await, in flush_buffers()255 let a = a0.association_internal.lock().await; in test_assoc_reliable_simple()264 let a = a0.association_internal.lock().await; in test_assoc_reliable_simple()281 let a = a0.association_internal.lock().await; in test_assoc_reliable_simple()330 let a = a0.association_internal.lock().await; in test_assoc_reliable_ordered_reordered()726 let a = a0.association_internal.lock().await; in test_assoc_reliable_short_buffer()735 let a = a0.association_internal.lock().await; in test_assoc_reliable_short_buffer()758 let a = a0.association_internal.lock().await; in test_assoc_reliable_short_buffer()1387 let a = a0.association_internal.lock().await; in test_assoc_congestion_control_fast_retransmission()1388 let b = a1.association_internal.lock().await; in test_assoc_congestion_control_fast_retransmission()[all …]