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/quic_flags.h" | 8 #include "net/quic/quic_flags.h" |
9 #include "net/quic/test_tools/quic_config_peer.h" | 9 #include "net/quic/test_tools/quic_config_peer.h" |
10 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" | 10 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" |
(...skipping 1018 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1029 manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow()); | 1029 manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow()); |
1030 VerifyUnackedPackets(nullptr, 0); | 1030 VerifyUnackedPackets(nullptr, 0); |
1031 VerifyRetransmittablePackets(nullptr, 0); | 1031 VerifyRetransmittablePackets(nullptr, 0); |
1032 } | 1032 } |
1033 | 1033 |
1034 TEST_F(QuicSentPacketManagerTest, ResetRecentMinRTTWithEmptyWindow) { | 1034 TEST_F(QuicSentPacketManagerTest, ResetRecentMinRTTWithEmptyWindow) { |
1035 QuicTime::Delta min_rtt = QuicTime::Delta::FromMilliseconds(50); | 1035 QuicTime::Delta min_rtt = QuicTime::Delta::FromMilliseconds(50); |
1036 QuicSentPacketManagerPeer::GetRttStats(&manager_)->UpdateRtt( | 1036 QuicSentPacketManagerPeer::GetRttStats(&manager_)->UpdateRtt( |
1037 min_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 1037 min_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
1038 EXPECT_EQ(min_rtt, | 1038 EXPECT_EQ(min_rtt, |
1039 QuicSentPacketManagerPeer::GetRttStats(&manager_)->min_rtt()); | 1039 QuicSentPacketManagerPeer::GetRttStats(&manager_)->MinRtt()); |
1040 EXPECT_EQ(min_rtt, | 1040 EXPECT_EQ(min_rtt, |
1041 QuicSentPacketManagerPeer::GetRttStats( | 1041 QuicSentPacketManagerPeer::GetRttStats( |
1042 &manager_)->recent_min_rtt()); | 1042 &manager_)->recent_min_rtt()); |
1043 | 1043 |
1044 // Send two packets with no prior bytes in flight. | 1044 // Send two packets with no prior bytes in flight. |
1045 SendDataPacket(1); | 1045 SendDataPacket(1); |
1046 SendDataPacket(2); | 1046 SendDataPacket(2); |
1047 | 1047 |
1048 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(100)); | 1048 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(100)); |
1049 // Ack two packets with 100ms RTT observations. | 1049 // Ack two packets with 100ms RTT observations. |
1050 QuicAckFrame ack_frame; | 1050 QuicAckFrame ack_frame; |
1051 ack_frame.delta_time_largest_observed = QuicTime::Delta::Zero(); | 1051 ack_frame.delta_time_largest_observed = QuicTime::Delta::Zero(); |
1052 ack_frame.largest_observed = 1; | 1052 ack_frame.largest_observed = 1; |
1053 ExpectAck(1); | 1053 ExpectAck(1); |
1054 manager_.OnIncomingAck(ack_frame, clock_.Now()); | 1054 manager_.OnIncomingAck(ack_frame, clock_.Now()); |
1055 | 1055 |
1056 // First ack does not change recent min rtt. | 1056 // First ack does not change recent min rtt. |
1057 EXPECT_EQ(min_rtt, | 1057 EXPECT_EQ(min_rtt, |
1058 QuicSentPacketManagerPeer::GetRttStats( | 1058 QuicSentPacketManagerPeer::GetRttStats( |
1059 &manager_)->recent_min_rtt()); | 1059 &manager_)->recent_min_rtt()); |
1060 | 1060 |
1061 ack_frame.largest_observed = 2; | 1061 ack_frame.largest_observed = 2; |
1062 ExpectAck(2); | 1062 ExpectAck(2); |
1063 manager_.OnIncomingAck(ack_frame, clock_.Now()); | 1063 manager_.OnIncomingAck(ack_frame, clock_.Now()); |
1064 | 1064 |
1065 EXPECT_EQ(min_rtt, | 1065 EXPECT_EQ(min_rtt, |
1066 QuicSentPacketManagerPeer::GetRttStats(&manager_)->min_rtt()); | 1066 QuicSentPacketManagerPeer::GetRttStats(&manager_)->MinRtt()); |
1067 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(100), | 1067 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(100), |
1068 QuicSentPacketManagerPeer::GetRttStats( | 1068 QuicSentPacketManagerPeer::GetRttStats( |
1069 &manager_)->recent_min_rtt()); | 1069 &manager_)->recent_min_rtt()); |
1070 } | 1070 } |
1071 | 1071 |
1072 TEST_F(QuicSentPacketManagerTest, RetransmissionTimeout) { | 1072 TEST_F(QuicSentPacketManagerTest, RetransmissionTimeout) { |
1073 // Send 100 packets and then ensure all are abandoned when the RTO fires. | 1073 // Send 100 packets and then ensure all are abandoned when the RTO fires. |
1074 const size_t kNumSentPackets = 100; | 1074 const size_t kNumSentPackets = 100; |
1075 for (size_t i = 1; i <= kNumSentPackets; ++i) { | 1075 for (size_t i = 1; i <= kNumSentPackets; ++i) { |
1076 SendDataPacket(i); | 1076 SendDataPacket(i); |
(...skipping 304 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1381 .WillOnce(Return(100 * kDefaultTCPMSS)); | 1381 .WillOnce(Return(100 * kDefaultTCPMSS)); |
1382 manager_.SetFromConfig(config); | 1382 manager_.SetFromConfig(config); |
1383 | 1383 |
1384 EXPECT_EQ(initial_rtt_us, | 1384 EXPECT_EQ(initial_rtt_us, |
1385 manager_.GetRttStats()->SmoothedRtt().ToMicroseconds()); | 1385 manager_.GetRttStats()->SmoothedRtt().ToMicroseconds()); |
1386 } | 1386 } |
1387 | 1387 |
1388 } // namespace | 1388 } // namespace |
1389 } // namespace test | 1389 } // namespace test |
1390 } // namespace net | 1390 } // namespace net |
OLD | NEW |