Chromium Code Reviews| Index: webrtc/video/call_stats.cc |
| diff --git a/webrtc/video/call_stats.cc b/webrtc/video/call_stats.cc |
| index ef5f0b211d870edc99e399c54d5390b32b1c663e..304189492d99ed3e5c1e3784b99c2e78cd0204fa 100644 |
| --- a/webrtc/video/call_stats.cc |
| +++ b/webrtc/video/call_stats.cc |
| @@ -34,17 +34,17 @@ void RemoveOldReports(int64_t now, std::list<CallStats::RttTime>* reports) { |
| } |
| int64_t GetMaxRttMs(std::list<CallStats::RttTime>* reports) { |
| + if (reports->empty()) |
| + return -1; |
| int64_t max_rtt_ms = 0; |
| - for (std::list<CallStats::RttTime>::const_iterator it = reports->begin(); |
| - it != reports->end(); ++it) { |
| - max_rtt_ms = std::max(it->rtt, max_rtt_ms); |
| - } |
| + for (const CallStats::RttTime& rtt_time : *reports) |
| + max_rtt_ms = std::max(rtt_time.rtt, max_rtt_ms); |
| return max_rtt_ms; |
| } |
| int64_t GetAvgRttMs(std::list<CallStats::RttTime>* reports) { |
| if (reports->empty()) { |
| - return 0; |
| + return -1; |
| } |
| int64_t sum = 0; |
| for (std::list<CallStats::RttTime>::const_iterator it = reports->begin(); |
| @@ -55,13 +55,13 @@ int64_t GetAvgRttMs(std::list<CallStats::RttTime>* reports) { |
| } |
| void UpdateAvgRttMs(std::list<CallStats::RttTime>* reports, int64_t* avg_rtt) { |
| - uint32_t cur_rtt_ms = GetAvgRttMs(reports); |
| - if (cur_rtt_ms == 0) { |
| + int64_t cur_rtt_ms = GetAvgRttMs(reports); |
| + if (cur_rtt_ms == -1) { |
| // Reset. |
| - *avg_rtt = 0; |
| + *avg_rtt = -1; |
| return; |
| } |
| - if (*avg_rtt == 0) { |
| + if (*avg_rtt == -1) { |
| // Initialize. |
| *avg_rtt = cur_rtt_ms; |
| return; |
| @@ -94,8 +94,8 @@ CallStats::CallStats(Clock* clock) |
| : clock_(clock), |
| rtcp_rtt_stats_(new RtcpObserver(this)), |
| last_process_time_(clock_->TimeInMilliseconds()), |
| - max_rtt_ms_(0), |
| - avg_rtt_ms_(0) {} |
| + max_rtt_ms_(-1), |
| + avg_rtt_ms_(-1) {} |
| CallStats::~CallStats() { |
| assert(observers_.empty()); |
| @@ -119,7 +119,7 @@ int32_t CallStats::Process() { |
| // If there is a valid rtt, update all observers with the max rtt. |
| // TODO(asapersson): Consider changing this to report the average rtt. |
|
åsapersson
2016/02/05 13:50:12
this todo seems no longer valid, maybe remove
sprang
2016/02/05 14:10:22
Done.
|
| - if (max_rtt_ms_ > 0) { |
| + if (max_rtt_ms_ >= 0) { |
| for (std::list<CallStatsObserver*>::iterator it = observers_.begin(); |
| it != observers_.end(); ++it) { |
| (*it)->OnRttUpdate(avg_rtt_ms_, max_rtt_ms_); |