Added implementations for entering/exiting STARTUP, DRAIN, PROBE_BW, PROBE_RTT modes, also updated M

webrtc/modules/remote_bitrate_estimator/test/estimators/max_bandwidth_filter.cc

Index: webrtc/modules/remote_bitrate_estimator/test/estimators/max_bandwidth_filter.cc
diff --git a/webrtc/modules/remote_bitrate_estimator/test/estimators/max_bandwidth_filter.cc b/webrtc/modules/remote_bitrate_estimator/test/estimators/max_bandwidth_filter.cc
index 53fb59cbb080dfbb7d027453e7c690b1b5309eb1..333c2c4d8e19c4e46acf290f06512e4bcb69e5c1 100644
--- a/webrtc/modules/remote_bitrate_estimator/test/estimators/max_bandwidth_filter.cc
+++ b/webrtc/modules/remote_bitrate_estimator/test/estimators/max_bandwidth_filter.cc
@@ -16,22 +16,50 @@ namespace testing {
 namespace bwe {
 MaxBandwidthFilter::MaxBandwidthFilter()
     : bandwidth_last_round_bytes_per_ms_(0),
-      round_bandwidth_updated_(0),
-      max_bandwidth_estimate_bytes_per_ms_(0),
+      max_bandwidth_estimate_bps_(0),
       rounds_without_growth_(0) {}
 
 MaxBandwidthFilter::~MaxBandwidthFilter() {}
 
-// Rounds are units for packets rtt_time, after packet has been acknowledged,
-// one round has passed from its send time.
-void MaxBandwidthFilter::AddBandwidthSample(int64_t sample_bytes_per_ms,
+// For detailed explanation about implementing bandwidth filter this way visit
+// "Bbr design" doc. Rounds are units for packets rtt_time, after packet has

[philipel, 2017/07/27 09:15:28]

Please update the design doc.

[gnish1, 2017/07/27 11:24:26]

Done.

+// been acknowledged, one round has passed from its send time.
+void MaxBandwidthFilter::AddBandwidthSample(int64_t sample_bps,
                                             int64_t round,
                                             size_t filter_size_round) {
-  if (round - round_bandwidth_updated_ >= filter_size_round ||
-      sample_bytes_per_ms >= max_bandwidth_estimate_bytes_per_ms_) {
-    max_bandwidth_estimate_bytes_per_ms_ = sample_bytes_per_ms;
-    round_bandwidth_updated_ = round;
+  if (bandwidth_samples_[0].first == 0 ||
+      sample_bps >= bandwidth_samples_[0].first ||
+      round - bandwidth_samples_[2].second >= filter_size_round)
+    bandwidth_samples_[0] = bandwidth_samples_[1] =
+        bandwidth_samples_[2] = {sample_bps, round};
+  if (sample_bps >= bandwidth_samples_[1].first) {
+    bandwidth_samples_[1] = {sample_bps, round};
+    bandwidth_samples_[2] = bandwidth_samples_[1];
+  } else {
+    if (sample_bps >= bandwidth_samples_[1].first)
+      bandwidth_samples_[2] = {sample_bps, round};
   }
+  if (round - bandwidth_samples_[0].second >= filter_size_round) {
+    bandwidth_samples_[0] = bandwidth_samples_[1];
+    bandwidth_samples_[1] = bandwidth_samples_[2];
+    bandwidth_samples_[2] = {sample_bps, round};
+    if (round - bandwidth_samples_[0].second >= filter_size_round) {
+      bandwidth_samples_[0] = bandwidth_samples_[1];
+      bandwidth_samples_[1] = bandwidth_samples_[2];
+    }
+    max_bandwidth_estimate_bps_ = bandwidth_samples_[0].first;
+    return;
+  }
+  if (bandwidth_samples_[1].first == bandwidth_samples_[0].first &&
+      round - bandwidth_samples_[1].second > filter_size_round / 4) {
+    bandwidth_samples_[2] = bandwidth_samples_[1] = {sample_bps, round};
+    max_bandwidth_estimate_bps_ = bandwidth_samples_[0].first;
+    return;
+  }
+  if (bandwidth_samples_[2].first == bandwidth_samples_[1].first &&
+      round - bandwidth_samples_[2].second > filter_size_round / 2)
+    bandwidth_samples_[2] = {sample_bps, round};
+  max_bandwidth_estimate_bps_ = bandwidth_samples_[0].first;
 }
 
 bool MaxBandwidthFilter::FullBandwidthReached(float growth_target,
@@ -40,8 +68,8 @@ bool MaxBandwidthFilter::FullBandwidthReached(float growth_target,
   // found and full bandwidth is not reached.
   int64_t minimal_bandwidth =
       bandwidth_last_round_bytes_per_ms_ * growth_target;
-  if (max_bandwidth_estimate_bytes_per_ms_ >= minimal_bandwidth) {
-    bandwidth_last_round_bytes_per_ms_ = max_bandwidth_estimate_bytes_per_ms_;
+  if (max_bandwidth_estimate_bps_ >= minimal_bandwidth) {
+    bandwidth_last_round_bytes_per_ms_ = max_bandwidth_estimate_bps_;
     rounds_without_growth_ = 0;
     return false;
   }