| 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 |
| (...skipping 404 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 415 size_t packet_length) { | 415 size_t packet_length) { |
| 416 rtc::CritScope cs(&receive_statistics_lock_); | 416 rtc::CritScope cs(&receive_statistics_lock_); |
| 417 StatisticianImplMap::iterator it = statisticians_.find(header.ssrc); | 417 StatisticianImplMap::iterator it = statisticians_.find(header.ssrc); |
| 418 // Ignore FEC if it is the first packet. | 418 // Ignore FEC if it is the first packet. |
| 419 if (it != statisticians_.end()) { | 419 if (it != statisticians_.end()) { |
| 420 it->second->FecPacketReceived(header, packet_length); | 420 it->second->FecPacketReceived(header, packet_length); |
| 421 } | 421 } |
| 422 } | 422 } |
| 423 | 423 |
| 424 StatisticianMap ReceiveStatisticsImpl::GetActiveStatisticians() const { | 424 StatisticianMap ReceiveStatisticsImpl::GetActiveStatisticians() const { |
| 425 StatisticianMap active_statisticians; |
| 425 rtc::CritScope cs(&receive_statistics_lock_); | 426 rtc::CritScope cs(&receive_statistics_lock_); |
| 426 StatisticianMap active_statisticians; | |
| 427 for (StatisticianImplMap::const_iterator it = statisticians_.begin(); | 427 for (StatisticianImplMap::const_iterator it = statisticians_.begin(); |
| 428 it != statisticians_.end(); ++it) { | 428 it != statisticians_.end(); ++it) { |
| 429 uint32_t secs; | 429 uint32_t secs; |
| 430 uint32_t frac; | 430 uint32_t frac; |
| 431 it->second->LastReceiveTimeNtp(&secs, &frac); | 431 it->second->LastReceiveTimeNtp(&secs, &frac); |
| 432 if (clock_->CurrentNtpInMilliseconds() - | 432 if (clock_->CurrentNtpInMilliseconds() - |
| 433 Clock::NtpToMs(secs, frac) < kStatisticsTimeoutMs) { | 433 Clock::NtpToMs(secs, frac) < kStatisticsTimeoutMs) { |
| 434 active_statisticians[it->first] = it->second; | 434 active_statisticians[it->first] = it->second; |
| 435 } | 435 } |
| 436 } | 436 } |
| (...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 511 void NullReceiveStatistics::SetMaxReorderingThreshold( | 511 void NullReceiveStatistics::SetMaxReorderingThreshold( |
| 512 int max_reordering_threshold) {} | 512 int max_reordering_threshold) {} |
| 513 | 513 |
| 514 void NullReceiveStatistics::RegisterRtcpStatisticsCallback( | 514 void NullReceiveStatistics::RegisterRtcpStatisticsCallback( |
| 515 RtcpStatisticsCallback* callback) {} | 515 RtcpStatisticsCallback* callback) {} |
| 516 | 516 |
| 517 void NullReceiveStatistics::RegisterRtpStatisticsCallback( | 517 void NullReceiveStatistics::RegisterRtpStatisticsCallback( |
| 518 StreamDataCountersCallback* callback) {} | 518 StreamDataCountersCallback* callback) {} |
| 519 | 519 |
| 520 } // namespace webrtc | 520 } // namespace webrtc |
| OLD | NEW |