Index: net/quic/congestion_control/tcp_cubic_sender_bytes_test.cc |
diff --git a/net/quic/congestion_control/tcp_cubic_sender_bytes_test.cc b/net/quic/congestion_control/tcp_cubic_sender_bytes_test.cc |
index 7fb8f9c63b81c2c9d619e87e25596921024ded9c..9203ac6a798dcd2d69dbed20cfe90c2eba9538bb 100644 |
--- a/net/quic/congestion_control/tcp_cubic_sender_bytes_test.cc |
+++ b/net/quic/congestion_control/tcp_cubic_sender_bytes_test.cc |
@@ -62,19 +62,15 @@ class TcpCubicSenderBytesTest : public ::testing::Test { |
int SendAvailableSendWindow() { |
// Send as long as TimeUntilSend returns Zero. |
int packets_sent = 0; |
- bool can_send = sender_ |
- ->TimeUntilSend(clock_.Now(), bytes_in_flight_, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero(); |
+ bool can_send = |
+ sender_->TimeUntilSend(clock_.Now(), bytes_in_flight_).IsZero(); |
while (can_send) { |
sender_->OnPacketSent(clock_.Now(), bytes_in_flight_, packet_number_++, |
kDefaultTCPMSS, HAS_RETRANSMITTABLE_DATA); |
++packets_sent; |
bytes_in_flight_ += kDefaultTCPMSS; |
- can_send = sender_ |
- ->TimeUntilSend(clock_.Now(), bytes_in_flight_, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero(); |
+ can_send = |
+ sender_->TimeUntilSend(clock_.Now(), bytes_in_flight_).IsZero(); |
} |
return packets_sent; |
} |
@@ -131,31 +127,26 @@ TEST_F(TcpCubicSenderBytesTest, SimpleSender) { |
// At startup make sure we are at the default. |
EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); |
// At startup make sure we can send. |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0).IsZero()); |
// Make sure we can send. |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0).IsZero()); |
// And that window is un-affected. |
EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); |
// Fill the send window with data, then verify that we can't send. |
SendAvailableSendWindow(); |
- EXPECT_FALSE(sender_ |
- ->TimeUntilSend(clock_.Now(), sender_->GetCongestionWindow(), |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_FALSE( |
+ sender_->TimeUntilSend(clock_.Now(), sender_->GetCongestionWindow()) |
+ .IsZero()); |
} |
TEST_F(TcpCubicSenderBytesTest, ApplicationLimitedSlowStart) { |
// Send exactly 10 packets and ensure the CWND ends at 14 packets. |
const int kNumberOfAcks = 5; |
// At startup make sure we can send. |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0).IsZero()); |
// Make sure we can send. |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0).IsZero()); |
SendAvailableSendWindow(); |
for (int i = 0; i < kNumberOfAcks; ++i) { |
@@ -170,12 +161,10 @@ TEST_F(TcpCubicSenderBytesTest, ApplicationLimitedSlowStart) { |
TEST_F(TcpCubicSenderBytesTest, ExponentialSlowStart) { |
const int kNumberOfAcks = 20; |
// At startup make sure we can send. |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0).IsZero()); |
EXPECT_EQ(QuicBandwidth::Zero(), sender_->BandwidthEstimate()); |
// Make sure we can send. |
- EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 0).IsZero()); |
for (int i = 0; i < kNumberOfAcks; ++i) { |
// Send our full send window. |
@@ -300,8 +289,7 @@ TEST_F(TcpCubicSenderBytesTest, NoPRRWhenLessThanOnePacketInFlight) { |
// Simulate abandoning all packets by supplying a bytes_in_flight of 0. |
// PRR should now allow a packet to be sent, even though prr's state variables |
// believe it has sent enough packets. |
- EXPECT_EQ(QuicTime::Delta::Zero(), |
- sender_->TimeUntilSend(clock_.Now(), 0, HAS_RETRANSMITTABLE_DATA)); |
+ EXPECT_EQ(QuicTime::Delta::Zero(), sender_->TimeUntilSend(clock_.Now(), 0)); |
} |
TEST_F(TcpCubicSenderBytesTest, SlowStartPacketLossPRR) { |
@@ -378,10 +366,7 @@ TEST_F(TcpCubicSenderBytesTest, SlowStartBurstPacketLossPRR) { |
LoseNPackets(num_packets_to_lose); |
// Immediately after the loss, ensure at least one packet can be sent. |
// Losses without subsequent acks can occur with timer based loss detection. |
- EXPECT_TRUE(sender_ |
- ->TimeUntilSend(clock_.Now(), bytes_in_flight_, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), bytes_in_flight_).IsZero()); |
AckNPackets(1); |
// We should now have fallen out of slow start with a reduced window. |
@@ -697,22 +682,14 @@ TEST_F(TcpCubicSenderBytesTest, PaceBelowCWND) { |
sender_->SetFromConfig(config, Perspective::IS_SERVER); |
sender_->OnRetransmissionTimeout(true); |
EXPECT_EQ(kDefaultTCPMSS, sender_->GetCongestionWindow()); |
- EXPECT_TRUE(sender_ |
- ->TimeUntilSend(QuicTime::Zero(), kDefaultTCPMSS, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
- EXPECT_TRUE(sender_ |
- ->TimeUntilSend(QuicTime::Zero(), 2 * kDefaultTCPMSS, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
- EXPECT_TRUE(sender_ |
- ->TimeUntilSend(QuicTime::Zero(), 3 * kDefaultTCPMSS, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
- EXPECT_FALSE(sender_ |
- ->TimeUntilSend(QuicTime::Zero(), 4 * kDefaultTCPMSS, |
- HAS_RETRANSMITTABLE_DATA) |
- .IsZero()); |
+ EXPECT_TRUE( |
+ sender_->TimeUntilSend(QuicTime::Zero(), kDefaultTCPMSS).IsZero()); |
+ EXPECT_TRUE( |
+ sender_->TimeUntilSend(QuicTime::Zero(), 2 * kDefaultTCPMSS).IsZero()); |
+ EXPECT_TRUE( |
+ sender_->TimeUntilSend(QuicTime::Zero(), 3 * kDefaultTCPMSS).IsZero()); |
+ EXPECT_FALSE( |
+ sender_->TimeUntilSend(QuicTime::Zero(), 4 * kDefaultTCPMSS).IsZero()); |
} |
TEST_F(TcpCubicSenderBytesTest, ResetAfterConnectionMigration) { |