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 namespace net { | 7 namespace net { |
8 | 8 |
9 namespace { | 9 namespace { |
10 | 10 |
11 // Default initial rtt used before any samples are received. | 11 // Default initial rtt used before any samples are received. |
12 const int kInitialRttMs = 100; | 12 const int kInitialRttMs = 100; |
13 const float kAlpha = 0.125f; | 13 const float kAlpha = 0.125f; |
14 const float kOneMinusAlpha = (1 - kAlpha); | 14 const float kOneMinusAlpha = (1 - kAlpha); |
15 const float kBeta = 0.25f; | 15 const float kBeta = 0.25f; |
16 const float kOneMinusBeta = (1 - kBeta); | 16 const float kOneMinusBeta = (1 - kBeta); |
17 const float kHalfWindow = 0.5f; | 17 const float kHalfWindow = 0.5f; |
18 const float kQuarterWindow = 0.25f; | 18 const float kQuarterWindow = 0.25f; |
19 | 19 |
20 } // namespace | 20 } // namespace |
21 | 21 |
22 RttStats::RttStats() | 22 RttStats::RttStats() |
23 : latest_rtt_(QuicTime::Delta::Zero()), | 23 : latest_rtt_(QuicTime::Delta::Zero()), |
24 min_rtt_(QuicTime::Delta::Zero()), | 24 min_rtt_(QuicTime::Delta::Zero()), |
25 smoothed_rtt_(QuicTime::Delta::Zero()), | 25 smoothed_rtt_(QuicTime::Delta::Zero()), |
26 mean_deviation_(QuicTime::Delta::Zero()), | 26 mean_deviation_(QuicTime::Delta::Zero()), |
27 initial_rtt_us_(kInitialRttMs * base::Time::kMicrosecondsPerMillisecond), | 27 initial_rtt_us_(kInitialRttMs * base::Time::kMicrosecondsPerMillisecond), |
28 num_min_rtt_samples_remaining_(0), | 28 num_min_rtt_samples_remaining_(0), |
29 recent_min_rtt_window_(QuicTime::Delta::Zero()) { } | 29 recent_min_rtt_window_(QuicTime::Delta::Zero()) { |
| 30 } |
30 | 31 |
31 bool RttStats::HasUpdates() const { | 32 bool RttStats::HasUpdates() const { |
32 return !smoothed_rtt_.IsZero(); | 33 return !smoothed_rtt_.IsZero(); |
33 } | 34 } |
34 | 35 |
35 void RttStats::SampleNewRecentMinRtt(uint32 num_samples) { | 36 void RttStats::SampleNewRecentMinRtt(uint32 num_samples) { |
36 num_min_rtt_samples_remaining_ = num_samples; | 37 num_min_rtt_samples_remaining_ = num_samples; |
37 new_min_rtt_ = RttSample(); | 38 new_min_rtt_ = RttSample(); |
38 } | 39 } |
39 | 40 |
(...skipping 21 matching lines...) Expand all Loading... |
61 | 62 |
62 latest_rtt_ = rtt_sample; | 63 latest_rtt_ = rtt_sample; |
63 // First time call or link delay decreases. | 64 // First time call or link delay decreases. |
64 if (min_rtt_.IsZero() || min_rtt_ > rtt_sample) { | 65 if (min_rtt_.IsZero() || min_rtt_ > rtt_sample) { |
65 min_rtt_ = rtt_sample; | 66 min_rtt_ = rtt_sample; |
66 } | 67 } |
67 UpdateRecentMinRtt(rtt_sample, now); | 68 UpdateRecentMinRtt(rtt_sample, now); |
68 // First time call. | 69 // First time call. |
69 if (!HasUpdates()) { | 70 if (!HasUpdates()) { |
70 smoothed_rtt_ = rtt_sample; | 71 smoothed_rtt_ = rtt_sample; |
71 mean_deviation_ = QuicTime::Delta::FromMicroseconds( | 72 mean_deviation_ = |
72 rtt_sample.ToMicroseconds() / 2); | 73 QuicTime::Delta::FromMicroseconds(rtt_sample.ToMicroseconds() / 2); |
73 } else { | 74 } else { |
74 mean_deviation_ = QuicTime::Delta::FromMicroseconds( | 75 mean_deviation_ = QuicTime::Delta::FromMicroseconds( |
75 kOneMinusBeta * mean_deviation_.ToMicroseconds() + | 76 kOneMinusBeta * mean_deviation_.ToMicroseconds() + |
76 kBeta * std::abs(smoothed_rtt_.Subtract(rtt_sample).ToMicroseconds())); | 77 kBeta * std::abs(smoothed_rtt_.Subtract(rtt_sample).ToMicroseconds())); |
77 smoothed_rtt_ = smoothed_rtt_.Multiply(kOneMinusAlpha).Add( | 78 smoothed_rtt_ = |
78 rtt_sample.Multiply(kAlpha)); | 79 smoothed_rtt_.Multiply(kOneMinusAlpha).Add(rtt_sample.Multiply(kAlpha)); |
79 DVLOG(1) << "Cubic; smoothed_rtt(us):" << smoothed_rtt_.ToMicroseconds() | 80 DVLOG(1) << "Cubic; smoothed_rtt(us):" << smoothed_rtt_.ToMicroseconds() |
80 << " mean_deviation(us):" << mean_deviation_.ToMicroseconds(); | 81 << " mean_deviation(us):" << mean_deviation_.ToMicroseconds(); |
81 } | 82 } |
82 } | 83 } |
83 | 84 |
84 void RttStats::UpdateRecentMinRtt(QuicTime::Delta rtt_sample, QuicTime now) { | 85 void RttStats::UpdateRecentMinRtt(QuicTime::Delta rtt_sample, QuicTime now) { |
85 // Recent min_rtt update. | 86 // Recent min_rtt update. |
86 if (num_min_rtt_samples_remaining_ > 0) { | 87 if (num_min_rtt_samples_remaining_ > 0) { |
87 --num_min_rtt_samples_remaining_; | 88 --num_min_rtt_samples_remaining_; |
88 if (new_min_rtt_.rtt.IsZero() || rtt_sample <= new_min_rtt_.rtt) { | 89 if (new_min_rtt_.rtt.IsZero() || rtt_sample <= new_min_rtt_.rtt) { |
(...skipping 14 matching lines...) Expand all Loading... |
103 } else if (rtt_sample <= quarter_window_rtt_.rtt) { | 104 } else if (rtt_sample <= quarter_window_rtt_.rtt) { |
104 quarter_window_rtt_ = RttSample(rtt_sample, now); | 105 quarter_window_rtt_ = RttSample(rtt_sample, now); |
105 } | 106 } |
106 | 107 |
107 // Expire old min rtt samples. | 108 // Expire old min rtt samples. |
108 if (recent_min_rtt_.time < now.Subtract(recent_min_rtt_window_)) { | 109 if (recent_min_rtt_.time < now.Subtract(recent_min_rtt_window_)) { |
109 recent_min_rtt_ = half_window_rtt_; | 110 recent_min_rtt_ = half_window_rtt_; |
110 half_window_rtt_ = quarter_window_rtt_; | 111 half_window_rtt_ = quarter_window_rtt_; |
111 quarter_window_rtt_ = RttSample(rtt_sample, now); | 112 quarter_window_rtt_ = RttSample(rtt_sample, now); |
112 } else if (half_window_rtt_.time < | 113 } else if (half_window_rtt_.time < |
113 now.Subtract(recent_min_rtt_window_.Multiply(kHalfWindow))) { | 114 now.Subtract(recent_min_rtt_window_.Multiply(kHalfWindow))) { |
114 half_window_rtt_ = quarter_window_rtt_; | 115 half_window_rtt_ = quarter_window_rtt_; |
115 quarter_window_rtt_ = RttSample(rtt_sample, now); | 116 quarter_window_rtt_ = RttSample(rtt_sample, now); |
116 } else if (quarter_window_rtt_.time < | 117 } else if (quarter_window_rtt_.time < |
117 now.Subtract(recent_min_rtt_window_.Multiply(kQuarterWindow))) { | 118 now.Subtract(recent_min_rtt_window_.Multiply(kQuarterWindow))) { |
118 quarter_window_rtt_ = RttSample(rtt_sample, now); | 119 quarter_window_rtt_ = RttSample(rtt_sample, now); |
119 } | 120 } |
120 } | 121 } |
121 | 122 |
122 QuicTime::Delta RttStats::SmoothedRtt() const { | 123 QuicTime::Delta RttStats::SmoothedRtt() const { |
123 if (!HasUpdates()) { | 124 if (!HasUpdates()) { |
124 return QuicTime::Delta::FromMicroseconds(initial_rtt_us_); | 125 return QuicTime::Delta::FromMicroseconds(initial_rtt_us_); |
125 } | 126 } |
126 return smoothed_rtt_; | 127 return smoothed_rtt_; |
127 } | 128 } |
128 | 129 |
129 } // namespace net | 130 } // namespace net |
OLD | NEW |