| /* |
| * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |
| * |
| * Use of this source code is governed by a BSD-style license |
| * that can be found in the LICENSE file in the root of the source |
| * tree. An additional intellectual property rights grant can be found |
| * in the file PATENTS. All contributing project authors may |
| * be found in the AUTHORS file in the root of the source tree. |
| */ |
| |
| #ifndef WEBRTC_MODULES_RTP_RTCP_SOURCE_RECEIVE_STATISTICS_IMPL_H_ |
| #define WEBRTC_MODULES_RTP_RTCP_SOURCE_RECEIVE_STATISTICS_IMPL_H_ |
| |
| #include "webrtc/modules/rtp_rtcp/include/receive_statistics.h" |
| |
| #include <algorithm> |
| #include <map> |
| #include <vector> |
| |
| #include "webrtc/rtc_base/criticalsection.h" |
| #include "webrtc/rtc_base/rate_statistics.h" |
| #include "webrtc/system_wrappers/include/ntp_time.h" |
| |
| namespace webrtc { |
| |
| class StreamStatisticianImpl : public StreamStatistician { |
| public: |
| StreamStatisticianImpl(uint32_t ssrc, |
| Clock* clock, |
| RtcpStatisticsCallback* rtcp_callback, |
| StreamDataCountersCallback* rtp_callback); |
| virtual ~StreamStatisticianImpl() {} |
| |
| bool GetStatistics(RtcpStatistics* statistics, bool reset) override; |
| void GetDataCounters(size_t* bytes_received, |
| uint32_t* packets_received) const override; |
| void GetReceiveStreamDataCounters( |
| StreamDataCounters* data_counters) const override; |
| uint32_t BitrateReceived() const override; |
| bool IsRetransmitOfOldPacket(const RTPHeader& header, |
| int64_t min_rtt) const override; |
| bool IsPacketInOrder(uint16_t sequence_number) const override; |
| |
| void IncomingPacket(const RTPHeader& rtp_header, |
| size_t packet_length, |
| bool retransmitted); |
| void FecPacketReceived(const RTPHeader& header, size_t packet_length); |
| void SetMaxReorderingThreshold(int max_reordering_threshold); |
| virtual void LastReceiveTimeNtp(uint32_t* secs, uint32_t* frac) const; |
| |
| private: |
| bool InOrderPacketInternal(uint16_t sequence_number) const; |
| RtcpStatistics CalculateRtcpStatistics() |
| EXCLUSIVE_LOCKS_REQUIRED(stream_lock_); |
| void UpdateJitter(const RTPHeader& header, NtpTime receive_time); |
| StreamDataCounters UpdateCounters(const RTPHeader& rtp_header, |
| size_t packet_length, |
| bool retransmitted); |
| |
| const uint32_t ssrc_; |
| Clock* const clock_; |
| rtc::CriticalSection stream_lock_; |
| RateStatistics incoming_bitrate_; |
| int max_reordering_threshold_; // In number of packets or sequence numbers. |
| |
| // Stats on received RTP packets. |
| uint32_t jitter_q4_; |
| uint32_t cumulative_loss_; |
| uint32_t jitter_q4_transmission_time_offset_; |
| |
| int64_t last_receive_time_ms_; |
| NtpTime last_receive_time_ntp_; |
| uint32_t last_received_timestamp_; |
| int32_t last_received_transmission_time_offset_; |
| uint16_t received_seq_first_; |
| uint16_t received_seq_max_; |
| uint16_t received_seq_wraps_; |
| |
| // Current counter values. |
| size_t received_packet_overhead_; |
| StreamDataCounters receive_counters_; |
| |
| // Counter values when we sent the last report. |
| uint32_t last_report_inorder_packets_; |
| uint32_t last_report_old_packets_; |
| uint16_t last_report_seq_max_; |
| RtcpStatistics last_reported_statistics_; |
| |
| // stream_lock_ shouldn't be held when calling callbacks. |
| RtcpStatisticsCallback* const rtcp_callback_; |
| StreamDataCountersCallback* const rtp_callback_; |
| }; |
| |
| class ReceiveStatisticsImpl : public ReceiveStatistics, |
| public RtcpStatisticsCallback, |
| public StreamDataCountersCallback { |
| public: |
| explicit ReceiveStatisticsImpl(Clock* clock); |
| |
| ~ReceiveStatisticsImpl(); |
| |
| // Implement ReceiveStatisticsProvider. |
| std::vector<rtcp::ReportBlock> RtcpReportBlocks(size_t max_blocks) override; |
| |
| // Implement ReceiveStatistics. |
| void IncomingPacket(const RTPHeader& header, |
| size_t packet_length, |
| bool retransmitted) override; |
| void FecPacketReceived(const RTPHeader& header, |
| size_t packet_length) override; |
| StatisticianMap GetActiveStatisticians() const override; |
| StreamStatistician* GetStatistician(uint32_t ssrc) const override; |
| void SetMaxReorderingThreshold(int max_reordering_threshold) override; |
| |
| void RegisterRtcpStatisticsCallback( |
| RtcpStatisticsCallback* callback) override; |
| |
| void RegisterRtpStatisticsCallback( |
| StreamDataCountersCallback* callback) override; |
| |
| private: |
| void StatisticsUpdated(const RtcpStatistics& statistics, |
| uint32_t ssrc) override; |
| void CNameChanged(const char* cname, uint32_t ssrc) override; |
| void DataCountersUpdated(const StreamDataCounters& counters, |
| uint32_t ssrc) override; |
| |
| typedef std::map<uint32_t, StreamStatisticianImpl*> StatisticianImplMap; |
| |
| Clock* const clock_; |
| rtc::CriticalSection receive_statistics_lock_; |
| StatisticianImplMap statisticians_; |
| |
| RtcpStatisticsCallback* rtcp_stats_callback_; |
| StreamDataCountersCallback* rtp_stats_callback_; |
| }; |
| } // namespace webrtc |
| #endif // WEBRTC_MODULES_RTP_RTCP_SOURCE_RECEIVE_STATISTICS_IMPL_H_ |