OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
11 #include "webrtc/modules/audio_coding/neteq/statistics_calculator.h" | 11 #include "webrtc/modules/audio_coding/neteq/statistics_calculator.h" |
12 | 12 |
13 #include <assert.h> | 13 #include <assert.h> |
14 #include <string.h> // memset | 14 #include <string.h> // memset |
15 #include <algorithm> | 15 #include <algorithm> |
16 | 16 |
17 #include "webrtc/base/checks.h" | 17 #include "webrtc/base/checks.h" |
18 #include "webrtc/base/safe_conversions.h" | 18 #include "webrtc/base/safe_conversions.h" |
19 #include "webrtc/modules/audio_coding/neteq/decision_logic.h" | 19 #include "webrtc/modules/audio_coding/neteq/decision_logic.h" |
20 #include "webrtc/modules/audio_coding/neteq/delay_manager.h" | 20 #include "webrtc/modules/audio_coding/neteq/delay_manager.h" |
21 #include "webrtc/system_wrappers/interface/metrics.h" | 21 #include "webrtc/system_wrappers/interface/metrics.h" |
22 | 22 |
23 namespace webrtc { | 23 namespace webrtc { |
24 | 24 |
25 // Allocating the static const so that it can be passed by reference to DCHECK. | 25 // Allocating the static const so that it can be passed by reference to |
| 26 // RTC_DCHECK. |
26 const size_t StatisticsCalculator::kLenWaitingTimes; | 27 const size_t StatisticsCalculator::kLenWaitingTimes; |
27 | 28 |
28 StatisticsCalculator::PeriodicUmaLogger::PeriodicUmaLogger( | 29 StatisticsCalculator::PeriodicUmaLogger::PeriodicUmaLogger( |
29 const std::string& uma_name, | 30 const std::string& uma_name, |
30 int report_interval_ms, | 31 int report_interval_ms, |
31 int max_value) | 32 int max_value) |
32 : uma_name_(uma_name), | 33 : uma_name_(uma_name), |
33 report_interval_ms_(report_interval_ms), | 34 report_interval_ms_(report_interval_ms), |
34 max_value_(max_value), | 35 max_value_(max_value), |
35 timer_(0) { | 36 timer_(0) { |
36 } | 37 } |
37 | 38 |
38 StatisticsCalculator::PeriodicUmaLogger::~PeriodicUmaLogger() = default; | 39 StatisticsCalculator::PeriodicUmaLogger::~PeriodicUmaLogger() = default; |
39 | 40 |
40 void StatisticsCalculator::PeriodicUmaLogger::AdvanceClock(int step_ms) { | 41 void StatisticsCalculator::PeriodicUmaLogger::AdvanceClock(int step_ms) { |
41 timer_ += step_ms; | 42 timer_ += step_ms; |
42 if (timer_ < report_interval_ms_) { | 43 if (timer_ < report_interval_ms_) { |
43 return; | 44 return; |
44 } | 45 } |
45 LogToUma(Metric()); | 46 LogToUma(Metric()); |
46 Reset(); | 47 Reset(); |
47 timer_ -= report_interval_ms_; | 48 timer_ -= report_interval_ms_; |
48 DCHECK_GE(timer_, 0); | 49 RTC_DCHECK_GE(timer_, 0); |
49 } | 50 } |
50 | 51 |
51 void StatisticsCalculator::PeriodicUmaLogger::LogToUma(int value) const { | 52 void StatisticsCalculator::PeriodicUmaLogger::LogToUma(int value) const { |
52 RTC_HISTOGRAM_COUNTS(uma_name_, value, 1, max_value_, 50); | 53 RTC_HISTOGRAM_COUNTS(uma_name_, value, 1, max_value_, 50); |
53 } | 54 } |
54 | 55 |
55 StatisticsCalculator::PeriodicUmaCount::PeriodicUmaCount( | 56 StatisticsCalculator::PeriodicUmaCount::PeriodicUmaCount( |
56 const std::string& uma_name, | 57 const std::string& uma_name, |
57 int report_interval_ms, | 58 int report_interval_ms, |
58 int max_value) | 59 int max_value) |
(...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
187 | 188 |
188 void StatisticsCalculator::LogDelayedPacketOutageEvent(int outage_duration_ms) { | 189 void StatisticsCalculator::LogDelayedPacketOutageEvent(int outage_duration_ms) { |
189 RTC_HISTOGRAM_COUNTS("WebRTC.Audio.DelayedPacketOutageEventMs", | 190 RTC_HISTOGRAM_COUNTS("WebRTC.Audio.DelayedPacketOutageEventMs", |
190 outage_duration_ms, 1 /* min */, 2000 /* max */, | 191 outage_duration_ms, 1 /* min */, 2000 /* max */, |
191 100 /* bucket count */); | 192 100 /* bucket count */); |
192 delayed_packet_outage_counter_.RegisterSample(); | 193 delayed_packet_outage_counter_.RegisterSample(); |
193 } | 194 } |
194 | 195 |
195 void StatisticsCalculator::StoreWaitingTime(int waiting_time_ms) { | 196 void StatisticsCalculator::StoreWaitingTime(int waiting_time_ms) { |
196 excess_buffer_delay_.RegisterSample(waiting_time_ms); | 197 excess_buffer_delay_.RegisterSample(waiting_time_ms); |
197 DCHECK_LE(waiting_times_.size(), kLenWaitingTimes); | 198 RTC_DCHECK_LE(waiting_times_.size(), kLenWaitingTimes); |
198 if (waiting_times_.size() == kLenWaitingTimes) { | 199 if (waiting_times_.size() == kLenWaitingTimes) { |
199 // Erase first value. | 200 // Erase first value. |
200 waiting_times_.pop_front(); | 201 waiting_times_.pop_front(); |
201 } | 202 } |
202 waiting_times_.push_back(waiting_time_ms); | 203 waiting_times_.push_back(waiting_time_ms); |
203 } | 204 } |
204 | 205 |
205 void StatisticsCalculator::GetNetworkStatistics( | 206 void StatisticsCalculator::GetNetworkStatistics( |
206 int fs_hz, | 207 int fs_hz, |
207 size_t num_samples_in_buffers, | 208 size_t num_samples_in_buffers, |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
286 // Ratio must be smaller than 1 in Q14. | 287 // Ratio must be smaller than 1 in Q14. |
287 assert((numerator << 14) / denominator < (1 << 14)); | 288 assert((numerator << 14) / denominator < (1 << 14)); |
288 return static_cast<uint16_t>((numerator << 14) / denominator); | 289 return static_cast<uint16_t>((numerator << 14) / denominator); |
289 } else { | 290 } else { |
290 // Will not produce a ratio larger than 1, since this is probably an error. | 291 // Will not produce a ratio larger than 1, since this is probably an error. |
291 return 1 << 14; | 292 return 1 << 14; |
292 } | 293 } |
293 } | 294 } |
294 | 295 |
295 } // namespace webrtc | 296 } // namespace webrtc |
OLD | NEW |