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( |