| Index: net/quic/congestion_control/fix_rate_sender.cc
|
| diff --git a/net/quic/congestion_control/fix_rate_sender.cc b/net/quic/congestion_control/fix_rate_sender.cc
|
| index 5398cc6234d7fa25cfb28a2f94758dd4760a58f4..cd0923d8513172eb242e47e345e8e98473302e71 100644
|
| --- a/net/quic/congestion_control/fix_rate_sender.cc
|
| +++ b/net/quic/congestion_control/fix_rate_sender.cc
|
| @@ -46,8 +46,14 @@ void FixRateSender::OnIncomingAck(
|
| QuicPacketSequenceNumber /*acked_sequence_number*/,
|
| QuicByteCount bytes_acked,
|
| QuicTime::Delta rtt) {
|
| - latest_rtt_ = rtt;
|
| + // RTT can't be negative.
|
| + DCHECK_LE(0, rtt.ToMicroseconds());
|
| +
|
| data_in_flight_ -= bytes_acked;
|
| + if (rtt.IsInfinite()) {
|
| + return;
|
| + }
|
| + latest_rtt_ = rtt;
|
| }
|
|
|
| void FixRateSender::OnIncomingLoss(QuicTime /*ack_receive_time*/) {
|
| @@ -105,4 +111,10 @@ QuicTime::Delta FixRateSender::SmoothedRtt() {
|
| return latest_rtt_;
|
| }
|
|
|
| +QuicTime::Delta FixRateSender::RetransmissionDelay() {
|
| + // TODO(pwestin): Calculate and return retransmission delay.
|
| + // Use 2 * the latest RTT for now.
|
| + return latest_rtt_.Add(latest_rtt_);
|
| +}
|
| +
|
| } // namespace net
|
|
|