OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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_unacked_packet_map.h" | 5 #include "net/quic/quic_unacked_packet_map.h" |
6 | 6 |
7 #include "net/quic/test_tools/quic_test_utils.h" | 7 #include "net/quic/test_tools/quic_test_utils.h" |
8 #include "testing/gtest/include/gtest/gtest.h" | 8 #include "testing/gtest/include/gtest/gtest.h" |
9 | 9 |
10 using std::min; | 10 using std::min; |
(...skipping 12 matching lines...) Expand all Loading... |
23 QuicUnackedPacketMapTest() | 23 QuicUnackedPacketMapTest() |
24 : now_(QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(1000))) { | 24 : now_(QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(1000))) { |
25 } | 25 } |
26 | 26 |
27 ~QuicUnackedPacketMapTest() override { | 27 ~QuicUnackedPacketMapTest() override { |
28 STLDeleteElements(&packets_); | 28 STLDeleteElements(&packets_); |
29 } | 29 } |
30 | 30 |
31 SerializedPacket CreateRetransmittablePacket( | 31 SerializedPacket CreateRetransmittablePacket( |
32 QuicPacketSequenceNumber sequence_number) { | 32 QuicPacketSequenceNumber sequence_number) { |
33 packets_.push_back(QuicPacket::NewDataPacket( | 33 packets_.push_back(new QuicPacket(nullptr, kDefaultLength, false, |
34 nullptr, kDefaultLength, false, PACKET_8BYTE_CONNECTION_ID, false, | 34 PACKET_8BYTE_CONNECTION_ID, false, |
35 PACKET_1BYTE_SEQUENCE_NUMBER)); | 35 PACKET_1BYTE_SEQUENCE_NUMBER)); |
36 return SerializedPacket(sequence_number, PACKET_1BYTE_SEQUENCE_NUMBER, | 36 return SerializedPacket(sequence_number, PACKET_1BYTE_SEQUENCE_NUMBER, |
37 packets_.back(), 0, new RetransmittableFrames()); | 37 packets_.back(), 0, new RetransmittableFrames()); |
38 } | 38 } |
39 | 39 |
40 SerializedPacket CreateNonRetransmittablePacket( | 40 SerializedPacket CreateNonRetransmittablePacket( |
41 QuicPacketSequenceNumber sequence_number) { | 41 QuicPacketSequenceNumber sequence_number) { |
42 packets_.push_back(QuicPacket::NewDataPacket( | 42 packets_.push_back(new QuicPacket(nullptr, kDefaultLength, false, |
43 nullptr, kDefaultLength, false, PACKET_8BYTE_CONNECTION_ID, false, | 43 PACKET_8BYTE_CONNECTION_ID, false, |
44 PACKET_1BYTE_SEQUENCE_NUMBER)); | 44 PACKET_1BYTE_SEQUENCE_NUMBER)); |
45 return SerializedPacket(sequence_number, PACKET_1BYTE_SEQUENCE_NUMBER, | 45 return SerializedPacket(sequence_number, PACKET_1BYTE_SEQUENCE_NUMBER, |
46 packets_.back(), 0, nullptr); | 46 packets_.back(), 0, nullptr); |
47 } | 47 } |
48 | 48 |
49 void VerifyInFlightPackets(QuicPacketSequenceNumber* packets, | 49 void VerifyInFlightPackets(QuicPacketSequenceNumber* packets, |
50 size_t num_packets) { | 50 size_t num_packets) { |
51 unacked_packets_.RemoveObsoletePackets(); | 51 unacked_packets_.RemoveObsoletePackets(); |
52 if (num_packets == 0) { | 52 if (num_packets == 0) { |
53 EXPECT_FALSE(unacked_packets_.HasInFlightPackets()); | 53 EXPECT_FALSE(unacked_packets_.HasInFlightPackets()); |
54 EXPECT_FALSE(unacked_packets_.HasMultipleInFlightPackets()); | 54 EXPECT_FALSE(unacked_packets_.HasMultipleInFlightPackets()); |
(...skipping 341 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
396 EXPECT_TRUE(unacked_packets_.IsUnacked(3)); | 396 EXPECT_TRUE(unacked_packets_.IsUnacked(3)); |
397 EXPECT_FALSE(unacked_packets_.IsUnacked(4)); | 397 EXPECT_FALSE(unacked_packets_.IsUnacked(4)); |
398 EXPECT_TRUE(unacked_packets_.IsUnacked(5)); | 398 EXPECT_TRUE(unacked_packets_.IsUnacked(5)); |
399 EXPECT_EQ(5u, unacked_packets_.largest_sent_packet()); | 399 EXPECT_EQ(5u, unacked_packets_.largest_sent_packet()); |
400 } | 400 } |
401 | 401 |
402 | 402 |
403 } // namespace | 403 } // namespace |
404 } // namespace test | 404 } // namespace test |
405 } // namespace net | 405 } // namespace net |
OLD | NEW |