Index: net/quic/congestion_control/hybrid_slow_start.cc |
diff --git a/net/quic/congestion_control/hybrid_slow_start.cc b/net/quic/congestion_control/hybrid_slow_start.cc |
deleted file mode 100644 |
index b7e10b9f4df5f0c6073f3c578d14129f7cf8326d..0000000000000000000000000000000000000000 |
--- a/net/quic/congestion_control/hybrid_slow_start.cc |
+++ /dev/null |
@@ -1,136 +0,0 @@ |
-// Copyright (c) 2012 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "net/quic/congestion_control/hybrid_slow_start.h" |
- |
-#include <algorithm> |
- |
-using std::max; |
-using std::min; |
- |
-namespace net { |
- |
-// Note(pwestin): the magic clamping numbers come from the original code in |
-// tcp_cubic.c. |
-const int64 kHybridStartLowWindow = 16; |
-// Number of delay samples for detecting the increase of delay. |
-const uint32 kHybridStartMinSamples = 8; |
-// Exit slow start if the min rtt has increased by more than 1/8th. |
-const int kHybridStartDelayFactorExp = 3; // 2^3 = 8 |
-// The original paper specifies 2 and 8ms, but those have changed over time. |
-const int64 kHybridStartDelayMinThresholdUs = 4000; |
-const int64 kHybridStartDelayMaxThresholdUs = 16000; |
- |
-HybridSlowStart::HybridSlowStart(const QuicClock* clock) |
- : clock_(clock), |
- ack_train_detection_(true), |
- started_(false), |
- hystart_found_(NOT_FOUND), |
- last_sent_sequence_number_(0), |
- round_start_(QuicTime::Zero()), |
- end_sequence_number_(0), |
- last_close_ack_pair_time_(QuicTime::Zero()), |
- rtt_sample_count_(0), |
- current_min_rtt_(QuicTime::Delta::Zero()) { |
-} |
- |
-void HybridSlowStart::OnPacketAcked( |
- QuicPacketSequenceNumber acked_sequence_number, bool in_slow_start) { |
- // OnPacketAcked gets invoked after ShouldExitSlowStart, so it's best to end |
- // the round when the final packet of the burst is received and start it on |
- // the next incoming ack. |
- if (in_slow_start && IsEndOfRound(acked_sequence_number)) { |
- started_ = false; |
- } |
-} |
- |
-void HybridSlowStart::OnPacketSent(QuicPacketSequenceNumber sequence_number) { |
- last_sent_sequence_number_ = sequence_number; |
-} |
- |
-void HybridSlowStart::Restart() { |
- started_ = false; |
- hystart_found_ = NOT_FOUND; |
-} |
- |
-void HybridSlowStart::StartReceiveRound(QuicPacketSequenceNumber last_sent) { |
- DVLOG(1) << "Reset hybrid slow start @" << last_sent; |
- round_start_ = last_close_ack_pair_time_ = clock_->ApproximateNow(); |
- end_sequence_number_ = last_sent; |
- current_min_rtt_ = QuicTime::Delta::Zero(); |
- rtt_sample_count_ = 0; |
- started_ = true; |
-} |
- |
-bool HybridSlowStart::IsEndOfRound(QuicPacketSequenceNumber ack) const { |
- return end_sequence_number_ <= ack; |
-} |
- |
-bool HybridSlowStart::ShouldExitSlowStart(QuicTime::Delta latest_rtt, |
- QuicTime::Delta min_rtt, |
- int64 congestion_window) { |
- if (!started_) { |
- // Time to start the hybrid slow start. |
- StartReceiveRound(last_sent_sequence_number_); |
- } |
- if (hystart_found_ != NOT_FOUND) { |
- return true; |
- } |
- QuicTime current_time = clock_->ApproximateNow(); |
- |
- // First detection parameter - ack-train detection. |
- // Since slow start burst out packets we can indirectly estimate the inter- |
- // arrival time by looking at the arrival time of the ACKs if the ACKs are |
- // spread out more then half the minimum RTT packets are being spread out |
- // more than the capacity. |
- // This first trigger will not come into play until we hit roughly 9.6 Mbps |
- // with delayed acks (or 4.8Mbps without delayed acks) |
- if (ack_train_detection_ && |
- current_time.Subtract(last_close_ack_pair_time_).ToMicroseconds() <= |
- kHybridStartDelayMinThresholdUs) { |
- last_close_ack_pair_time_ = current_time; |
- if (current_time.Subtract(round_start_).ToMicroseconds() >= |
- min_rtt.ToMicroseconds() >> 1) { |
- hystart_found_ = ACK_TRAIN; |
- } |
- } else if (last_close_ack_pair_time_ == round_start_) { |
- // If the previous ack wasn't close, then move forward the round start time |
- // to the incoming ack. |
- last_close_ack_pair_time_ = round_start_ = current_time; |
- } |
- // Second detection parameter - delay increase detection. |
- // Compare the minimum delay (current_min_rtt_) of the current |
- // burst of packets relative to the minimum delay during the session. |
- // Note: we only look at the first few(8) packets in each burst, since we |
- // only want to compare the lowest RTT of the burst relative to previous |
- // bursts. |
- rtt_sample_count_++; |
- if (rtt_sample_count_ <= kHybridStartMinSamples) { |
- if (current_min_rtt_.IsZero() || current_min_rtt_ > latest_rtt) { |
- current_min_rtt_ = latest_rtt; |
- } |
- } |
- // We only need to check this once per round. |
- if (rtt_sample_count_ == kHybridStartMinSamples) { |
- // Divide min_rtt by 16 to get a rtt increase threshold for exiting. |
- int64 min_rtt_increase_threshold_us = min_rtt.ToMicroseconds() >> |
- kHybridStartDelayFactorExp; |
- // Ensure the rtt threshold is never less than 2ms or more than 16ms. |
- min_rtt_increase_threshold_us = min(min_rtt_increase_threshold_us, |
- kHybridStartDelayMaxThresholdUs); |
- QuicTime::Delta min_rtt_increase_threshold = |
- QuicTime::Delta::FromMicroseconds(max(min_rtt_increase_threshold_us, |
- kHybridStartDelayMinThresholdUs)); |
- |
- if (current_min_rtt_ > min_rtt.Add(min_rtt_increase_threshold)) { |
- hystart_found_= DELAY; |
- } |
- } |
- // Exit from slow start if the cwnd is greater than 16 and an ack train or |
- // increasing delay are found. |
- return congestion_window >= kHybridStartLowWindow && |
- hystart_found_ != NOT_FOUND; |
-} |
- |
-} // namespace net |