Searched refs:get_rto (Results 1 – 4 of 4) sorted by relevance
88 assert_eq!(m.get_rto(), RTO_INITIAL, "should be rtoInitial"); in test_rto_manager_initial_values()104 let rto = m.get_rto(); in test_rto_manager_rto_calculation_small_rtt()123 let rto = m.get_rto(); in test_rto_manager_rto_calculation_large_rtt()156 assert_eq!(m.get_rto(), RTO_INITIAL, "should be rtoInitial"); in test_rto_manager_reset()
60 pub(crate) fn get_rto(&self) -> u64 { in get_rto() method
355 t3rtx.start(self.rto_mgr.get_rto()).await; in gather_outbound_data_and_reconfig_packets()404 treconfig.start(self.rto_mgr.get_rto()).await; in gather_outbound_data_and_reconfig_packets()524 t2shutdown.start(self.rto_mgr.get_rto()).await; in gather_outbound_shutdown_packets()534 t2shutdown.start(self.rto_mgr.get_rto()).await; in gather_outbound_shutdown_packets()786 t1cookie.start(self.rto_mgr.get_rto()).await; in handle_init_ack()1135 self.rto_mgr.get_rto() in process_selective_ack()1192 self.rto_mgr.get_rto() in process_selective_ack()1225 t3rtx.start(self.rto_mgr.get_rto()).await; in on_cumulative_tsn_ack_point_advanced()1491 t3rtx.start(self.rto_mgr.get_rto()).await; in postprocess_sack()
398 let rto = ai.rto_mgr.get_rto(); in new()