| Index: net/quic/congestion_control/paced_sender_test.cc
|
| diff --git a/net/quic/congestion_control/paced_sender_test.cc b/net/quic/congestion_control/paced_sender_test.cc
|
| index d2432aac08933a9023f34ddbd357958eedc066e5..cc9297f8af349dd245d323baeace711a1e5e9621 100644
|
| --- a/net/quic/congestion_control/paced_sender_test.cc
|
| +++ b/net/quic/congestion_control/paced_sender_test.cc
|
| @@ -19,7 +19,7 @@ class PacedSenderTest : public ::testing::Test {
|
| protected:
|
| PacedSenderTest()
|
| : zero_time_(QuicTime::Delta::Zero()),
|
| - paced_sender_(new PacedSender(&clock_,
|
| + paced_sender_(new PacedSender(
|
| QuicBandwidth::FromKBytesPerSecond(kHundredKBytesPerS))) {
|
| }
|
|
|
| @@ -29,59 +29,48 @@ class PacedSenderTest : public ::testing::Test {
|
| };
|
|
|
| TEST_F(PacedSenderTest, Basic) {
|
| - paced_sender_->UpdateBandwidthEstimate(
|
| + paced_sender_->UpdateBandwidthEstimate(clock_.Now(),
|
| QuicBandwidth::FromKBytesPerSecond(kHundredKBytesPerS * 10));
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - EXPECT_EQ(kMaxPacketSize * 2,
|
| - paced_sender_->AvailableWindow(kMaxPacketSize * 4));
|
| - paced_sender_->SentPacket(kMaxPacketSize);
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - paced_sender_->SentPacket(kMaxPacketSize);
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| + paced_sender_->SentPacket(clock_.Now(), kMaxPacketSize);
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| + paced_sender_->SentPacket(clock_.Now(), kMaxPacketSize);
|
| EXPECT_EQ(static_cast<int64>(kMaxPacketSize * 2),
|
| - paced_sender_->TimeUntilSend(zero_time_).ToMicroseconds());
|
| - EXPECT_EQ(0u, paced_sender_->AvailableWindow(kMaxPacketSize * 4));
|
| + paced_sender_->TimeUntilSend(
|
| + clock_.Now(), zero_time_).ToMicroseconds());
|
| clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(24));
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - EXPECT_EQ(kMaxPacketSize * 2u,
|
| - paced_sender_->AvailableWindow(kMaxPacketSize * 4));
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| }
|
|
|
| TEST_F(PacedSenderTest, LowRate) {
|
| - paced_sender_->UpdateBandwidthEstimate(
|
| + paced_sender_->UpdateBandwidthEstimate(clock_.Now(),
|
| QuicBandwidth::FromKBytesPerSecond(kHundredKBytesPerS));
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - size_t window = paced_sender_->AvailableWindow(kMaxPacketSize * 4);
|
| - EXPECT_EQ(kMaxPacketSize * 2, window);
|
| - paced_sender_->SentPacket(kMaxPacketSize);
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - paced_sender_->SentPacket(kMaxPacketSize);
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| + paced_sender_->SentPacket(clock_.Now(), kMaxPacketSize);
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| + paced_sender_->SentPacket(clock_.Now(), kMaxPacketSize);
|
| EXPECT_EQ(static_cast<int64>(kMaxPacketSize * 20),
|
| - paced_sender_->TimeUntilSend(zero_time_).ToMicroseconds());
|
| - EXPECT_EQ(0u, paced_sender_->AvailableWindow(kMaxPacketSize * 4));
|
| + paced_sender_->TimeUntilSend(
|
| + clock_.Now(), zero_time_).ToMicroseconds());
|
| clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(24));
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - EXPECT_EQ(kMaxPacketSize * 2,
|
| - paced_sender_->AvailableWindow(kMaxPacketSize * 4));
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| }
|
|
|
| TEST_F(PacedSenderTest, HighRate) {
|
| QuicBandwidth bandwidth_estimate = QuicBandwidth::FromKBytesPerSecond(
|
| kHundredKBytesPerS * 100);
|
| - paced_sender_->UpdateBandwidthEstimate(bandwidth_estimate);
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - EXPECT_EQ(static_cast<uint64>(bandwidth_estimate.ToBytesPerSecond() / 500u),
|
| - paced_sender_->AvailableWindow(kMaxPacketSize * 100));
|
| + paced_sender_->UpdateBandwidthEstimate(clock_.Now(), bandwidth_estimate);
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| for (int i = 0; i < 16; ++i) {
|
| - paced_sender_->SentPacket(kMaxPacketSize);
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| + paced_sender_->SentPacket(clock_.Now(), kMaxPacketSize);
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(
|
| + clock_.Now(), zero_time_).IsZero());
|
| }
|
| - paced_sender_->SentPacket(kMaxPacketSize);
|
| - EXPECT_EQ(0u, paced_sender_->AvailableWindow(kMaxPacketSize * 100));
|
| - EXPECT_EQ(2040, paced_sender_->TimeUntilSend(zero_time_).ToMicroseconds());
|
| + paced_sender_->SentPacket(clock_.Now(), kMaxPacketSize);
|
| + EXPECT_EQ(2040, paced_sender_->TimeUntilSend(
|
| + clock_.Now(), zero_time_).ToMicroseconds());
|
| clock_.AdvanceTime(QuicTime::Delta::FromMicroseconds(20400));
|
| - EXPECT_TRUE(paced_sender_->TimeUntilSend(zero_time_).IsZero());
|
| - EXPECT_EQ(static_cast<uint64>(bandwidth_estimate.ToBytesPerSecond() / 500u),
|
| - paced_sender_->AvailableWindow(kMaxPacketSize * 100));
|
| + EXPECT_TRUE(paced_sender_->TimeUntilSend(clock_.Now(), zero_time_).IsZero());
|
| }
|
|
|
| } // namespace test
|
|
|