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 |