Searched refs:bytes_in_flight (Results 1 – 4 of 4) sorted by relevance
117 bytes_in_flight: usize, field176 bytes_in_flight: 0, in new()220 (self.bytes_in_flight + sent_bytes) < self.congestion_window; in on_packet_sent()371 let epoch = if self.bytes_in_flight > 0 { in on_loss_detection_timeout()429 self.bytes_in_flight = self.bytes_in_flight.saturating_sub(unacked_bytes); in on_pkt_num_space_discarded()457 self.congestion_window.saturating_sub(self.bytes_in_flight) in cwnd_available()534 if self.bytes_in_flight == 0 { in pto_time_and_space()584 if self.bytes_in_flight == 0 && handshake_status.peer_verified_address { in set_loss_detection_timer()720 self.bytes_in_flight = self.bytes_in_flight.saturating_sub(lost_bytes); in on_packets_lost()741 self.delivery_rate.check_app_limited(self.bytes_in_flight) in rate_check_app_limited()[all …]
49 r.bytes_in_flight += sent_bytes; in on_packet_sent()55 r.bytes_in_flight = r.bytes_in_flight.saturating_sub(packet.size); in on_packet_acked()146 assert_eq!(r.bytes_in_flight, 0); in reno_init()160 assert_eq!(r.bytes_in_flight, 1000); in reno_send()
120 pub fn check_app_limited(&mut self, bytes_in_flight: usize) { in check_app_limited()121 let limited = self.delivered + bytes_in_flight; in check_app_limited()292 .check_app_limited(recvry.bytes_in_flight); in app_limited_check()
134 if r.bytes_in_flight == 0 { in on_packet_sent()158 r.bytes_in_flight = r.bytes_in_flight.saturating_sub(packet.size); in on_packet_acked()302 assert_eq!(r.bytes_in_flight, 0); in cubic_init()314 assert_eq!(r.bytes_in_flight, 1000); in cubic_send()