ProbingEstimator: Erase history based on time threshold

webrtc/modules/congestion_controller/delay_based_bwe.cc

 /*
  *  Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 74 matching lines @@
     if (last_seen_packet_ms_ == -1 ||
         now_ms - last_seen_packet_ms_ > kStreamTimeOutMs) {
       inter_arrival_.reset(new InterArrival(
           (kTimestampGroupLengthMs << kInterArrivalShift) / 1000,
           kTimestampToMs, true));
       estimator_.reset(new OveruseEstimator(OverUseDetectorOptions()));
     }
     last_seen_packet_ms_ = now_ms;
 
     if (info.probe_cluster_id != PacketInfo::kNotAProbe) {
-      ProbingResult probe_result =
-          probe_bitrate_estimator_.PacketFeedback(info);
-      if (probe_result.valid()) {
-        remote_rate_.SetEstimate(probe_result.bps, probe_result.timestamp);
+      int bps = probe_bitrate_estimator_.HandleProbeAndEstimateBitrate(info);
+      if (bps > 0) {
+        remote_rate_.SetEstimate(bps, info.arrival_time_ms);
         update_estimate = true;
       }
     }
 
     uint32_t send_time_24bits =
         static_cast<uint32_t>(((static_cast<uint64_t>(info.send_time_ms)
                                 << kAbsSendTimeFraction) +
                                500) /
                               1000) &
         0x00FFFFFF;
@@ skipping 79 matching lines @@
   return true;
 }
 
 void DelayBasedBwe::SetMinBitrate(int min_bitrate_bps) {
   // Called from both the configuration thread and the network thread. Shouldn't
   // be called from the network thread in the future.
   rtc::CritScope lock(&crit_);
   remote_rate_.SetMinBitrate(min_bitrate_bps);
 }
 }  // namespace webrtc