sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |
| 3 | * |
| 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 |
| 6 | * tree. An additional intellectual property rights grant can be found |
| 7 | * in the file PATENTS. All contributing project authors may |
| 8 | * be found in the AUTHORS file in the root of the source tree. |
| 9 | */ |
| 10 | |
| 11 | #ifndef WEBRTC_VIDEO_RECEIVE_STATISTICS_PROXY_H_ |
| 12 | #define WEBRTC_VIDEO_RECEIVE_STATISTICS_PROXY_H_ |
| 13 | |
sprang | 0ab8e81 | 2016-02-24 01:35:40 -0800 | [diff] [blame] | 14 | #include <map> |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 15 | #include <string> |
| 16 | |
Peter Boström | f2f8283 | 2015-05-01 13:00:41 +0200 | [diff] [blame] | 17 | #include "webrtc/base/criticalsection.h" |
tkchin | f75d008 | 2016-02-23 22:49:42 -0800 | [diff] [blame] | 18 | #include "webrtc/base/rate_statistics.h" |
asapersson | d89920b | 2015-07-22 06:52:00 -0700 | [diff] [blame] | 19 | #include "webrtc/base/ratetracker.h" |
pbos@webrtc.org | 38344ed | 2014-09-24 06:05:00 +0000 | [diff] [blame] | 20 | #include "webrtc/base/thread_annotations.h" |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 21 | #include "webrtc/common_types.h" |
pbos | a96b60b | 2016-04-18 21:12:48 -0700 | [diff] [blame] | 22 | #include "webrtc/common_video/include/frame_callback.h" |
Henrik Kjellander | 2557b86 | 2015-11-18 22:00:21 +0100 | [diff] [blame] | 23 | #include "webrtc/modules/video_coding/include/video_coding_defines.h" |
Peter Boström | 7623ce4 | 2015-12-09 12:13:30 +0100 | [diff] [blame] | 24 | #include "webrtc/video/report_block_stats.h" |
asapersson | de9e5ff | 2016-11-02 07:14:03 -0700 | [diff] [blame] | 25 | #include "webrtc/video/stats_counter.h" |
mflodman | cfc8e3b | 2016-05-03 21:22:04 -0700 | [diff] [blame] | 26 | #include "webrtc/video/video_stream_decoder.h" |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 27 | #include "webrtc/video_receive_stream.h" |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 28 | |
| 29 | namespace webrtc { |
| 30 | |
| 31 | class Clock; |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 32 | class ViECodec; |
| 33 | class ViEDecoderObserver; |
asapersson | 86b0160 | 2015-10-20 23:55:26 -0700 | [diff] [blame] | 34 | struct CodecSpecificInfo; |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 35 | |
pbos | f42376c | 2015-08-28 07:35:32 -0700 | [diff] [blame] | 36 | class ReceiveStatisticsProxy : public VCMReceiveStatisticsCallback, |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 37 | public RtcpStatisticsCallback, |
pbos@webrtc.org | 1d0fa5d | 2015-02-19 12:47:00 +0000 | [diff] [blame] | 38 | public RtcpPacketTypeCounterObserver, |
pbos@webrtc.org | 5570769 | 2014-12-19 15:45:03 +0000 | [diff] [blame] | 39 | public StreamDataCountersCallback { |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 40 | public: |
Tommi | 733b547 | 2016-06-10 17:58:01 +0200 | [diff] [blame] | 41 | ReceiveStatisticsProxy(const VideoReceiveStream::Config* config, |
sprang | 0ab8e81 | 2016-02-24 01:35:40 -0800 | [diff] [blame] | 42 | Clock* clock); |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 43 | virtual ~ReceiveStatisticsProxy(); |
| 44 | |
| 45 | VideoReceiveStream::Stats GetStats() const; |
| 46 | |
| 47 | void OnDecodedFrame(); |
asapersson | de9e5ff | 2016-11-02 07:14:03 -0700 | [diff] [blame] | 48 | void OnSyncOffsetUpdated(int64_t sync_offset_ms, double estimated_freq_khz); |
asapersson | 1490f7a | 2016-09-23 02:09:46 -0700 | [diff] [blame] | 49 | void OnRenderedFrame(const VideoFrame& frame); |
pbos | f42376c | 2015-08-28 07:35:32 -0700 | [diff] [blame] | 50 | void OnIncomingPayloadType(int payload_type); |
Peter Boström | b7d9a97 | 2015-12-18 16:01:11 +0100 | [diff] [blame] | 51 | void OnDecoderImplementationName(const char* implementation_name); |
pbos | f42376c | 2015-08-28 07:35:32 -0700 | [diff] [blame] | 52 | void OnIncomingRate(unsigned int framerate, unsigned int bitrate_bps); |
| 53 | void OnDecoderTiming(int decode_ms, |
| 54 | int max_decode_ms, |
| 55 | int current_delay_ms, |
| 56 | int target_delay_ms, |
| 57 | int jitter_buffer_ms, |
| 58 | int min_playout_delay_ms, |
asapersson | 13c433c | 2015-10-06 04:08:15 -0700 | [diff] [blame] | 59 | int render_delay_ms, |
| 60 | int64_t rtt_ms); |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 61 | |
asapersson | 86b0160 | 2015-10-20 23:55:26 -0700 | [diff] [blame] | 62 | void OnPreDecode(const EncodedImage& encoded_image, |
| 63 | const CodecSpecificInfo* codec_specific_info); |
| 64 | |
asapersson | d89920b | 2015-07-22 06:52:00 -0700 | [diff] [blame] | 65 | // Overrides VCMReceiveStatisticsCallback. |
kjellander@webrtc.org | 14665ff | 2015-03-04 12:58:35 +0000 | [diff] [blame] | 66 | void OnReceiveRatesUpdated(uint32_t bitRate, uint32_t frameRate) override; |
| 67 | void OnFrameCountsUpdated(const FrameCounts& frame_counts) override; |
| 68 | void OnDiscardedPacketsUpdated(int discarded_packets) override; |
pbos@webrtc.org | 5570769 | 2014-12-19 15:45:03 +0000 | [diff] [blame] | 69 | |
pbos@webrtc.org | ce4e9a3 | 2014-12-18 13:50:16 +0000 | [diff] [blame] | 70 | // Overrides RtcpStatisticsCallback. |
kjellander@webrtc.org | 14665ff | 2015-03-04 12:58:35 +0000 | [diff] [blame] | 71 | void StatisticsUpdated(const webrtc::RtcpStatistics& statistics, |
| 72 | uint32_t ssrc) override; |
| 73 | void CNameChanged(const char* cname, uint32_t ssrc) override; |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 74 | |
asapersson | d89920b | 2015-07-22 06:52:00 -0700 | [diff] [blame] | 75 | // Overrides RtcpPacketTypeCounterObserver. |
kjellander@webrtc.org | 14665ff | 2015-03-04 12:58:35 +0000 | [diff] [blame] | 76 | void RtcpPacketTypesCounterUpdated( |
pbos@webrtc.org | 1d0fa5d | 2015-02-19 12:47:00 +0000 | [diff] [blame] | 77 | uint32_t ssrc, |
kjellander@webrtc.org | 14665ff | 2015-03-04 12:58:35 +0000 | [diff] [blame] | 78 | const RtcpPacketTypeCounter& packet_counter) override; |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 79 | // Overrides StreamDataCountersCallback. |
kjellander@webrtc.org | 14665ff | 2015-03-04 12:58:35 +0000 | [diff] [blame] | 80 | void DataCountersUpdated(const webrtc::StreamDataCounters& counters, |
| 81 | uint32_t ssrc) override; |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 82 | |
pbos@webrtc.org | ce4e9a3 | 2014-12-18 13:50:16 +0000 | [diff] [blame] | 83 | private: |
asapersson | d89920b | 2015-07-22 06:52:00 -0700 | [diff] [blame] | 84 | struct SampleCounter { |
| 85 | SampleCounter() : sum(0), num_samples(0) {} |
| 86 | void Add(int sample); |
| 87 | int Avg(int min_required_samples) const; |
| 88 | |
| 89 | private: |
| 90 | int sum; |
| 91 | int num_samples; |
| 92 | }; |
asapersson | 86b0160 | 2015-10-20 23:55:26 -0700 | [diff] [blame] | 93 | struct QpCounters { |
| 94 | SampleCounter vp8; |
| 95 | }; |
asapersson | d89920b | 2015-07-22 06:52:00 -0700 | [diff] [blame] | 96 | |
| 97 | void UpdateHistograms() EXCLUSIVE_LOCKS_REQUIRED(crit_); |
| 98 | |
pbos@webrtc.org | de1429e | 2014-04-28 13:00:21 +0000 | [diff] [blame] | 99 | Clock* const clock_; |
Tommi | 733b547 | 2016-06-10 17:58:01 +0200 | [diff] [blame] | 100 | // Ownership of this object lies with the owner of the ReceiveStatisticsProxy |
| 101 | // instance. Lifetime is guaranteed to outlive |this|. |
| 102 | // TODO(tommi): In practice the config_ reference is only used for accessing |
brandtr | b5f2c3f | 2016-10-04 23:28:39 -0700 | [diff] [blame] | 103 | // config_.rtp.ulpfec.ulpfec_payload_type. Instead of holding a pointer back, |
Tommi | 733b547 | 2016-06-10 17:58:01 +0200 | [diff] [blame] | 104 | // we could just store the value of ulpfec_payload_type and change the |
| 105 | // ReceiveStatisticsProxy() ctor to accept a const& of Config (since we'll |
| 106 | // then no longer store a pointer to the object). |
| 107 | const VideoReceiveStream::Config& config_; |
asapersson | 4374a09 | 2016-07-27 00:39:09 -0700 | [diff] [blame] | 108 | const int64_t start_ms_; |
pbos@webrtc.org | de1429e | 2014-04-28 13:00:21 +0000 | [diff] [blame] | 109 | |
pbos | 5ad935c | 2016-01-25 03:52:44 -0800 | [diff] [blame] | 110 | rtc::CriticalSection crit_; |
pbos@webrtc.org | de1429e | 2014-04-28 13:00:21 +0000 | [diff] [blame] | 111 | VideoReceiveStream::Stats stats_ GUARDED_BY(crit_); |
| 112 | RateStatistics decode_fps_estimator_ GUARDED_BY(crit_); |
| 113 | RateStatistics renders_fps_estimator_ GUARDED_BY(crit_); |
Tim Psiaki | 6304626 | 2015-09-14 10:38:08 -0700 | [diff] [blame] | 114 | rtc::RateTracker render_fps_tracker_ GUARDED_BY(crit_); |
asapersson | f839dcc | 2015-10-08 00:41:59 -0700 | [diff] [blame] | 115 | rtc::RateTracker render_pixel_tracker_ GUARDED_BY(crit_); |
asapersson | d89920b | 2015-07-22 06:52:00 -0700 | [diff] [blame] | 116 | SampleCounter render_width_counter_ GUARDED_BY(crit_); |
| 117 | SampleCounter render_height_counter_ GUARDED_BY(crit_); |
asapersson | f8cdd18 | 2016-03-15 01:00:47 -0700 | [diff] [blame] | 118 | SampleCounter sync_offset_counter_ GUARDED_BY(crit_); |
asapersson | 6718e97 | 2015-07-24 00:20:58 -0700 | [diff] [blame] | 119 | SampleCounter decode_time_counter_ GUARDED_BY(crit_); |
asapersson | 8688a4e | 2016-04-27 23:42:35 -0700 | [diff] [blame] | 120 | SampleCounter jitter_buffer_delay_counter_ GUARDED_BY(crit_); |
| 121 | SampleCounter target_delay_counter_ GUARDED_BY(crit_); |
| 122 | SampleCounter current_delay_counter_ GUARDED_BY(crit_); |
asapersson | 13c433c | 2015-10-06 04:08:15 -0700 | [diff] [blame] | 123 | SampleCounter delay_counter_ GUARDED_BY(crit_); |
asapersson | 1490f7a | 2016-09-23 02:09:46 -0700 | [diff] [blame] | 124 | SampleCounter e2e_delay_counter_ GUARDED_BY(crit_); |
asapersson | de9e5ff | 2016-11-02 07:14:03 -0700 | [diff] [blame] | 125 | MaxCounter freq_offset_counter_ GUARDED_BY(crit_); |
Åsa Persson | 3c391cb | 2015-04-27 10:09:49 +0200 | [diff] [blame] | 126 | ReportBlockStats report_block_stats_ GUARDED_BY(crit_); |
asapersson | 86b0160 | 2015-10-20 23:55:26 -0700 | [diff] [blame] | 127 | QpCounters qp_counters_; // Only accessed on the decoding thread. |
sprang | 0ab8e81 | 2016-02-24 01:35:40 -0800 | [diff] [blame] | 128 | std::map<uint32_t, StreamDataCounters> rtx_stats_ GUARDED_BY(crit_); |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 129 | }; |
| 130 | |
sprang@webrtc.org | 0931570 | 2014-02-07 12:06:29 +0000 | [diff] [blame] | 131 | } // namespace webrtc |
| 132 | #endif // WEBRTC_VIDEO_RECEIVE_STATISTICS_PROXY_H_ |