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/rtp_rtcp/source/receive_statistics_impl.h" | 11 #include "webrtc/modules/rtp_rtcp/source/receive_statistics_impl.h" |
12 | 12 |
13 #include <math.h> | 13 #include <math.h> |
14 | 14 |
15 #include <cstdlib> | 15 #include <cstdlib> |
16 | 16 |
17 #include "webrtc/modules/remote_bitrate_estimator/test/bwe_test_logging.h" | 17 #include "webrtc/modules/remote_bitrate_estimator/test/bwe_test_logging.h" |
18 #include "webrtc/modules/rtp_rtcp/source/rtp_rtcp_config.h" | 18 #include "webrtc/modules/rtp_rtcp/source/rtp_rtcp_config.h" |
19 #include "webrtc/modules/rtp_rtcp/source/time_util.h" | 19 #include "webrtc/modules/rtp_rtcp/source/time_util.h" |
| 20 #include "webrtc/system_wrappers/include/clock.h" |
20 | 21 |
21 namespace webrtc { | 22 namespace webrtc { |
22 | 23 |
23 const int64_t kStatisticsTimeoutMs = 8000; | 24 const int64_t kStatisticsTimeoutMs = 8000; |
24 const int64_t kStatisticsProcessIntervalMs = 1000; | 25 const int64_t kStatisticsProcessIntervalMs = 1000; |
25 | 26 |
26 StreamStatistician::~StreamStatistician() {} | 27 StreamStatistician::~StreamStatistician() {} |
27 | 28 |
28 StreamStatisticianImpl::StreamStatisticianImpl( | 29 StreamStatisticianImpl::StreamStatisticianImpl( |
29 Clock* clock, | 30 Clock* clock, |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
71 | 72 |
72 if (receive_counters_.transmitted.packets == 1) { | 73 if (receive_counters_.transmitted.packets == 1) { |
73 received_seq_first_ = header.sequenceNumber; | 74 received_seq_first_ = header.sequenceNumber; |
74 receive_counters_.first_packet_time_ms = clock_->TimeInMilliseconds(); | 75 receive_counters_.first_packet_time_ms = clock_->TimeInMilliseconds(); |
75 } | 76 } |
76 | 77 |
77 // Count only the new packets received. That is, if packets 1, 2, 3, 5, 4, 6 | 78 // Count only the new packets received. That is, if packets 1, 2, 3, 5, 4, 6 |
78 // are received, 4 will be ignored. | 79 // are received, 4 will be ignored. |
79 if (in_order) { | 80 if (in_order) { |
80 // Current time in samples. | 81 // Current time in samples. |
81 NtpTime receive_time(*clock_); | 82 NtpTime receive_time = clock_->CurrentNtpTime(); |
82 | 83 |
83 // Wrong if we use RetransmitOfOldPacket. | 84 // Wrong if we use RetransmitOfOldPacket. |
84 if (receive_counters_.transmitted.packets > 1 && | 85 if (receive_counters_.transmitted.packets > 1 && |
85 received_seq_max_ > header.sequenceNumber) { | 86 received_seq_max_ > header.sequenceNumber) { |
86 // Wrap around detected. | 87 // Wrap around detected. |
87 received_seq_wraps_++; | 88 received_seq_wraps_++; |
88 } | 89 } |
89 // New max. | 90 // New max. |
90 received_seq_max_ = header.sequenceNumber; | 91 received_seq_max_ = header.sequenceNumber; |
91 | 92 |
(...skipping 418 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
510 void NullReceiveStatistics::SetMaxReorderingThreshold( | 511 void NullReceiveStatistics::SetMaxReorderingThreshold( |
511 int max_reordering_threshold) {} | 512 int max_reordering_threshold) {} |
512 | 513 |
513 void NullReceiveStatistics::RegisterRtcpStatisticsCallback( | 514 void NullReceiveStatistics::RegisterRtcpStatisticsCallback( |
514 RtcpStatisticsCallback* callback) {} | 515 RtcpStatisticsCallback* callback) {} |
515 | 516 |
516 void NullReceiveStatistics::RegisterRtpStatisticsCallback( | 517 void NullReceiveStatistics::RegisterRtpStatisticsCallback( |
517 StreamDataCountersCallback* callback) {} | 518 StreamDataCountersCallback* callback) {} |
518 | 519 |
519 } // namespace webrtc | 520 } // namespace webrtc |
OLD | NEW |