Index: net/quic/congestion_control/fix_rate_test.cc |
diff --git a/net/quic/congestion_control/fix_rate_test.cc b/net/quic/congestion_control/fix_rate_test.cc |
index d32e336cea373b4778ba234412421be03399b552..bbbb3cd7e39f1b915d56a41ba2e1757f87e24df6 100644 |
--- a/net/quic/congestion_control/fix_rate_test.cc |
+++ b/net/quic/congestion_control/fix_rate_test.cc |
@@ -2,6 +2,8 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
+// Test for FixRate sender and receiver. |
+ |
#include "base/logging.h" |
#include "base/memory/scoped_ptr.h" |
#include "net/quic/congestion_control/fix_rate_receiver.h" |
@@ -24,7 +26,6 @@ class FixRateReceiverPeer : public FixRateReceiver { |
} |
}; |
-const bool kHasRetransmittableData = true; |
class FixRateTest : public ::testing::Test { |
protected: |
FixRateTest() |
@@ -60,24 +61,21 @@ TEST_F(FixRateTest, SenderAPI) { |
sender_->OnIncomingQuicCongestionFeedbackFrame(feedback, clock_.Now(), |
unused_bandwidth_, unused_packet_map_); |
EXPECT_EQ(300000, sender_->BandwidthEstimate().ToBytesPerSecond()); |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false).IsZero()); |
- sender_->SentPacket(clock_.Now(), 1, kMaxPacketSize, false, |
- kHasRetransmittableData); |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false).IsZero()); |
- sender_->SentPacket(clock_.Now(), 2, kMaxPacketSize, false, |
- kHasRetransmittableData); |
- sender_->SentPacket(clock_.Now(), 3, 600, false, |
- kHasRetransmittableData); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false, true).IsZero()); |
+ sender_->SentPacket(clock_.Now(), 1, kMaxPacketSize, false); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false, true).IsZero()); |
+ sender_->SentPacket(clock_.Now(), 2, kMaxPacketSize, false); |
+ sender_->SentPacket(clock_.Now(), 3, 600, false); |
EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), |
- sender_->TimeUntilSend(clock_.Now(), false)); |
+ sender_->TimeUntilSend(clock_.Now(), false, true)); |
clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(2)); |
EXPECT_EQ(QuicTime::Delta::Infinite(), |
- sender_->TimeUntilSend(clock_.Now(), false)); |
+ sender_->TimeUntilSend(clock_.Now(), false, true)); |
clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(8)); |
sender_->OnIncomingAck(1, kMaxPacketSize, rtt_); |
sender_->OnIncomingAck(2, kMaxPacketSize, rtt_); |
sender_->OnIncomingAck(3, 600, rtt_); |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false).IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false, true).IsZero()); |
} |
TEST_F(FixRateTest, FixRatePacing) { |
@@ -92,13 +90,12 @@ TEST_F(FixRateTest, FixRatePacing) { |
QuicTime acc_advance_time(QuicTime::Zero()); |
QuicPacketSequenceNumber sequence_number = 0; |
for (int i = 0; i < num_packets; i += 2) { |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false).IsZero()); |
- sender_->SentPacket(clock_.Now(), sequence_number++, packet_size, false, |
- kHasRetransmittableData); |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false).IsZero()); |
- sender_->SentPacket(clock_.Now(), sequence_number++, packet_size, false, |
- kHasRetransmittableData); |
- QuicTime::Delta advance_time = sender_->TimeUntilSend(clock_.Now(), false); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false, true).IsZero()); |
+ sender_->SentPacket(clock_.Now(), sequence_number++, packet_size, false); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), false, true).IsZero()); |
+ sender_->SentPacket(clock_.Now(), sequence_number++, packet_size, false); |
+ QuicTime::Delta advance_time = sender_->TimeUntilSend(clock_.Now(), false, |
+ true); |
clock_.AdvanceTime(advance_time); |
sender_->OnIncomingAck(sequence_number - 1, packet_size, rtt_); |
sender_->OnIncomingAck(sequence_number - 2, packet_size, rtt_); |