| 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/congestion_control/rtt_stats.h" | 5 #include "net/quic/congestion_control/rtt_stats.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/test/mock_log.h" | 10 #include "base/test/mock_log.h" |
| (...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 71 } | 71 } |
| 72 | 72 |
| 73 TEST_F(RttStatsTest, MinRtt) { | 73 TEST_F(RttStatsTest, MinRtt) { |
| 74 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), | 74 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), |
| 75 QuicTime::Delta::Zero(), QuicTime::Zero()); | 75 QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 76 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.min_rtt()); | 76 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.min_rtt()); |
| 77 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), | 77 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), |
| 78 rtt_stats_.WindowedMinRtt()); | 78 rtt_stats_.WindowedMinRtt()); |
| 79 rtt_stats_.UpdateRtt( | 79 rtt_stats_.UpdateRtt( |
| 80 QuicTime::Delta::FromMilliseconds(10), QuicTime::Delta::Zero(), | 80 QuicTime::Delta::FromMilliseconds(10), QuicTime::Delta::Zero(), |
| 81 QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(10))); | 81 QuicTime::Zero() + QuicTime::Delta::FromMilliseconds(10)); |
| 82 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); | 82 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 83 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); | 83 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); |
| 84 rtt_stats_.UpdateRtt( | 84 rtt_stats_.UpdateRtt( |
| 85 QuicTime::Delta::FromMilliseconds(50), QuicTime::Delta::Zero(), | 85 QuicTime::Delta::FromMilliseconds(50), QuicTime::Delta::Zero(), |
| 86 QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(20))); | 86 QuicTime::Zero() + QuicTime::Delta::FromMilliseconds(20)); |
| 87 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); | 87 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 88 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); | 88 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); |
| 89 rtt_stats_.UpdateRtt( | 89 rtt_stats_.UpdateRtt( |
| 90 QuicTime::Delta::FromMilliseconds(50), QuicTime::Delta::Zero(), | 90 QuicTime::Delta::FromMilliseconds(50), QuicTime::Delta::Zero(), |
| 91 QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(30))); | 91 QuicTime::Zero() + QuicTime::Delta::FromMilliseconds(30)); |
| 92 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); | 92 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 93 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); | 93 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); |
| 94 rtt_stats_.UpdateRtt( | 94 rtt_stats_.UpdateRtt( |
| 95 QuicTime::Delta::FromMilliseconds(50), QuicTime::Delta::Zero(), | 95 QuicTime::Delta::FromMilliseconds(50), QuicTime::Delta::Zero(), |
| 96 QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(40))); | 96 QuicTime::Zero() + QuicTime::Delta::FromMilliseconds(40)); |
| 97 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); | 97 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 98 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); | 98 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); |
| 99 // Verify that ack_delay does not go into recording of min_rtt_. | 99 // Verify that ack_delay does not go into recording of min_rtt_. |
| 100 rtt_stats_.UpdateRtt( | 100 rtt_stats_.UpdateRtt( |
| 101 QuicTime::Delta::FromMilliseconds(7), | 101 QuicTime::Delta::FromMilliseconds(7), |
| 102 QuicTime::Delta::FromMilliseconds(2), | 102 QuicTime::Delta::FromMilliseconds(2), |
| 103 QuicTime::Zero().Add(QuicTime::Delta::FromMilliseconds(50))); | 103 QuicTime::Zero() + QuicTime::Delta::FromMilliseconds(50)); |
| 104 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.min_rtt()); | 104 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.min_rtt()); |
| 105 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.WindowedMinRtt()); | 105 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.WindowedMinRtt()); |
| 106 } | 106 } |
| 107 | 107 |
| 108 TEST_F(RttStatsTest, WindowedMinRtt) { | 108 TEST_F(RttStatsTest, WindowedMinRtt) { |
| 109 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(10), | 109 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(10), |
| 110 QuicTime::Delta::Zero(), QuicTime::Zero()); | 110 QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 111 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); | 111 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 112 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); | 112 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.WindowedMinRtt()); |
| 113 | 113 |
| (...skipping 11 matching lines...) Expand all Loading... |
| 125 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(50), rtt_stats_.WindowedMinRtt()); | 125 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(50), rtt_stats_.WindowedMinRtt()); |
| 126 } | 126 } |
| 127 | 127 |
| 128 TEST_F(RttStatsTest, ExpireSmoothedMetrics) { | 128 TEST_F(RttStatsTest, ExpireSmoothedMetrics) { |
| 129 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); | 129 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); |
| 130 rtt_stats_.UpdateRtt(initial_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 130 rtt_stats_.UpdateRtt(initial_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 131 EXPECT_EQ(initial_rtt, rtt_stats_.min_rtt()); | 131 EXPECT_EQ(initial_rtt, rtt_stats_.min_rtt()); |
| 132 EXPECT_EQ(initial_rtt, rtt_stats_.WindowedMinRtt()); | 132 EXPECT_EQ(initial_rtt, rtt_stats_.WindowedMinRtt()); |
| 133 EXPECT_EQ(initial_rtt, rtt_stats_.smoothed_rtt()); | 133 EXPECT_EQ(initial_rtt, rtt_stats_.smoothed_rtt()); |
| 134 | 134 |
| 135 EXPECT_EQ(initial_rtt.Multiply(0.5), rtt_stats_.mean_deviation()); | 135 EXPECT_EQ(0.5 * initial_rtt, rtt_stats_.mean_deviation()); |
| 136 | 136 |
| 137 // Update once with a 20ms RTT. | 137 // Update once with a 20ms RTT. |
| 138 QuicTime::Delta doubled_rtt = initial_rtt.Multiply(2); | 138 QuicTime::Delta doubled_rtt = 2 * initial_rtt; |
| 139 rtt_stats_.UpdateRtt(doubled_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 139 rtt_stats_.UpdateRtt(doubled_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 140 EXPECT_EQ(initial_rtt.Multiply(1.125), rtt_stats_.smoothed_rtt()); | 140 EXPECT_EQ(1.125 * initial_rtt, rtt_stats_.smoothed_rtt()); |
| 141 | 141 |
| 142 // Expire the smoothed metrics, increasing smoothed rtt and mean deviation. | 142 // Expire the smoothed metrics, increasing smoothed rtt and mean deviation. |
| 143 rtt_stats_.ExpireSmoothedMetrics(); | 143 rtt_stats_.ExpireSmoothedMetrics(); |
| 144 EXPECT_EQ(doubled_rtt, rtt_stats_.smoothed_rtt()); | 144 EXPECT_EQ(doubled_rtt, rtt_stats_.smoothed_rtt()); |
| 145 EXPECT_EQ(initial_rtt.Multiply(0.875), rtt_stats_.mean_deviation()); | 145 EXPECT_EQ(0.875 * initial_rtt, rtt_stats_.mean_deviation()); |
| 146 | 146 |
| 147 // Now go back down to 5ms and expire the smoothed metrics, and ensure the | 147 // Now go back down to 5ms and expire the smoothed metrics, and ensure the |
| 148 // mean deviation increases to 15ms. | 148 // mean deviation increases to 15ms. |
| 149 QuicTime::Delta half_rtt = initial_rtt.Multiply(0.5); | 149 QuicTime::Delta half_rtt = 0.5 * initial_rtt; |
| 150 rtt_stats_.UpdateRtt(half_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 150 rtt_stats_.UpdateRtt(half_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 151 EXPECT_GT(doubled_rtt, rtt_stats_.smoothed_rtt()); | 151 EXPECT_GT(doubled_rtt, rtt_stats_.smoothed_rtt()); |
| 152 EXPECT_LT(initial_rtt, rtt_stats_.mean_deviation()); | 152 EXPECT_LT(initial_rtt, rtt_stats_.mean_deviation()); |
| 153 } | 153 } |
| 154 | 154 |
| 155 TEST_F(RttStatsTest, UpdateRttWithBadSendDeltas) { | 155 TEST_F(RttStatsTest, UpdateRttWithBadSendDeltas) { |
| 156 // Make sure we ignore bad RTTs. | 156 // Make sure we ignore bad RTTs. |
| 157 base::test::MockLog log; | 157 base::test::MockLog log; |
| 158 | 158 |
| 159 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); | 159 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 193 // Reset rtt stats on connection migrations. | 193 // Reset rtt stats on connection migrations. |
| 194 rtt_stats_.OnConnectionMigration(); | 194 rtt_stats_.OnConnectionMigration(); |
| 195 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.latest_rtt()); | 195 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.latest_rtt()); |
| 196 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.smoothed_rtt()); | 196 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.smoothed_rtt()); |
| 197 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.min_rtt()); | 197 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.min_rtt()); |
| 198 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.WindowedMinRtt()); | 198 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.WindowedMinRtt()); |
| 199 } | 199 } |
| 200 | 200 |
| 201 } // namespace test | 201 } // namespace test |
| 202 } // namespace net | 202 } // namespace net |
| OLD | NEW |