Add a new rate based sending connection option which uses the pacing rate to keep the bytes_in_flig…

net/quic/congestion_control/pacing_sender.cc

 // Copyright (c) 2013 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/pacing_sender.h"
 
 #include "net/quic/quic_flags.h"
 
 using std::min;
 
@@ skipping 70 matching lines @@
         initial_packet_burst_,
         static_cast<uint32_t>(sender_->GetCongestionWindow() / kDefaultTCPMSS));
   }
   if (burst_tokens_ > 0) {
     --burst_tokens_;
     was_last_send_delayed_ = false;
     last_delayed_packet_sent_time_ = QuicTime::Zero();
     ideal_next_packet_send_time_ = QuicTime::Zero();
     return in_flight;
   }
-  // The next packet should be sent as soon as the current packets has been
-  // transferred.
-  QuicTime::Delta delay = PacingRate().TransferTime(bytes);
+  // The next packet should be sent as soon as the current packet has been
+  // transferred.  PacingRate is based on bytes in flight including this packet.
+  QuicTime::Delta delay =
+      PacingRate(bytes_in_flight + bytes).TransferTime(bytes);
   // If the last send was delayed, and the alarm took a long time to get
   // invoked, allow the connection to make up for lost time.
   if (was_last_send_delayed_) {
     ideal_next_packet_send_time_ = ideal_next_packet_send_time_.Add(delay);
     // The send was application limited if it takes longer than the
     // pacing delay between sent packets.
     const bool application_limited =
         last_delayed_packet_sent_time_.IsInitialized() &&
         sent_time > last_delayed_packet_sent_time_.Add(delay);
     const bool making_up_for_lost_time =
@@ skipping 43 matching lines @@
     DVLOG(1) << "Delaying packet: "
              << ideal_next_packet_send_time_.Subtract(now).ToMicroseconds();
     was_last_send_delayed_ = true;
     return ideal_next_packet_send_time_.Subtract(now);
   }
 
   DVLOG(1) << "Sending packet now";
   return QuicTime::Delta::Zero();
 }
 
-QuicBandwidth PacingSender::PacingRate() const {
+QuicBandwidth PacingSender::PacingRate(QuicByteCount bytes_in_flight) const {
   if (!max_pacing_rate_.IsZero()) {
     return QuicBandwidth::FromBitsPerSecond(
         min(max_pacing_rate_.ToBitsPerSecond(),
-            sender_->PacingRate().ToBitsPerSecond()));
+            sender_->PacingRate(bytes_in_flight).ToBitsPerSecond()));
   }
-  return sender_->PacingRate();
+  return sender_->PacingRate(bytes_in_flight);
 }
 
 QuicBandwidth PacingSender::BandwidthEstimate() const {
   return sender_->BandwidthEstimate();
 }
 
 QuicTime::Delta PacingSender::RetransmissionDelay() const {
   return sender_->RetransmissionDelay();
 }
 
@@ skipping 11 matching lines @@
 
 QuicByteCount PacingSender::GetSlowStartThreshold() const {
   return sender_->GetSlowStartThreshold();
 }
 
 CongestionControlType PacingSender::GetCongestionControlType() const {
   return sender_->GetCongestionControlType();
 }
 
 }  // namespace net