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 |