| 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 "net/test/scoped_mock_log.h" | 10 #include "net/test/scoped_mock_log.h" |
| (...skipping 19 matching lines...) Expand all Loading... |
| 30 } | 30 } |
| 31 }; | 31 }; |
| 32 | 32 |
| 33 class RttStatsTest : public ::testing::Test { | 33 class RttStatsTest : public ::testing::Test { |
| 34 protected: | 34 protected: |
| 35 RttStats rtt_stats_; | 35 RttStats rtt_stats_; |
| 36 }; | 36 }; |
| 37 | 37 |
| 38 TEST_F(RttStatsTest, DefaultsBeforeUpdate) { | 38 TEST_F(RttStatsTest, DefaultsBeforeUpdate) { |
| 39 EXPECT_LT(0u, rtt_stats_.initial_rtt_us()); | 39 EXPECT_LT(0u, rtt_stats_.initial_rtt_us()); |
| 40 EXPECT_EQ(QuicTime::Delta::FromMicroseconds(rtt_stats_.initial_rtt_us()), | 40 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.min_rtt()); |
| 41 rtt_stats_.MinRtt()); | 41 EXPECT_EQ(QuicTime::Delta::Zero(), rtt_stats_.smoothed_rtt()); |
| 42 EXPECT_EQ(QuicTime::Delta::FromMicroseconds(rtt_stats_.initial_rtt_us()), | |
| 43 rtt_stats_.SmoothedRtt()); | |
| 44 } | 42 } |
| 45 | 43 |
| 46 TEST_F(RttStatsTest, SmoothedRtt) { | 44 TEST_F(RttStatsTest, SmoothedRtt) { |
| 47 // Verify that ack_delay is corrected for in Smoothed RTT. | 45 // Verify that ack_delay is corrected for in Smoothed RTT. |
| 48 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(300), | 46 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(300), |
| 49 QuicTime::Delta::FromMilliseconds(100), | 47 QuicTime::Delta::FromMilliseconds(100), |
| 50 QuicTime::Zero()); | 48 QuicTime::Zero()); |
| 51 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.latest_rtt()); | 49 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.latest_rtt()); |
| 52 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.SmoothedRtt()); | 50 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.smoothed_rtt()); |
| 53 // Verify that effective RTT of zero does not change Smoothed RTT. | 51 // Verify that effective RTT of zero does not change Smoothed RTT. |
| 54 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), | 52 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), |
| 55 QuicTime::Delta::FromMilliseconds(200), | 53 QuicTime::Delta::FromMilliseconds(200), |
| 56 QuicTime::Zero()); | 54 QuicTime::Zero()); |
| 57 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.latest_rtt()); | 55 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.latest_rtt()); |
| 58 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.SmoothedRtt()); | 56 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.smoothed_rtt()); |
| 59 // Verify that large erroneous ack_delay does not change Smoothed RTT. | 57 // Verify that large erroneous ack_delay does not change Smoothed RTT. |
| 60 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), | 58 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), |
| 61 QuicTime::Delta::FromMilliseconds(300), | 59 QuicTime::Delta::FromMilliseconds(300), |
| 62 QuicTime::Zero()); | 60 QuicTime::Zero()); |
| 63 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.latest_rtt()); | 61 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.latest_rtt()); |
| 64 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.SmoothedRtt()); | 62 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.smoothed_rtt()); |
| 65 } | 63 } |
| 66 | 64 |
| 67 TEST_F(RttStatsTest, MinRtt) { | 65 TEST_F(RttStatsTest, MinRtt) { |
| 68 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), | 66 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(200), |
| 69 QuicTime::Delta::Zero(), | 67 QuicTime::Delta::Zero(), |
| 70 QuicTime::Zero()); | 68 QuicTime::Zero()); |
| 71 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.MinRtt()); | 69 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), rtt_stats_.min_rtt()); |
| 72 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), | 70 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(200), |
| 73 rtt_stats_.recent_min_rtt()); | 71 rtt_stats_.recent_min_rtt()); |
| 74 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(10), | 72 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(10), |
| 75 QuicTime::Delta::Zero(), | 73 QuicTime::Delta::Zero(), |
| 76 QuicTime::Zero().Add( | 74 QuicTime::Zero().Add( |
| 77 QuicTime::Delta::FromMilliseconds(10))); | 75 QuicTime::Delta::FromMilliseconds(10))); |
| 78 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 76 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 79 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); | 77 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); |
| 80 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), | 78 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), |
| 81 QuicTime::Delta::Zero(), | 79 QuicTime::Delta::Zero(), |
| 82 QuicTime::Zero().Add( | 80 QuicTime::Zero().Add( |
| 83 QuicTime::Delta::FromMilliseconds(20))); | 81 QuicTime::Delta::FromMilliseconds(20))); |
| 84 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 82 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 85 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); | 83 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); |
| 86 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), | 84 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), |
| 87 QuicTime::Delta::Zero(), | 85 QuicTime::Delta::Zero(), |
| 88 QuicTime::Zero().Add( | 86 QuicTime::Zero().Add( |
| 89 QuicTime::Delta::FromMilliseconds(30))); | 87 QuicTime::Delta::FromMilliseconds(30))); |
| 90 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 88 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 91 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); | 89 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); |
| 92 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), | 90 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), |
| 93 QuicTime::Delta::Zero(), | 91 QuicTime::Delta::Zero(), |
| 94 QuicTime::Zero().Add( | 92 QuicTime::Zero().Add( |
| 95 QuicTime::Delta::FromMilliseconds(40))); | 93 QuicTime::Delta::FromMilliseconds(40))); |
| 96 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 94 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 97 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); | 95 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); |
| 98 // Verify that ack_delay does not go into recording of min_rtt_. | 96 // Verify that ack_delay does not go into recording of min_rtt_. |
| 99 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(7), | 97 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(7), |
| 100 QuicTime::Delta::FromMilliseconds(2), | 98 QuicTime::Delta::FromMilliseconds(2), |
| 101 QuicTime::Zero().Add( | 99 QuicTime::Zero().Add( |
| 102 QuicTime::Delta::FromMilliseconds(50))); | 100 QuicTime::Delta::FromMilliseconds(50))); |
| 103 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.MinRtt()); | 101 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.min_rtt()); |
| 104 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.recent_min_rtt()); | 102 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(7), rtt_stats_.recent_min_rtt()); |
| 105 } | 103 } |
| 106 | 104 |
| 107 TEST_F(RttStatsTest, RecentMinRtt) { | 105 TEST_F(RttStatsTest, RecentMinRtt) { |
| 108 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(10), | 106 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(10), |
| 109 QuicTime::Delta::Zero(), | 107 QuicTime::Delta::Zero(), |
| 110 QuicTime::Zero()); | 108 QuicTime::Zero()); |
| 111 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 109 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 112 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); | 110 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); |
| 113 | 111 |
| 114 rtt_stats_.SampleNewRecentMinRtt(4); | 112 rtt_stats_.SampleNewRecentMinRtt(4); |
| 115 for (int i = 0; i < 3; ++i) { | 113 for (int i = 0; i < 3; ++i) { |
| 116 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), | 114 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), |
| 117 QuicTime::Delta::Zero(), | 115 QuicTime::Delta::Zero(), |
| 118 QuicTime::Zero()); | 116 QuicTime::Zero()); |
| 119 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 117 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 120 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), | 118 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), |
| 121 rtt_stats_.recent_min_rtt()); | 119 rtt_stats_.recent_min_rtt()); |
| 122 } | 120 } |
| 123 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), | 121 rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(50), |
| 124 QuicTime::Delta::Zero(), | 122 QuicTime::Delta::Zero(), |
| 125 QuicTime::Zero()); | 123 QuicTime::Zero()); |
| 126 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 124 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 127 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(50), rtt_stats_.recent_min_rtt()); | 125 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(50), rtt_stats_.recent_min_rtt()); |
| 128 } | 126 } |
| 129 | 127 |
| 130 TEST_F(RttStatsTest, WindowedRecentMinRtt) { | 128 TEST_F(RttStatsTest, WindowedRecentMinRtt) { |
| 131 // Set the window to 99ms, so 25ms is more than a quarter rtt. | 129 // Set the window to 99ms, so 25ms is more than a quarter rtt. |
| 132 rtt_stats_.set_recent_min_rtt_window(QuicTime::Delta::FromMilliseconds(99)); | 130 rtt_stats_.set_recent_min_rtt_window(QuicTime::Delta::FromMilliseconds(99)); |
| 133 | 131 |
| 134 QuicTime now = QuicTime::Zero(); | 132 QuicTime now = QuicTime::Zero(); |
| 135 QuicTime::Delta rtt_sample = QuicTime::Delta::FromMilliseconds(10); | 133 QuicTime::Delta rtt_sample = QuicTime::Delta::FromMilliseconds(10); |
| 136 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); | 134 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); |
| 137 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 135 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 138 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); | 136 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.recent_min_rtt()); |
| 139 | 137 |
| 140 // Gradually increase the rtt samples and ensure the recent_min_rtt starts | 138 // Gradually increase the rtt samples and ensure the recent_min_rtt starts |
| 141 // rising. | 139 // rising. |
| 142 for (int i = 0; i < 8; ++i) { | 140 for (int i = 0; i < 8; ++i) { |
| 143 now = now.Add(QuicTime::Delta::FromMilliseconds(25)); | 141 now = now.Add(QuicTime::Delta::FromMilliseconds(25)); |
| 144 rtt_sample = rtt_sample.Add(QuicTime::Delta::FromMilliseconds(10)); | 142 rtt_sample = rtt_sample.Add(QuicTime::Delta::FromMilliseconds(10)); |
| 145 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); | 143 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); |
| 146 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 144 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 147 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); | 145 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); |
| 148 EXPECT_EQ(rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(10)), | 146 EXPECT_EQ(rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(10)), |
| 149 RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); | 147 RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); |
| 150 if (i < 3) { | 148 if (i < 3) { |
| 151 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), | 149 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), |
| 152 rtt_stats_.recent_min_rtt()); | 150 rtt_stats_.recent_min_rtt()); |
| 153 } else if (i < 5) { | 151 } else if (i < 5) { |
| 154 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(30), | 152 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(30), |
| 155 rtt_stats_.recent_min_rtt()); | 153 rtt_stats_.recent_min_rtt()); |
| 156 } else if (i < 7) { | 154 } else if (i < 7) { |
| 157 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(50), | 155 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(50), |
| 158 rtt_stats_.recent_min_rtt()); | 156 rtt_stats_.recent_min_rtt()); |
| 159 } else { | 157 } else { |
| 160 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(70), | 158 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(70), |
| 161 rtt_stats_.recent_min_rtt()); | 159 rtt_stats_.recent_min_rtt()); |
| 162 } | 160 } |
| 163 } | 161 } |
| 164 | 162 |
| 165 // A new quarter rtt low sets that, but nothing else. | 163 // A new quarter rtt low sets that, but nothing else. |
| 166 rtt_sample = rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(5)); | 164 rtt_sample = rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(5)); |
| 167 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); | 165 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); |
| 168 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 166 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 169 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); | 167 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); |
| 170 EXPECT_EQ(rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(5)), | 168 EXPECT_EQ(rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(5)), |
| 171 RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); | 169 RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); |
| 172 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(70), | 170 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(70), |
| 173 rtt_stats_.recent_min_rtt()); | 171 rtt_stats_.recent_min_rtt()); |
| 174 | 172 |
| 175 // A new half rtt low sets that and the quarter rtt low. | 173 // A new half rtt low sets that and the quarter rtt low. |
| 176 rtt_sample = rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(15)); | 174 rtt_sample = rtt_sample.Subtract(QuicTime::Delta::FromMilliseconds(15)); |
| 177 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); | 175 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); |
| 178 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 176 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 179 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); | 177 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); |
| 180 EXPECT_EQ(rtt_sample, RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); | 178 EXPECT_EQ(rtt_sample, RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); |
| 181 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(70), | 179 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(70), |
| 182 rtt_stats_.recent_min_rtt()); | 180 rtt_stats_.recent_min_rtt()); |
| 183 | 181 |
| 184 // A new full window loss sets the recent_min_rtt, but not min_rtt. | 182 // A new full window loss sets the recent_min_rtt, but not min_rtt. |
| 185 rtt_sample = QuicTime::Delta::FromMilliseconds(65); | 183 rtt_sample = QuicTime::Delta::FromMilliseconds(65); |
| 186 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); | 184 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); |
| 187 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.MinRtt()); | 185 EXPECT_EQ(QuicTime::Delta::FromMilliseconds(10), rtt_stats_.min_rtt()); |
| 188 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); | 186 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); |
| 189 EXPECT_EQ(rtt_sample, RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); | 187 EXPECT_EQ(rtt_sample, RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); |
| 190 EXPECT_EQ(rtt_sample, rtt_stats_.recent_min_rtt()); | 188 EXPECT_EQ(rtt_sample, rtt_stats_.recent_min_rtt()); |
| 191 | 189 |
| 192 // A new all time low sets both the min_rtt and the recent_min_rtt. | 190 // A new all time low sets both the min_rtt and the recent_min_rtt. |
| 193 rtt_sample = QuicTime::Delta::FromMilliseconds(5); | 191 rtt_sample = QuicTime::Delta::FromMilliseconds(5); |
| 194 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); | 192 rtt_stats_.UpdateRtt(rtt_sample, QuicTime::Delta::Zero(), now); |
| 195 | 193 |
| 196 EXPECT_EQ(rtt_sample, rtt_stats_.MinRtt()); | 194 EXPECT_EQ(rtt_sample, rtt_stats_.min_rtt()); |
| 197 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); | 195 EXPECT_EQ(rtt_sample, RttStatsPeer::GetQuarterWindowRtt(&rtt_stats_)); |
| 198 EXPECT_EQ(rtt_sample, RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); | 196 EXPECT_EQ(rtt_sample, RttStatsPeer::GetHalfWindowRtt(&rtt_stats_)); |
| 199 EXPECT_EQ(rtt_sample, rtt_stats_.recent_min_rtt()); | 197 EXPECT_EQ(rtt_sample, rtt_stats_.recent_min_rtt()); |
| 200 } | 198 } |
| 201 | 199 |
| 202 TEST_F(RttStatsTest, ExpireSmoothedMetrics) { | 200 TEST_F(RttStatsTest, ExpireSmoothedMetrics) { |
| 203 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); | 201 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); |
| 204 rtt_stats_.UpdateRtt(initial_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 202 rtt_stats_.UpdateRtt(initial_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 205 EXPECT_EQ(initial_rtt, rtt_stats_.MinRtt()); | 203 EXPECT_EQ(initial_rtt, rtt_stats_.min_rtt()); |
| 206 EXPECT_EQ(initial_rtt, rtt_stats_.recent_min_rtt()); | 204 EXPECT_EQ(initial_rtt, rtt_stats_.recent_min_rtt()); |
| 207 EXPECT_EQ(initial_rtt, rtt_stats_.SmoothedRtt()); | 205 EXPECT_EQ(initial_rtt, rtt_stats_.smoothed_rtt()); |
| 208 | 206 |
| 209 EXPECT_EQ(initial_rtt.Multiply(0.5), rtt_stats_.mean_deviation()); | 207 EXPECT_EQ(initial_rtt.Multiply(0.5), rtt_stats_.mean_deviation()); |
| 210 | 208 |
| 211 // Update once with a 20ms RTT. | 209 // Update once with a 20ms RTT. |
| 212 QuicTime::Delta doubled_rtt = initial_rtt.Multiply(2); | 210 QuicTime::Delta doubled_rtt = initial_rtt.Multiply(2); |
| 213 rtt_stats_.UpdateRtt(doubled_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 211 rtt_stats_.UpdateRtt(doubled_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 214 EXPECT_EQ(initial_rtt.Multiply(1.125), rtt_stats_.SmoothedRtt()); | 212 EXPECT_EQ(initial_rtt.Multiply(1.125), rtt_stats_.smoothed_rtt()); |
| 215 | 213 |
| 216 // Expire the smoothed metrics, increasing smoothed rtt and mean deviation. | 214 // Expire the smoothed metrics, increasing smoothed rtt and mean deviation. |
| 217 rtt_stats_.ExpireSmoothedMetrics(); | 215 rtt_stats_.ExpireSmoothedMetrics(); |
| 218 EXPECT_EQ(doubled_rtt, rtt_stats_.SmoothedRtt()); | 216 EXPECT_EQ(doubled_rtt, rtt_stats_.smoothed_rtt()); |
| 219 EXPECT_EQ(initial_rtt.Multiply(0.875), rtt_stats_.mean_deviation()); | 217 EXPECT_EQ(initial_rtt.Multiply(0.875), rtt_stats_.mean_deviation()); |
| 220 | 218 |
| 221 // Now go back down to 5ms and expire the smoothed metrics, and ensure the | 219 // Now go back down to 5ms and expire the smoothed metrics, and ensure the |
| 222 // mean deviation increases to 15ms. | 220 // mean deviation increases to 15ms. |
| 223 QuicTime::Delta half_rtt = initial_rtt.Multiply(0.5); | 221 QuicTime::Delta half_rtt = initial_rtt.Multiply(0.5); |
| 224 rtt_stats_.UpdateRtt(half_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 222 rtt_stats_.UpdateRtt(half_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 225 EXPECT_GT(doubled_rtt, rtt_stats_.SmoothedRtt()); | 223 EXPECT_GT(doubled_rtt, rtt_stats_.smoothed_rtt()); |
| 226 EXPECT_LT(initial_rtt, rtt_stats_.mean_deviation()); | 224 EXPECT_LT(initial_rtt, rtt_stats_.mean_deviation()); |
| 227 } | 225 } |
| 228 | 226 |
| 229 TEST_F(RttStatsTest, UpdateRttWithBadSendDeltas) { | 227 TEST_F(RttStatsTest, UpdateRttWithBadSendDeltas) { |
| 230 // Make sure we ignore bad RTTs. | 228 // Make sure we ignore bad RTTs. |
| 231 ScopedMockLog log; | 229 ScopedMockLog log; |
| 232 | 230 |
| 233 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); | 231 QuicTime::Delta initial_rtt = QuicTime::Delta::FromMilliseconds(10); |
| 234 rtt_stats_.UpdateRtt(initial_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); | 232 rtt_stats_.UpdateRtt(initial_rtt, QuicTime::Delta::Zero(), QuicTime::Zero()); |
| 235 EXPECT_EQ(initial_rtt, rtt_stats_.MinRtt()); | 233 EXPECT_EQ(initial_rtt, rtt_stats_.min_rtt()); |
| 236 EXPECT_EQ(initial_rtt, rtt_stats_.recent_min_rtt()); | 234 EXPECT_EQ(initial_rtt, rtt_stats_.recent_min_rtt()); |
| 237 EXPECT_EQ(initial_rtt, rtt_stats_.SmoothedRtt()); | 235 EXPECT_EQ(initial_rtt, rtt_stats_.smoothed_rtt()); |
| 238 | 236 |
| 239 vector<QuicTime::Delta> bad_send_deltas; | 237 vector<QuicTime::Delta> bad_send_deltas; |
| 240 bad_send_deltas.push_back(QuicTime::Delta::Zero()); | 238 bad_send_deltas.push_back(QuicTime::Delta::Zero()); |
| 241 bad_send_deltas.push_back(QuicTime::Delta::Infinite()); | 239 bad_send_deltas.push_back(QuicTime::Delta::Infinite()); |
| 242 bad_send_deltas.push_back(QuicTime::Delta::FromMicroseconds(-1000)); | 240 bad_send_deltas.push_back(QuicTime::Delta::FromMicroseconds(-1000)); |
| 243 log.StartCapturingLogs(); | 241 log.StartCapturingLogs(); |
| 244 | 242 |
| 245 for (QuicTime::Delta bad_send_delta : bad_send_deltas) { | 243 for (QuicTime::Delta bad_send_delta : bad_send_deltas) { |
| 246 SCOPED_TRACE(Message() << "bad_send_delta = " | 244 SCOPED_TRACE(Message() << "bad_send_delta = " |
| 247 << bad_send_delta.ToMicroseconds()); | 245 << bad_send_delta.ToMicroseconds()); |
| 248 EXPECT_CALL(log, Log(LOG_WARNING, _, _, _, HasSubstr("Ignoring"))); | 246 EXPECT_CALL(log, Log(LOG_WARNING, _, _, _, HasSubstr("Ignoring"))); |
| 249 rtt_stats_.UpdateRtt(bad_send_delta, | 247 rtt_stats_.UpdateRtt(bad_send_delta, |
| 250 QuicTime::Delta::Zero(), | 248 QuicTime::Delta::Zero(), |
| 251 QuicTime::Zero()); | 249 QuicTime::Zero()); |
| 252 EXPECT_EQ(initial_rtt, rtt_stats_.MinRtt()); | 250 EXPECT_EQ(initial_rtt, rtt_stats_.min_rtt()); |
| 253 EXPECT_EQ(initial_rtt, rtt_stats_.recent_min_rtt()); | 251 EXPECT_EQ(initial_rtt, rtt_stats_.recent_min_rtt()); |
| 254 EXPECT_EQ(initial_rtt, rtt_stats_.SmoothedRtt()); | 252 EXPECT_EQ(initial_rtt, rtt_stats_.smoothed_rtt()); |
| 255 } | 253 } |
| 256 } | 254 } |
| 257 | 255 |
| 258 } // namespace test | 256 } // namespace test |
| 259 } // namespace net | 257 } // namespace net |
| OLD | NEW |