Searched refs:congestion_window (Results 1 – 10 of 10) sorted by relevance
65 if r.congestion_window < r.ssthresh { in on_packet_acked()70 r.congestion_window = cwnd; in on_packet_acked()73 r.congestion_window += packet.size; in on_packet_acked()77 let mut reno_cwnd = r.congestion_window; in on_packet_acked()81 if r.bytes_acked >= r.congestion_window { in on_packet_acked()82 r.bytes_acked -= r.congestion_window; in on_packet_acked()97 r.congestion_window = reno_cwnd; in on_packet_acked()109 r.congestion_window = (r.congestion_window as f64 * in congestion_event()113 r.congestion_window = in congestion_event()114 cmp::max(r.congestion_window, recovery::MINIMUM_WINDOW); in congestion_event()[all …]
116 cubic.w_last_max = r.congestion_window as f64; in collapse_cwnd()120 r.ssthresh = (r.congestion_window as f64 * BETA_CUBIC) as usize; in collapse_cwnd()168 if r.congestion_window < r.ssthresh { in on_packet_acked()173 r.congestion_window = cwnd; in on_packet_acked()177 r.congestion_window += packet.size; in on_packet_acked()192 r.cubic_state.w_max = r.congestion_window as f64; in on_packet_acked()204 r.cubic_state.w_max = r.congestion_window as f64; in on_packet_acked()218 let mut cubic_cwnd = r.congestion_window; in on_packet_acked()243 r.cubic_state.cwnd_inc += cubic_cwnd - r.congestion_window; in on_packet_acked()249 r.congestion_window += recovery::MAX_DATAGRAM_SIZE; in on_packet_acked()[all …]
115 congestion_window: usize, field174 congestion_window: INITIAL_WINDOW, in new()220 (self.bytes_in_flight + sent_bytes) < self.congestion_window; in on_packet_sent()230 self.congestion_window < self.ssthresh in on_packet_sent()448 self.congestion_window in cwnd()457 self.congestion_window.saturating_sub(self.bytes_in_flight) in cwnd_available()751 self.congestion_window, in hystart_on_packet_acked()864 write!(f, "cwnd={} ", self.congestion_window)?; in fmt()
149 if (update.congestion_window) in Update()150 update_state_.congestion_window = update.congestion_window; in Update()
153 if (state_update.congestion_window) in PrintState()154 congestion_window_ = *state_update.congestion_window; in PrintState()
72 metrics->congestion_window.emplace(info->tcpi_snd_cwnd); in extract_opt_stats_from_tcp_info()135 metrics->congestion_window.emplace(read_unaligned<uint32_t>(val)); in extract_opt_stats_from_cmsg()
66 absl::optional<uint32_t> congestion_window; member
221 update.congestion_window = current_data_window_; in OnProcessInterval()581 update.congestion_window = current_data_window_; in OnTransportPacketsFeedback()610 update.congestion_window = current_data_window_; in GetNetworkState()
235 absl::optional<DataSize> congestion_window; member
642 if (update.congestion_window) { in PostUpdates()643 pacer()->SetCongestionWindow(*update.congestion_window); in PostUpdates()