| Index: net/quic/quic_sent_packet_manager_test.cc
|
| diff --git a/net/quic/quic_sent_packet_manager_test.cc b/net/quic/quic_sent_packet_manager_test.cc
|
| index 8a386bfd0d0c7db6dd41837ae0c2a9cb3e4d6268..798c8deb8ca5ebd0861680744426ab5b0de5bf46 100644
|
| --- a/net/quic/quic_sent_packet_manager_test.cc
|
| +++ b/net/quic/quic_sent_packet_manager_test.cc
|
| @@ -226,7 +226,7 @@ class QuicSentPacketManagerTest : public ::testing::TestWithParam<bool> {
|
| new QuicStreamFrame(1, false, 0, IOVector()));
|
| packet.retransmittable_frames->set_encryption_level(ENCRYPTION_NONE);
|
| manager_.OnSerializedPacket(packet);
|
| - manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(),
|
| + manager_.OnPacketSent(sequence_number, clock_.Now(),
|
| packet.packet->length(), NOT_RETRANSMISSION,
|
| HAS_RETRANSMITTABLE_DATA);
|
| }
|
| @@ -238,7 +238,7 @@ class QuicSentPacketManagerTest : public ::testing::TestWithParam<bool> {
|
| .Times(1).WillOnce(Return(true));
|
| SerializedPacket packet(CreateFecPacket(sequence_number));
|
| manager_.OnSerializedPacket(packet);
|
| - manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(),
|
| + manager_.OnPacketSent(sequence_number, clock_.Now(),
|
| packet.packet->length(), NOT_RETRANSMISSION,
|
| NO_RETRANSMITTABLE_DATA);
|
| }
|
| @@ -282,10 +282,7 @@ class QuicSentPacketManagerTest : public ::testing::TestWithParam<bool> {
|
|
|
| TEST_F(QuicSentPacketManagerTest, IsUnacked) {
|
| VerifyUnackedPackets(NULL, 0);
|
| -
|
| - SerializedPacket serialized_packet(CreateDataPacket(1));
|
| -
|
| - manager_.OnSerializedPacket(serialized_packet);
|
| + SendDataPacket(1);
|
|
|
| QuicPacketSequenceNumber unacked[] = { 1 };
|
| VerifyUnackedPackets(unacked, arraysize(unacked));
|
| @@ -648,16 +645,12 @@ TEST_F(QuicSentPacketManagerTest, GetLeastUnacked) {
|
| }
|
|
|
| TEST_F(QuicSentPacketManagerTest, GetLeastUnackedUnacked) {
|
| - SerializedPacket serialized_packet(CreateDataPacket(1));
|
| -
|
| - manager_.OnSerializedPacket(serialized_packet);
|
| + SendDataPacket(1);
|
| EXPECT_EQ(1u, manager_.GetLeastUnacked());
|
| }
|
|
|
| TEST_F(QuicSentPacketManagerTest, GetLeastUnackedUnackedFec) {
|
| - SerializedPacket serialized_packet(CreateFecPacket(1));
|
| -
|
| - manager_.OnSerializedPacket(serialized_packet);
|
| + SendFecPacket(1);
|
| EXPECT_EQ(1u, manager_.GetLeastUnacked());
|
| }
|
|
|
| @@ -690,29 +683,17 @@ TEST_F(QuicSentPacketManagerTest, GetLeastUnackedAndDiscard) {
|
| TEST_F(QuicSentPacketManagerTest, GetSentTime) {
|
| VerifyUnackedPackets(NULL, 0);
|
|
|
| - SerializedPacket serialized_packet(CreateFecPacket(1));
|
| - manager_.OnSerializedPacket(serialized_packet);
|
| - EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 1, _, _))
|
| - .Times(1).WillOnce(Return(true));
|
| - manager_.OnPacketSent(1, QuicTime::Zero(), kDefaultLength, NOT_RETRANSMISSION,
|
| - NO_RETRANSMITTABLE_DATA);
|
| -
|
| - SerializedPacket serialized_packet2(CreateFecPacket(2));
|
| - QuicTime sent_time = QuicTime::Zero().Add(QuicTime::Delta::FromSeconds(1));
|
| - manager_.OnSerializedPacket(serialized_packet2);
|
| - EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, 2, _, _))
|
| - .Times(1).WillOnce(Return(true));
|
| - manager_.OnPacketSent(2, sent_time, kDefaultLength, NOT_RETRANSMISSION,
|
| - NO_RETRANSMITTABLE_DATA);
|
| -
|
| + QuicTime sent_time = clock_.Now();
|
| + SendFecPacket(1);
|
| + QuicTime sent_time2 = clock_.Now();
|
| + SendFecPacket(2);
|
| QuicPacketSequenceNumber unacked[] = { 1, 2 };
|
| VerifyUnackedPackets(unacked, arraysize(unacked));
|
| VerifyRetransmittablePackets(NULL, 0);
|
|
|
| EXPECT_TRUE(manager_.HasUnackedPackets());
|
| - EXPECT_EQ(QuicTime::Zero(),
|
| - QuicSentPacketManagerPeer::GetSentTime(&manager_, 1));
|
| - EXPECT_EQ(sent_time, QuicSentPacketManagerPeer::GetSentTime(&manager_, 2));
|
| + EXPECT_EQ(sent_time, QuicSentPacketManagerPeer::GetSentTime(&manager_, 1));
|
| + EXPECT_EQ(sent_time2, QuicSentPacketManagerPeer::GetSentTime(&manager_, 2));
|
| }
|
|
|
| TEST_F(QuicSentPacketManagerTest, AckAckAndUpdateRtt) {
|
| @@ -1020,13 +1001,12 @@ TEST_F(QuicSentPacketManagerTest, CryptoHandshakeSpuriousRetransmission) {
|
| }
|
|
|
| TEST_F(QuicSentPacketManagerTest, CryptoHandshakeTimeoutUnsentDataPacket) {
|
| - // Send 2 crypto packets and serialize 1 data packet.
|
| + // Send 2 crypto packets and 1 data packet.
|
| const size_t kNumSentCryptoPackets = 2;
|
| for (size_t i = 1; i <= kNumSentCryptoPackets; ++i) {
|
| SendCryptoPacket(i);
|
| }
|
| - SerializedPacket packet(CreateDataPacket(3));
|
| - manager_.OnSerializedPacket(packet);
|
| + SendDataPacket(3);
|
| EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
|
|
|
| // Retransmit 2 crypto packets, but not the serialized packet.
|
| @@ -1092,32 +1072,6 @@ TEST_F(QuicSentPacketManagerTest,
|
| VerifyRetransmittablePackets(NULL, 0);
|
| }
|
|
|
| -TEST_F(QuicSentPacketManagerTest, TailLossProbeTimeoutUnsentDataPacket) {
|
| - QuicSentPacketManagerPeer::SetMaxTailLossProbes(&manager_, 2);
|
| - // Serialize two data packets and send the latter.
|
| - SerializedPacket packet(CreateDataPacket(1));
|
| - manager_.OnSerializedPacket(packet);
|
| - SendDataPacket(2);
|
| - EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
|
| - EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
|
| -
|
| - // Retransmit 1 unacked packets, but not the first serialized packet.
|
| - manager_.OnRetransmissionTimeout();
|
| - EXPECT_EQ(QuicTime::Delta::Zero(),
|
| - manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
|
| - EXPECT_FALSE(manager_.HasPendingRetransmissions());
|
| - manager_.MaybeRetransmitTailLossProbe();
|
| - EXPECT_TRUE(manager_.HasPendingRetransmissions());
|
| - RetransmitNextPacket(3);
|
| - EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _, _)).WillOnce(Return(
|
| - QuicTime::Delta::Infinite()));
|
| - EXPECT_EQ(QuicTime::Delta::Infinite(),
|
| - manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
|
| - EXPECT_FALSE(manager_.HasPendingRetransmissions());
|
| - EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
|
| - EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
|
| -}
|
| -
|
| TEST_F(QuicSentPacketManagerTest, ResetRecentMinRTTWithEmptyWindow) {
|
| QuicTime::Delta min_rtt = QuicTime::Delta::FromMilliseconds(50);
|
| QuicSentPacketManagerPeer::GetRttStats(&manager_)->UpdateRtt(
|
|
|