Index: net/quic/core/congestion_control/rtt_stats.cc |
diff --git a/net/quic/core/congestion_control/rtt_stats.cc b/net/quic/core/congestion_control/rtt_stats.cc |
index 91d3e2ad3c089f0b66e51f6107f1c733922ee654..086511cd3a2fc45dab13efa69c5fb8120dce1d83 100644 |
--- a/net/quic/core/congestion_control/rtt_stats.cc |
+++ b/net/quic/core/congestion_control/rtt_stats.cc |
@@ -20,8 +20,6 @@ const float kAlpha = 0.125f; |
const float kOneMinusAlpha = (1 - kAlpha); |
const float kBeta = 0.25f; |
const float kOneMinusBeta = (1 - kBeta); |
-// 10-second window length for windowed min RTT. |
-const int kMinRttWindowLengthMs = 10000; |
} // namespace |
@@ -31,20 +29,7 @@ RttStats::RttStats() |
smoothed_rtt_(QuicTime::Delta::Zero()), |
previous_srtt_(QuicTime::Delta::Zero()), |
mean_deviation_(QuicTime::Delta::Zero()), |
- initial_rtt_us_(kInitialRttMs * kNumMicrosPerMilli), |
- forced_windowed_min_rtt_(QuicTime::Delta::Zero()), |
- forced_windowed_min_rtt_time_(QuicTime::Zero()), |
- num_samples_for_forced_min_(0), |
- windowed_min_rtt_( |
- QuicTime::Delta::FromMilliseconds(kMinRttWindowLengthMs), |
- QuicTime::Delta::Zero(), |
- QuicTime::Zero()) {} |
- |
-void RttStats::SampleNewWindowedMinRtt(uint32_t num_samples) { |
- num_samples_for_forced_min_ = num_samples; |
- forced_windowed_min_rtt_ = QuicTime::Delta::Zero(); |
- forced_windowed_min_rtt_time_ = QuicTime::Zero(); |
-} |
+ initial_rtt_us_(kInitialRttMs * kNumMicrosPerMilli) {} |
void RttStats::ExpireSmoothedMetrics() { |
mean_deviation_ = max(mean_deviation_, |
@@ -71,7 +56,6 @@ void RttStats::UpdateRtt(QuicTime::Delta send_delta, |
if (min_rtt_.IsZero() || min_rtt_ > send_delta) { |
min_rtt_ = send_delta; |
} |
- UpdateWindowedMinRtt(send_delta, now); |
// Correct for ack_delay if information received from the peer results in a |
// positive RTT sample. Otherwise, we use the send_delta as a reasonable |
@@ -98,33 +82,12 @@ void RttStats::UpdateRtt(QuicTime::Delta send_delta, |
} |
} |
-void RttStats::UpdateWindowedMinRtt(QuicTime::Delta rtt_sample, QuicTime now) { |
- // Update windowed_min_rtt. |
- windowed_min_rtt_.Update(rtt_sample, now); |
- if (num_samples_for_forced_min_ <= 0) { |
- return; |
- } |
- // Reset windowed_min_rtt to the min of num_samples_for_forced_min_ samples. |
- if (forced_windowed_min_rtt_.IsZero() || |
- rtt_sample <= forced_windowed_min_rtt_) { |
- forced_windowed_min_rtt_ = rtt_sample; |
- forced_windowed_min_rtt_time_ = now; |
- } |
- if (num_samples_for_forced_min_ == 1) { |
- windowed_min_rtt_.Reset(forced_windowed_min_rtt_, |
- forced_windowed_min_rtt_time_); |
- } |
- --num_samples_for_forced_min_; |
-} |
- |
void RttStats::OnConnectionMigration() { |
latest_rtt_ = QuicTime::Delta::Zero(); |
min_rtt_ = QuicTime::Delta::Zero(); |
smoothed_rtt_ = QuicTime::Delta::Zero(); |
mean_deviation_ = QuicTime::Delta::Zero(); |
initial_rtt_us_ = kInitialRttMs * kNumMicrosPerMilli; |
- num_samples_for_forced_min_ = 0; |
- windowed_min_rtt_.Reset(QuicTime::Delta::Zero(), QuicTime::Zero()); |
} |
} // namespace net |