Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1302)

Unified Diff: net/quic/congestion_control/fix_rate_test.cc

Issue 12806002: Land Recent QUIC Changes (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: minor comment fix Created 7 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/congestion_control/fix_rate_sender.cc ('k') | net/quic/congestion_control/hybrid_slow_start.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_);
« no previous file with comments | « net/quic/congestion_control/fix_rate_sender.cc ('k') | net/quic/congestion_control/hybrid_slow_start.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698