Index: webrtc/base/rate_statistics.cc |
diff --git a/webrtc/base/rate_statistics.cc b/webrtc/base/rate_statistics.cc |
deleted file mode 100644 |
index 3122dbb3e690611bbaf80b39711e9c336d74b60a..0000000000000000000000000000000000000000 |
--- a/webrtc/base/rate_statistics.cc |
+++ /dev/null |
@@ -1,121 +0,0 @@ |
-/* |
- * Copyright (c) 2013 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. |
- */ |
- |
-#include "webrtc/base/rate_statistics.h" |
- |
-#include <algorithm> |
- |
-#include "webrtc/base/checks.h" |
- |
-namespace webrtc { |
- |
-RateStatistics::RateStatistics(int64_t window_size_ms, float scale) |
- : buckets_(new Bucket[window_size_ms]()), |
- accumulated_count_(0), |
- num_samples_(0), |
- oldest_time_(-window_size_ms), |
- oldest_index_(0), |
- scale_(scale), |
- max_window_size_ms_(window_size_ms), |
- current_window_size_ms_(max_window_size_ms_) {} |
- |
-RateStatistics::~RateStatistics() {} |
- |
-void RateStatistics::Reset() { |
- accumulated_count_ = 0; |
- num_samples_ = 0; |
- oldest_time_ = -max_window_size_ms_; |
- oldest_index_ = 0; |
- current_window_size_ms_ = max_window_size_ms_; |
- for (int64_t i = 0; i < max_window_size_ms_; i++) |
- buckets_[i] = Bucket(); |
-} |
- |
-void RateStatistics::Update(size_t count, int64_t now_ms) { |
- if (now_ms < oldest_time_) { |
- // Too old data is ignored. |
- return; |
- } |
- |
- EraseOld(now_ms); |
- |
- // First ever sample, reset window to start now. |
- if (!IsInitialized()) |
- oldest_time_ = now_ms; |
- |
- uint32_t now_offset = static_cast<uint32_t>(now_ms - oldest_time_); |
- RTC_DCHECK_LT(now_offset, max_window_size_ms_); |
- uint32_t index = oldest_index_ + now_offset; |
- if (index >= max_window_size_ms_) |
- index -= max_window_size_ms_; |
- buckets_[index].sum += count; |
- ++buckets_[index].samples; |
- accumulated_count_ += count; |
- ++num_samples_; |
-} |
- |
-rtc::Optional<uint32_t> RateStatistics::Rate(int64_t now_ms) const { |
- // Yeah, this const_cast ain't pretty, but the alternative is to declare most |
- // of the members as mutable... |
- const_cast<RateStatistics*>(this)->EraseOld(now_ms); |
- |
- // If window is a single bucket or there is only one sample in a data set that |
- // has not grown to the full window size, treat this as rate unavailable. |
- int64_t active_window_size = now_ms - oldest_time_ + 1; |
- if (num_samples_ == 0 || active_window_size <= 1 || |
- (num_samples_ <= 1 && active_window_size < current_window_size_ms_)) { |
- return rtc::Optional<uint32_t>(); |
- } |
- |
- float scale = scale_ / active_window_size; |
- return rtc::Optional<uint32_t>( |
- static_cast<uint32_t>(accumulated_count_ * scale + 0.5f)); |
-} |
- |
-void RateStatistics::EraseOld(int64_t now_ms) { |
- if (!IsInitialized()) |
- return; |
- |
- // New oldest time that is included in data set. |
- int64_t new_oldest_time = now_ms - current_window_size_ms_ + 1; |
- |
- // New oldest time is older than the current one, no need to cull data. |
- if (new_oldest_time <= oldest_time_) |
- return; |
- |
- // Loop over buckets and remove too old data points. |
- while (num_samples_ > 0 && oldest_time_ < new_oldest_time) { |
- const Bucket& oldest_bucket = buckets_[oldest_index_]; |
- RTC_DCHECK_GE(accumulated_count_, oldest_bucket.sum); |
- RTC_DCHECK_GE(num_samples_, oldest_bucket.samples); |
- accumulated_count_ -= oldest_bucket.sum; |
- num_samples_ -= oldest_bucket.samples; |
- buckets_[oldest_index_] = Bucket(); |
- if (++oldest_index_ >= max_window_size_ms_) |
- oldest_index_ = 0; |
- ++oldest_time_; |
- } |
- oldest_time_ = new_oldest_time; |
-} |
- |
-bool RateStatistics::SetWindowSize(int64_t window_size_ms, int64_t now_ms) { |
- if (window_size_ms <= 0 || window_size_ms > max_window_size_ms_) |
- return false; |
- |
- current_window_size_ms_ = window_size_ms; |
- EraseOld(now_ms); |
- return true; |
-} |
- |
-bool RateStatistics::IsInitialized() const { |
- return oldest_time_ != -max_window_size_ms_; |
-} |
- |
-} // namespace webrtc |