| Index: net/quic/core/congestion_control/bbr_sender.cc
|
| diff --git a/net/quic/core/congestion_control/bbr_sender.cc b/net/quic/core/congestion_control/bbr_sender.cc
|
| index 5220d3a94e31e49d701cb4a3a8bb9c02e13578b2..6207a12f8e444fe7742d88b04ae3669f5fcc1bef 100644
|
| --- a/net/quic/core/congestion_control/bbr_sender.cc
|
| +++ b/net/quic/core/congestion_control/bbr_sender.cc
|
| @@ -80,9 +80,6 @@ BbrSender::BbrSender(const RttStats* rtt_stats,
|
| last_sent_packet_(0),
|
| current_round_trip_end_(0),
|
| max_bandwidth_(kBandwidthWindowSize, QuicBandwidth::Zero(), 0),
|
| - max_ack_spacing_(kBandwidthWindowSize, QuicTime::Delta::Zero(), 0),
|
| - largest_acked_time_(QuicTime::Zero()),
|
| - largest_acked_sent_time_(QuicTime::Zero()),
|
| max_ack_height_(kBandwidthWindowSize, 0, 0),
|
| aggregation_epoch_start_time_(QuicTime::Zero()),
|
| aggregation_epoch_bytes_(0),
|
| @@ -250,10 +247,6 @@ void BbrSender::OnCongestionEvent(bool /*rtt_updated*/,
|
| min_rtt_expired = UpdateBandwidthAndMinRtt(event_time, acked_packets);
|
| UpdateRecoveryState(last_acked_packet, !lost_packets.empty(),
|
| is_round_start);
|
| - if (FLAGS_quic_reloadable_flag_quic_bbr_ack_spacing2) {
|
| - QUIC_FLAG_COUNT_N(quic_reloadable_flag_quic_bbr_ack_spacing2, 1, 2);
|
| - UpdateAckSpacing(event_time, last_acked_packet, acked_packets);
|
| - }
|
| if (FLAGS_quic_reloadable_flag_quic_bbr_ack_aggregation_bytes) {
|
| QUIC_FLAG_COUNT_N(quic_reloadable_flag_quic_bbr_ack_aggregation_bytes, 1,
|
| 2);
|
| @@ -527,42 +520,6 @@ void BbrSender::UpdateRecoveryState(QuicPacketNumber last_acked_packet,
|
| }
|
| }
|
|
|
| -// TODO(ianswett): Move this logic into BandwidthSampler.
|
| -void BbrSender::UpdateAckSpacing(QuicTime ack_time,
|
| - QuicPacketNumber largest_newly_acked,
|
| - const CongestionVector& acked_packets) {
|
| - // Ignore acks of reordered packets.
|
| - if (largest_newly_acked < unacked_packets_->largest_observed()) {
|
| - return;
|
| - }
|
| - // Ignore acks of only one packet to filter out delayed acks.
|
| - if (acked_packets.size() == 1) {
|
| - return;
|
| - }
|
| - QuicTime largest_newly_acked_sent_time =
|
| - unacked_packets_->GetTransmissionInfo(largest_newly_acked).sent_time;
|
| - // Initialize on the first ack.
|
| - if (!largest_acked_time_.IsInitialized()) {
|
| - largest_acked_time_ = ack_time;
|
| - largest_acked_sent_time_ = largest_newly_acked_sent_time;
|
| - return;
|
| - }
|
| - QuicTime::Delta ack_delta = ack_time - largest_acked_time_;
|
| - QuicTime::Delta send_delta =
|
| - largest_newly_acked_sent_time - largest_acked_sent_time_;
|
| - largest_acked_time_ = ack_time;
|
| - largest_acked_sent_time_ = largest_newly_acked_sent_time;
|
| - if (ack_delta <= send_delta) {
|
| - return;
|
| - }
|
| -
|
| - // Limit the ack spacing to SRTT to filter outliers.
|
| - QuicTime::Delta ack_spacing =
|
| - std::min(ack_delta - send_delta, rtt_stats_->smoothed_rtt());
|
| - max_ack_spacing_.Update(ack_spacing, round_trip_count_);
|
| -}
|
| -
|
| -// TODO(ianswett): Move this logic into BandwidthSampler.
|
| void BbrSender::UpdateAckAggregationBytes(QuicTime ack_time,
|
| QuicByteCount newly_acked_bytes) {
|
| // Compute how many bytes are expected to be delivered, assuming max bandwidth
|
| @@ -619,11 +576,6 @@ void BbrSender::CalculateCongestionWindow(QuicByteCount bytes_acked) {
|
| if (rtt_variance_weight_ > 0.f && !BandwidthEstimate().IsZero()) {
|
| target_window += rtt_variance_weight_ * rtt_stats_->mean_deviation() *
|
| BandwidthEstimate();
|
| - } else if (FLAGS_quic_reloadable_flag_quic_bbr_ack_spacing2 &&
|
| - is_at_full_bandwidth_) {
|
| - QUIC_FLAG_COUNT_N(quic_reloadable_flag_quic_bbr_ack_spacing2, 2, 2);
|
| - // Add CWND for inter-ack spacing once STARTUP has been exited.
|
| - target_window += max_ack_spacing_.GetBest() * BandwidthEstimate();
|
| } else if (FLAGS_quic_reloadable_flag_quic_bbr_ack_aggregation_bytes &&
|
| is_at_full_bandwidth_) {
|
| QUIC_FLAG_COUNT_N(quic_reloadable_flag_quic_bbr_ack_aggregation_bytes, 2,
|
|
|