OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/quic/quic_sent_packet_manager.h" | 5 #include "net/quic/quic_sent_packet_manager.h" |
6 | 6 |
7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
8 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" | 8 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" |
9 #include "net/quic/test_tools/quic_test_utils.h" | 9 #include "net/quic/test_tools/quic_test_utils.h" |
10 #include "testing/gmock/include/gmock/gmock.h" | 10 #include "testing/gmock/include/gmock/gmock.h" |
(...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
142 .Times(1).WillOnce(Return(true)); | 142 .Times(1).WillOnce(Return(true)); |
143 SerializedPacket packet(CreateDataPacket(sequence_number)); | 143 SerializedPacket packet(CreateDataPacket(sequence_number)); |
144 packet.retransmittable_frames->AddStreamFrame( | 144 packet.retransmittable_frames->AddStreamFrame( |
145 new QuicStreamFrame(1, false, 0, IOVector())); | 145 new QuicStreamFrame(1, false, 0, IOVector())); |
146 manager_.OnSerializedPacket(packet); | 146 manager_.OnSerializedPacket(packet); |
147 manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(), | 147 manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(), |
148 packet.packet->length(), NOT_RETRANSMISSION, | 148 packet.packet->length(), NOT_RETRANSMISSION, |
149 HAS_RETRANSMITTABLE_DATA); | 149 HAS_RETRANSMITTABLE_DATA); |
150 } | 150 } |
151 | 151 |
| 152 void SendFecPacket(QuicPacketSequenceNumber sequence_number) { |
| 153 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, sequence_number, _, _, _)) |
| 154 .Times(1).WillOnce(Return(true)); |
| 155 SerializedPacket packet(CreateFecPacket(sequence_number)); |
| 156 manager_.OnSerializedPacket(packet); |
| 157 manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(), |
| 158 packet.packet->length(), NOT_RETRANSMISSION, |
| 159 NO_RETRANSMITTABLE_DATA); |
| 160 } |
| 161 |
152 // Based on QuicConnection's WritePendingRetransmissions. | 162 // Based on QuicConnection's WritePendingRetransmissions. |
153 void RetransmitNextPacket( | 163 void RetransmitNextPacket( |
154 QuicPacketSequenceNumber retransmission_sequence_number) { | 164 QuicPacketSequenceNumber retransmission_sequence_number) { |
155 EXPECT_TRUE(manager_.HasPendingRetransmissions()); | 165 EXPECT_TRUE(manager_.HasPendingRetransmissions()); |
156 EXPECT_CALL(*send_algorithm_, | 166 EXPECT_CALL(*send_algorithm_, |
157 OnPacketSent(_, retransmission_sequence_number, _, _, _)) | 167 OnPacketSent(_, retransmission_sequence_number, _, _, _)) |
158 .Times(1).WillOnce(Return(true)); | 168 .Times(1).WillOnce(Return(true)); |
159 const QuicSentPacketManager::PendingRetransmission pending = | 169 const QuicSentPacketManager::PendingRetransmission pending = |
160 manager_.NextPendingRetransmission(); | 170 manager_.NextPendingRetransmission(); |
161 manager_.OnRetransmittedPacket( | 171 manager_.OnRetransmittedPacket( |
(...skipping 238 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
400 EXPECT_CALL(*send_algorithm_, OnPacketAcked(5, _)); | 410 EXPECT_CALL(*send_algorithm_, OnPacketAcked(5, _)); |
401 EXPECT_CALL(*send_algorithm_, OnPacketLost(2, _)); | 411 EXPECT_CALL(*send_algorithm_, OnPacketLost(2, _)); |
402 EXPECT_CALL(*send_algorithm_, OnPacketAbandoned(2, _)); | 412 EXPECT_CALL(*send_algorithm_, OnPacketAbandoned(2, _)); |
403 manager_.OnIncomingAck(received_info, clock_.ApproximateNow()); | 413 manager_.OnIncomingAck(received_info, clock_.ApproximateNow()); |
404 | 414 |
405 VerifyUnackedPackets(NULL, 0); | 415 VerifyUnackedPackets(NULL, 0); |
406 EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_)); | 416 EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_)); |
407 EXPECT_EQ(1u, stats_.packets_spuriously_retransmitted); | 417 EXPECT_EQ(1u, stats_.packets_spuriously_retransmitted); |
408 } | 418 } |
409 | 419 |
| 420 TEST_F(QuicSentPacketManagerTest, LoseButDontRetransmitRevivedPacket) { |
| 421 SendDataPacket(1); |
| 422 SendDataPacket(2); |
| 423 SendFecPacket(3); |
| 424 SendDataPacket(4); |
| 425 |
| 426 // Ack 2 and 3, and mark 1 as revived. |
| 427 ReceivedPacketInfo received_info; |
| 428 received_info.largest_observed = 3; |
| 429 received_info.missing_packets.insert(1); |
| 430 received_info.revived_packets.insert(1); |
| 431 EXPECT_CALL(*send_algorithm_, UpdateRtt(_)); |
| 432 EXPECT_CALL(*send_algorithm_, OnPacketAcked(_, _)).Times(2); |
| 433 manager_.OnIncomingAck(received_info, clock_.ApproximateNow()); |
| 434 |
| 435 EXPECT_FALSE(manager_.HasPendingRetransmissions()); |
| 436 QuicPacketSequenceNumber unacked[] = { 1, 4 }; |
| 437 VerifyUnackedPackets(unacked, arraysize(unacked)); |
| 438 EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_)); |
| 439 QuicPacketSequenceNumber retransmittable[] = { 4 }; |
| 440 VerifyRetransmittablePackets(retransmittable, arraysize(retransmittable)); |
| 441 |
| 442 // Ack the 4th packet and expect the 1st to be considered lost. |
| 443 received_info.largest_observed = 4; |
| 444 EXPECT_CALL(*send_algorithm_, UpdateRtt(_)); |
| 445 EXPECT_CALL(*send_algorithm_, OnPacketLost(1, _)); |
| 446 EXPECT_CALL(*send_algorithm_, OnPacketAbandoned(1, _)); |
| 447 EXPECT_CALL(*send_algorithm_, OnPacketAcked(4, _)); |
| 448 manager_.OnIncomingAck(received_info, clock_.ApproximateNow()); |
| 449 |
| 450 EXPECT_FALSE(manager_.HasPendingRetransmissions()); |
| 451 VerifyRetransmittablePackets(NULL, 0); |
| 452 } |
| 453 |
410 TEST_F(QuicSentPacketManagerTest, TruncatedAck) { | 454 TEST_F(QuicSentPacketManagerTest, TruncatedAck) { |
411 SendDataPacket(1); | 455 SendDataPacket(1); |
412 RetransmitAndSendPacket(1, 2); | 456 RetransmitAndSendPacket(1, 2); |
413 RetransmitAndSendPacket(2, 3); | 457 RetransmitAndSendPacket(2, 3); |
414 RetransmitAndSendPacket(3, 4); | 458 RetransmitAndSendPacket(3, 4); |
415 RetransmitAndSendPacket(4, 5); | 459 RetransmitAndSendPacket(4, 5); |
416 | 460 |
417 // Truncated ack with 4 NACKs, so the first packet is lost. | 461 // Truncated ack with 4 NACKs, so the first packet is lost. |
418 ReceivedPacketInfo received_info; | 462 ReceivedPacketInfo received_info; |
419 received_info.largest_observed = 4; | 463 received_info.largest_observed = 4; |
(...skipping 803 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1223 delay = delay.Add(delay); | 1267 delay = delay.Add(delay); |
1224 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); | 1268 EXPECT_CALL(*send_algorithm_, OnRetransmissionTimeout(true)); |
1225 manager_.OnRetransmissionTimeout(); | 1269 manager_.OnRetransmissionTimeout(); |
1226 RetransmitNextPacket(i + 2); | 1270 RetransmitNextPacket(i + 2); |
1227 } | 1271 } |
1228 } | 1272 } |
1229 | 1273 |
1230 } // namespace | 1274 } // namespace |
1231 } // namespace test | 1275 } // namespace test |
1232 } // namespace net | 1276 } // namespace net |
OLD | NEW |