| Index: webrtc/modules/rtp_rtcp/source/receive_statistics_impl.cc
|
| diff --git a/webrtc/modules/rtp_rtcp/source/receive_statistics_impl.cc b/webrtc/modules/rtp_rtcp/source/receive_statistics_impl.cc
|
| index 8ac7e0a38324261286dd5b445824ddcffcd982c0..f089d36afb9c01dc588cbc8d94639ec29a7e0885 100644
|
| --- a/webrtc/modules/rtp_rtcp/source/receive_statistics_impl.cc
|
| +++ b/webrtc/modules/rtp_rtcp/source/receive_statistics_impl.cc
|
| @@ -14,7 +14,7 @@
|
|
|
| #include "webrtc/base/scoped_ptr.h"
|
| #include "webrtc/modules/rtp_rtcp/source/bitrate.h"
|
| -#include "webrtc/modules/rtp_rtcp/source/rtp_utility.h"
|
| +#include "webrtc/modules/rtp_rtcp/source/time_util.h"
|
| #include "webrtc/system_wrappers/include/critical_section_wrapper.h"
|
|
|
| namespace webrtc {
|
| @@ -37,8 +37,6 @@ StreamStatisticianImpl::StreamStatisticianImpl(
|
| cumulative_loss_(0),
|
| jitter_q4_transmission_time_offset_(0),
|
| last_receive_time_ms_(0),
|
| - last_receive_time_secs_(0),
|
| - last_receive_time_frac_(0),
|
| last_received_timestamp_(0),
|
| last_received_transmission_time_offset_(0),
|
| received_seq_first_(0),
|
| @@ -79,9 +77,7 @@ void StreamStatisticianImpl::UpdateCounters(const RTPHeader& header,
|
| // are received, 4 will be ignored.
|
| if (in_order) {
|
| // Current time in samples.
|
| - uint32_t receive_time_secs;
|
| - uint32_t receive_time_frac;
|
| - clock_->CurrentNtp(receive_time_secs, receive_time_frac);
|
| + NtpTime receive_time(*clock_);
|
|
|
| // Wrong if we use RetransmitOfOldPacket.
|
| if (receive_counters_.transmitted.packets > 1 &&
|
| @@ -97,11 +93,10 @@ void StreamStatisticianImpl::UpdateCounters(const RTPHeader& header,
|
| if (header.timestamp != last_received_timestamp_ &&
|
| (receive_counters_.transmitted.packets -
|
| receive_counters_.retransmitted.packets) > 1) {
|
| - UpdateJitter(header, receive_time_secs, receive_time_frac);
|
| + UpdateJitter(header, receive_time);
|
| }
|
| last_received_timestamp_ = header.timestamp;
|
| - last_receive_time_secs_ = receive_time_secs;
|
| - last_receive_time_frac_ = receive_time_frac;
|
| + last_receive_time_ntp_ = receive_time;
|
| last_receive_time_ms_ = clock_->TimeInMilliseconds();
|
| }
|
|
|
| @@ -113,14 +108,11 @@ void StreamStatisticianImpl::UpdateCounters(const RTPHeader& header,
|
| }
|
|
|
| void StreamStatisticianImpl::UpdateJitter(const RTPHeader& header,
|
| - uint32_t receive_time_secs,
|
| - uint32_t receive_time_frac) {
|
| - uint32_t receive_time_rtp = RtpUtility::ConvertNTPTimeToRTP(
|
| - receive_time_secs, receive_time_frac, header.payload_type_frequency);
|
| + NtpTime receive_time) {
|
| + uint32_t receive_time_rtp =
|
| + NtpToRtp(receive_time, header.payload_type_frequency);
|
| uint32_t last_receive_time_rtp =
|
| - RtpUtility::ConvertNTPTimeToRTP(last_receive_time_secs_,
|
| - last_receive_time_frac_,
|
| - header.payload_type_frequency);
|
| + NtpToRtp(last_receive_time_ntp_, header.payload_type_frequency);
|
| int32_t time_diff_samples = (receive_time_rtp - last_receive_time_rtp) -
|
| (header.timestamp - last_received_timestamp_);
|
|
|
| @@ -319,8 +311,8 @@ void StreamStatisticianImpl::ProcessBitrate() {
|
| void StreamStatisticianImpl::LastReceiveTimeNtp(uint32_t* secs,
|
| uint32_t* frac) const {
|
| CriticalSectionScoped cs(stream_lock_.get());
|
| - *secs = last_receive_time_secs_;
|
| - *frac = last_receive_time_frac_;
|
| + *secs = last_receive_time_ntp_.seconds();
|
| + *frac = last_receive_time_ntp_.fractions();
|
| }
|
|
|
| bool StreamStatisticianImpl::IsRetransmitOfOldPacket(
|
|
|