OLD | NEW |
(Empty) | |
| 1 /* |
| 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
| 3 * |
| 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ |
| 10 #ifndef WEBRTC_MODULES_CONGESTION_CONTROLLER_TRENDLINE_ESTIMATOR_H_ |
| 11 #define WEBRTC_MODULES_CONGESTION_CONTROLLER_TRENDLINE_ESTIMATOR_H_ |
| 12 |
| 13 #include <list> |
| 14 #include <utility> |
| 15 |
| 16 #include "webrtc/base/constructormagic.h" |
| 17 #include "webrtc/common_types.h" |
| 18 |
| 19 namespace webrtc { |
| 20 |
| 21 class TrendlineEstimator { |
| 22 public: |
| 23 // |window_size| is the number of points required to compute a trend line. |
| 24 // |smoothing_coef| controls how much we smooth out the delay before fitting |
| 25 // the trend line. |threshold_gain| is used to scale the trendline slope for |
| 26 // comparison to the old threshold. Once the old estimator has been removed |
| 27 // (or the thresholds been merged into the estimators), we can just set the |
| 28 // threshold instead of setting a gain. |
| 29 TrendlineEstimator(size_t window_size, |
| 30 double smoothing_coef, |
| 31 double threshold_gain); |
| 32 ~TrendlineEstimator(); |
| 33 |
| 34 // Update the estimator with a new sample. The deltas should represent deltas |
| 35 // between timestamp groups as defined by the InterArrival class. |
| 36 void Update(double recv_delta_ms, double send_delta_ms, double now_ms); |
| 37 |
| 38 // Returns the estimated trend k multiplied by some gain. |
| 39 // 0 < k < 1 -> the delay increases, queues are filling up |
| 40 // k == 0 -> the delay does not change |
| 41 // k < 0 -> the delay decreases, queues are being emptied |
| 42 double trendline_slope() const { return trendline_ * threshold_gain_; } |
| 43 |
| 44 // Returns the number of deltas which the current estimator state is based on. |
| 45 unsigned int num_of_deltas() const { return num_of_deltas_; } |
| 46 |
| 47 private: |
| 48 // Parameters. |
| 49 const size_t window_size_; |
| 50 const double smoothing_coef_; |
| 51 const double threshold_gain_; |
| 52 // Used by the existing threshold. |
| 53 unsigned int num_of_deltas_; |
| 54 // Exponential backoff filtering. |
| 55 double accumulated_delay_; |
| 56 double smoothed_delay_; |
| 57 // Linear least squares regression. |
| 58 std::list<std::pair<double, double>> delay_hist_; |
| 59 double trendline_; |
| 60 |
| 61 RTC_DISALLOW_COPY_AND_ASSIGN(TrendlineEstimator); |
| 62 }; |
| 63 } // namespace webrtc |
| 64 |
| 65 #endif // WEBRTC_MODULES_CONGESTION_CONTROLLER_TRENDLINE_ESTIMATOR_H_ |
OLD | NEW |