| /* |
| * Copyright 2020 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. |
| */ |
| |
| #include "video/receive_statistics_proxy2.h" |
| |
| #include <limits> |
| #include <memory> |
| #include <string> |
| #include <tuple> |
| #include <utility> |
| |
| #include "absl/types/optional.h" |
| #include "api/scoped_refptr.h" |
| #include "api/video/i420_buffer.h" |
| #include "api/video/video_frame.h" |
| #include "api/video/video_frame_buffer.h" |
| #include "api/video/video_rotation.h" |
| #include "rtc_base/task_utils/to_queued_task.h" |
| #include "rtc_base/thread.h" |
| #include "system_wrappers/include/metrics.h" |
| #include "test/field_trial.h" |
| #include "test/gtest.h" |
| #include "test/run_loop.h" |
| #include "video/video_receive_stream2.h" |
| |
| namespace webrtc { |
| namespace internal { |
| namespace { |
| const int64_t kFreqOffsetProcessIntervalInMs = 40000; |
| const uint32_t kLocalSsrc = 123; |
| const uint32_t kRemoteSsrc = 456; |
| const int kMinRequiredSamples = 200; |
| const int kWidth = 1280; |
| const int kHeight = 720; |
| } // namespace |
| |
| // TODO(sakal): ReceiveStatisticsProxy is lacking unittesting. |
| class ReceiveStatisticsProxy2Test : public ::testing::Test { |
| public: |
| ReceiveStatisticsProxy2Test() : fake_clock_(1234), config_(GetTestConfig()) { |
| metrics::Reset(); |
| statistics_proxy_.reset( |
| new ReceiveStatisticsProxy(&config_, &fake_clock_, loop_.task_queue())); |
| } |
| |
| ~ReceiveStatisticsProxy2Test() override { statistics_proxy_.reset(); } |
| |
| protected: |
| // Convenience method to avoid too many explict flushes. |
| VideoReceiveStream::Stats FlushAndGetStats() { |
| loop_.Flush(); |
| return statistics_proxy_->GetStats(); |
| } |
| |
| void FlushAndUpdateHistograms(absl::optional<int> fraction_lost, |
| const StreamDataCounters& rtp_stats, |
| const StreamDataCounters* rtx_stats) { |
| loop_.Flush(); |
| statistics_proxy_->UpdateHistograms(fraction_lost, rtp_stats, rtx_stats); |
| } |
| |
| VideoReceiveStream::Config GetTestConfig() { |
| VideoReceiveStream::Config config(nullptr); |
| config.rtp.local_ssrc = kLocalSsrc; |
| config.rtp.remote_ssrc = kRemoteSsrc; |
| return config; |
| } |
| |
| VideoFrame CreateFrame(int width, int height) { |
| return CreateVideoFrame(width, height, 0); |
| } |
| |
| VideoFrame CreateFrameWithRenderTime(Timestamp render_time) { |
| return CreateFrameWithRenderTimeMs(render_time.ms()); |
| } |
| |
| VideoFrame CreateFrameWithRenderTimeMs(int64_t render_time_ms) { |
| return CreateVideoFrame(kWidth, kHeight, render_time_ms); |
| } |
| |
| VideoFrame CreateVideoFrame(int width, int height, int64_t render_time_ms) { |
| VideoFrame frame = |
| VideoFrame::Builder() |
| .set_video_frame_buffer(I420Buffer::Create(width, height)) |
| .set_timestamp_rtp(0) |
| .set_timestamp_ms(render_time_ms) |
| .set_rotation(kVideoRotation_0) |
| .build(); |
| frame.set_ntp_time_ms(fake_clock_.CurrentNtpInMilliseconds()); |
| return frame; |
| } |
| |
| // Return the current fake time as a Timestamp. |
| Timestamp Now() { return fake_clock_.CurrentTime(); } |
| |
| // Creates a VideoFrameMetaData instance with a timestamp. |
| VideoFrameMetaData MetaData(const VideoFrame& frame, Timestamp ts) { |
| return VideoFrameMetaData(frame, ts); |
| } |
| |
| // Creates a VideoFrameMetaData instance with the current fake time. |
| VideoFrameMetaData MetaData(const VideoFrame& frame) { |
| return VideoFrameMetaData(frame, Now()); |
| } |
| |
| SimulatedClock fake_clock_; |
| const VideoReceiveStream::Config config_; |
| std::unique_ptr<ReceiveStatisticsProxy> statistics_proxy_; |
| test::RunLoop loop_; |
| }; |
| |
| TEST_F(ReceiveStatisticsProxy2Test, OnDecodedFrameIncreasesFramesDecoded) { |
| EXPECT_EQ(0u, statistics_proxy_->GetStats().frames_decoded); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| for (uint32_t i = 1; i <= 3; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(i, FlushAndGetStats().frames_decoded); |
| } |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, DecodedFpsIsReported) { |
| const int kFps = 20; |
| const int kRequiredSamples = metrics::kMinRunTimeInSeconds * kFps; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| for (int i = 0; i < kRequiredSamples; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| fake_clock_.AdvanceTimeMilliseconds(1000 / kFps); |
| } |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.DecodedFramesPerSecond")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DecodedFramesPerSecond", kFps)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, DecodedFpsIsNotReportedForTooFewSamples) { |
| const int kFps = 20; |
| const int kRequiredSamples = metrics::kMinRunTimeInSeconds * kFps; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| for (int i = 0; i < kRequiredSamples - 1; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| fake_clock_.AdvanceTimeMilliseconds(1000 / kFps); |
| } |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.DecodedFramesPerSecond")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| OnDecodedFrameWithQpDoesNotResetFramesDecodedOrTotalDecodeTime) { |
| EXPECT_EQ(0u, statistics_proxy_->GetStats().frames_decoded); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| unsigned int expected_total_decode_time_ms = 0; |
| unsigned int expected_frames_decoded = 0; |
| for (uint32_t i = 1; i <= 3; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 1, |
| VideoContentType::UNSPECIFIED); |
| expected_total_decode_time_ms += 1; |
| ++expected_frames_decoded; |
| loop_.Flush(); |
| EXPECT_EQ(expected_frames_decoded, |
| statistics_proxy_->GetStats().frames_decoded); |
| EXPECT_EQ(expected_total_decode_time_ms, |
| statistics_proxy_->GetStats().total_decode_time_ms); |
| } |
| statistics_proxy_->OnDecodedFrame(frame, 1u, 3, |
| VideoContentType::UNSPECIFIED); |
| ++expected_frames_decoded; |
| expected_total_decode_time_ms += 3; |
| loop_.Flush(); |
| EXPECT_EQ(expected_frames_decoded, |
| statistics_proxy_->GetStats().frames_decoded); |
| EXPECT_EQ(expected_total_decode_time_ms, |
| statistics_proxy_->GetStats().total_decode_time_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, OnDecodedFrameIncreasesQpSum) { |
| EXPECT_EQ(absl::nullopt, statistics_proxy_->GetStats().qp_sum); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, 3u, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(3u, FlushAndGetStats().qp_sum); |
| statistics_proxy_->OnDecodedFrame(frame, 127u, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(130u, FlushAndGetStats().qp_sum); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, OnDecodedFrameIncreasesTotalDecodeTime) { |
| EXPECT_EQ(absl::nullopt, statistics_proxy_->GetStats().qp_sum); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, 3u, 4, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(4u, FlushAndGetStats().total_decode_time_ms); |
| statistics_proxy_->OnDecodedFrame(frame, 127u, 7, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(11u, FlushAndGetStats().total_decode_time_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsContentType) { |
| const std::string kRealtimeString("realtime"); |
| const std::string kScreenshareString("screen"); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| EXPECT_EQ(kRealtimeString, videocontenttypehelpers::ToString( |
| statistics_proxy_->GetStats().content_type)); |
| statistics_proxy_->OnDecodedFrame(frame, 3u, 0, |
| VideoContentType::SCREENSHARE); |
| EXPECT_EQ(kScreenshareString, |
| videocontenttypehelpers::ToString(FlushAndGetStats().content_type)); |
| statistics_proxy_->OnDecodedFrame(frame, 3u, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(kRealtimeString, |
| videocontenttypehelpers::ToString(FlushAndGetStats().content_type)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsMaxTotalInterFrameDelay) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| const TimeDelta kInterFrameDelay1 = TimeDelta::Millis(100); |
| const TimeDelta kInterFrameDelay2 = TimeDelta::Millis(200); |
| const TimeDelta kInterFrameDelay3 = TimeDelta::Millis(300); |
| double expected_total_inter_frame_delay = 0; |
| double expected_total_squared_inter_frame_delay = 0; |
| EXPECT_EQ(expected_total_inter_frame_delay, |
| statistics_proxy_->GetStats().total_inter_frame_delay); |
| EXPECT_EQ(expected_total_squared_inter_frame_delay, |
| statistics_proxy_->GetStats().total_squared_inter_frame_delay); |
| |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_DOUBLE_EQ(expected_total_inter_frame_delay, |
| FlushAndGetStats().total_inter_frame_delay); |
| EXPECT_DOUBLE_EQ(expected_total_squared_inter_frame_delay, |
| FlushAndGetStats().total_squared_inter_frame_delay); |
| |
| fake_clock_.AdvanceTime(kInterFrameDelay1); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| expected_total_inter_frame_delay += kInterFrameDelay1.seconds<double>(); |
| expected_total_squared_inter_frame_delay += |
| pow(kInterFrameDelay1.seconds<double>(), 2.0); |
| EXPECT_DOUBLE_EQ(expected_total_inter_frame_delay, |
| FlushAndGetStats().total_inter_frame_delay); |
| EXPECT_DOUBLE_EQ( |
| expected_total_squared_inter_frame_delay, |
| statistics_proxy_->GetStats().total_squared_inter_frame_delay); |
| |
| fake_clock_.AdvanceTime(kInterFrameDelay2); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| expected_total_inter_frame_delay += kInterFrameDelay2.seconds<double>(); |
| expected_total_squared_inter_frame_delay += |
| pow(kInterFrameDelay2.seconds<double>(), 2.0); |
| EXPECT_DOUBLE_EQ(expected_total_inter_frame_delay, |
| FlushAndGetStats().total_inter_frame_delay); |
| EXPECT_DOUBLE_EQ( |
| expected_total_squared_inter_frame_delay, |
| statistics_proxy_->GetStats().total_squared_inter_frame_delay); |
| |
| fake_clock_.AdvanceTime(kInterFrameDelay3); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| expected_total_inter_frame_delay += kInterFrameDelay3.seconds<double>(); |
| expected_total_squared_inter_frame_delay += |
| pow(kInterFrameDelay3.seconds<double>(), 2.0); |
| EXPECT_DOUBLE_EQ(expected_total_inter_frame_delay, |
| FlushAndGetStats().total_inter_frame_delay); |
| EXPECT_DOUBLE_EQ( |
| expected_total_squared_inter_frame_delay, |
| statistics_proxy_->GetStats().total_squared_inter_frame_delay); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsMaxInterframeDelay) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| const int64_t kInterframeDelayMs1 = 100; |
| const int64_t kInterframeDelayMs2 = 200; |
| const int64_t kInterframeDelayMs3 = 100; |
| EXPECT_EQ(-1, statistics_proxy_->GetStats().interframe_delay_max_ms); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(-1, FlushAndGetStats().interframe_delay_max_ms); |
| |
| fake_clock_.AdvanceTimeMilliseconds(kInterframeDelayMs1); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(kInterframeDelayMs1, FlushAndGetStats().interframe_delay_max_ms); |
| |
| fake_clock_.AdvanceTimeMilliseconds(kInterframeDelayMs2); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(kInterframeDelayMs2, FlushAndGetStats().interframe_delay_max_ms); |
| |
| fake_clock_.AdvanceTimeMilliseconds(kInterframeDelayMs3); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| // kInterframeDelayMs3 is smaller than kInterframeDelayMs2. |
| EXPECT_EQ(kInterframeDelayMs2, FlushAndGetStats().interframe_delay_max_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportInterframeDelayInWindow) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| const int64_t kInterframeDelayMs1 = 900; |
| const int64_t kInterframeDelayMs2 = 750; |
| const int64_t kInterframeDelayMs3 = 700; |
| EXPECT_EQ(-1, statistics_proxy_->GetStats().interframe_delay_max_ms); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(-1, FlushAndGetStats().interframe_delay_max_ms); |
| |
| fake_clock_.AdvanceTimeMilliseconds(kInterframeDelayMs1); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(kInterframeDelayMs1, FlushAndGetStats().interframe_delay_max_ms); |
| |
| fake_clock_.AdvanceTimeMilliseconds(kInterframeDelayMs2); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| // Still first delay is the maximum |
| EXPECT_EQ(kInterframeDelayMs1, FlushAndGetStats().interframe_delay_max_ms); |
| |
| fake_clock_.AdvanceTimeMilliseconds(kInterframeDelayMs3); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| // Now the first sample is out of the window, so the second is the maximum. |
| EXPECT_EQ(kInterframeDelayMs2, FlushAndGetStats().interframe_delay_max_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsFreezeMetrics) { |
| const int64_t kFreezeDurationMs = 1000; |
| |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(0u, stats.freeze_count); |
| EXPECT_FALSE(stats.total_freezes_duration_ms); |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| for (size_t i = 0; i < VideoQualityObserver::kMinFrameSamplesToDetectFreeze; |
| ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(30); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| } |
| |
| // Freeze. |
| fake_clock_.AdvanceTimeMilliseconds(kFreezeDurationMs); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(1u, stats.freeze_count); |
| EXPECT_EQ(kFreezeDurationMs, stats.total_freezes_duration_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsPauseMetrics) { |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| ASSERT_EQ(0u, stats.pause_count); |
| ASSERT_EQ(0u, stats.total_pauses_duration_ms); |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| // Pause. |
| fake_clock_.AdvanceTimeMilliseconds(5432); |
| statistics_proxy_->OnStreamInactive(); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(1u, stats.pause_count); |
| EXPECT_EQ(5432u, stats.total_pauses_duration_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, PauseBeforeFirstAndAfterLastFrameIgnored) { |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| ASSERT_EQ(0u, stats.pause_count); |
| ASSERT_EQ(0u, stats.total_pauses_duration_ms); |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| // Pause -> Frame -> Pause |
| fake_clock_.AdvanceTimeMilliseconds(5000); |
| statistics_proxy_->OnStreamInactive(); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| fake_clock_.AdvanceTimeMilliseconds(30); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| fake_clock_.AdvanceTimeMilliseconds(5000); |
| statistics_proxy_->OnStreamInactive(); |
| |
| stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(0u, stats.pause_count); |
| EXPECT_EQ(0u, stats.total_pauses_duration_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsFramesDuration) { |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| ASSERT_EQ(0u, stats.total_frames_duration_ms); |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| // Emulate delay before first frame is rendered. This is needed to ensure |
| // that frame duration only covers time since first frame is rendered and |
| // not the total time. |
| fake_clock_.AdvanceTimeMilliseconds(5432); |
| |
| for (int i = 0; i <= 10; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(30); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| } |
| |
| stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(10 * 30u, stats.total_frames_duration_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsSumSquaredFrameDurations) { |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| ASSERT_EQ(0u, stats.sum_squared_frame_durations); |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| for (int i = 0; i <= 10; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(30); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| } |
| |
| stats = statistics_proxy_->GetStats(); |
| const double kExpectedSumSquaredFrameDurationsSecs = |
| 10 * (30 / 1000.0 * 30 / 1000.0); |
| EXPECT_EQ(kExpectedSumSquaredFrameDurationsSecs, |
| stats.sum_squared_frame_durations); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, OnDecodedFrameWithoutQpQpSumWontExist) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| EXPECT_EQ(absl::nullopt, statistics_proxy_->GetStats().qp_sum); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(absl::nullopt, FlushAndGetStats().qp_sum); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, OnDecodedFrameWithoutQpResetsQpSum) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| EXPECT_EQ(absl::nullopt, statistics_proxy_->GetStats().qp_sum); |
| statistics_proxy_->OnDecodedFrame(frame, 3u, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(3u, FlushAndGetStats().qp_sum); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| EXPECT_EQ(absl::nullopt, FlushAndGetStats().qp_sum); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, OnRenderedFrameIncreasesFramesRendered) { |
| EXPECT_EQ(0u, statistics_proxy_->GetStats().frames_rendered); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| for (uint32_t i = 1; i <= 3; ++i) { |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| EXPECT_EQ(i, statistics_proxy_->GetStats().frames_rendered); |
| } |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsSsrc) { |
| EXPECT_EQ(kRemoteSsrc, statistics_proxy_->GetStats().ssrc); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsIncomingPayloadType) { |
| const int kPayloadType = 111; |
| statistics_proxy_->OnIncomingPayloadType(kPayloadType); |
| loop_.Flush(); |
| EXPECT_EQ(kPayloadType, statistics_proxy_->GetStats().current_payload_type); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsDecoderImplementationName) { |
| const char* kName = "decoderName"; |
| statistics_proxy_->OnDecoderImplementationName(kName); |
| loop_.Flush(); |
| EXPECT_STREQ( |
| kName, statistics_proxy_->GetStats().decoder_implementation_name.c_str()); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsOnCompleteFrame) { |
| const int kFrameSizeBytes = 1000; |
| statistics_proxy_->OnCompleteFrame(true, kFrameSizeBytes, |
| VideoContentType::UNSPECIFIED); |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(1, stats.network_frame_rate); |
| EXPECT_EQ(1, stats.frame_counts.key_frames); |
| EXPECT_EQ(0, stats.frame_counts.delta_frames); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsOnDroppedFrame) { |
| unsigned int dropped_frames = 0; |
| for (int i = 0; i < 10; ++i) { |
| statistics_proxy_->OnDroppedFrames(i); |
| dropped_frames += i; |
| } |
| VideoReceiveStream::Stats stats = FlushAndGetStats(); |
| EXPECT_EQ(dropped_frames, stats.frames_dropped); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsDecodeTimingStats) { |
| const int kMaxDecodeMs = 2; |
| const int kCurrentDelayMs = 3; |
| const int kTargetDelayMs = 4; |
| const int kJitterBufferMs = 5; |
| const int kMinPlayoutDelayMs = 6; |
| const int kRenderDelayMs = 7; |
| const int64_t kRttMs = 8; |
| statistics_proxy_->OnRttUpdate(kRttMs); |
| statistics_proxy_->OnFrameBufferTimingsUpdated( |
| kMaxDecodeMs, kCurrentDelayMs, kTargetDelayMs, kJitterBufferMs, |
| kMinPlayoutDelayMs, kRenderDelayMs); |
| VideoReceiveStream::Stats stats = FlushAndGetStats(); |
| EXPECT_EQ(kMaxDecodeMs, stats.max_decode_ms); |
| EXPECT_EQ(kCurrentDelayMs, stats.current_delay_ms); |
| EXPECT_EQ(kTargetDelayMs, stats.target_delay_ms); |
| EXPECT_EQ(kJitterBufferMs, stats.jitter_buffer_ms); |
| EXPECT_EQ(kMinPlayoutDelayMs, stats.min_playout_delay_ms); |
| EXPECT_EQ(kRenderDelayMs, stats.render_delay_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsRtcpPacketTypeCounts) { |
| const uint32_t kFirPackets = 33; |
| const uint32_t kPliPackets = 44; |
| const uint32_t kNackPackets = 55; |
| RtcpPacketTypeCounter counter; |
| counter.fir_packets = kFirPackets; |
| counter.pli_packets = kPliPackets; |
| counter.nack_packets = kNackPackets; |
| statistics_proxy_->RtcpPacketTypesCounterUpdated(kRemoteSsrc, counter); |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(kFirPackets, stats.rtcp_packet_type_counts.fir_packets); |
| EXPECT_EQ(kPliPackets, stats.rtcp_packet_type_counts.pli_packets); |
| EXPECT_EQ(kNackPackets, stats.rtcp_packet_type_counts.nack_packets); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| GetStatsReportsNoRtcpPacketTypeCountsForUnknownSsrc) { |
| RtcpPacketTypeCounter counter; |
| counter.fir_packets = 33; |
| statistics_proxy_->RtcpPacketTypesCounterUpdated(kRemoteSsrc + 1, counter); |
| EXPECT_EQ(0u, |
| statistics_proxy_->GetStats().rtcp_packet_type_counts.fir_packets); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsFrameCounts) { |
| const int kKeyFrames = 3; |
| const int kDeltaFrames = 22; |
| for (int i = 0; i < kKeyFrames; i++) { |
| statistics_proxy_->OnCompleteFrame(true, 0, VideoContentType::UNSPECIFIED); |
| } |
| for (int i = 0; i < kDeltaFrames; i++) { |
| statistics_proxy_->OnCompleteFrame(false, 0, VideoContentType::UNSPECIFIED); |
| } |
| |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(kKeyFrames, stats.frame_counts.key_frames); |
| EXPECT_EQ(kDeltaFrames, stats.frame_counts.delta_frames); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsCName) { |
| const char* kName = "cName"; |
| statistics_proxy_->OnCname(kRemoteSsrc, kName); |
| EXPECT_STREQ(kName, statistics_proxy_->GetStats().c_name.c_str()); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsNoCNameForUnknownSsrc) { |
| const char* kName = "cName"; |
| statistics_proxy_->OnCname(kRemoteSsrc + 1, kName); |
| EXPECT_STREQ("", statistics_proxy_->GetStats().c_name.c_str()); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReportsLongestTimingFrameInfo) { |
| const int64_t kShortEndToEndDelay = 10; |
| const int64_t kMedEndToEndDelay = 20; |
| const int64_t kLongEndToEndDelay = 100; |
| const uint32_t kExpectedRtpTimestamp = 2; |
| TimingFrameInfo info; |
| absl::optional<TimingFrameInfo> result; |
| info.rtp_timestamp = kExpectedRtpTimestamp - 1; |
| info.capture_time_ms = 0; |
| info.decode_finish_ms = kShortEndToEndDelay; |
| statistics_proxy_->OnTimingFrameInfoUpdated(info); |
| info.rtp_timestamp = |
| kExpectedRtpTimestamp; // this frame should be reported in the end. |
| info.capture_time_ms = 0; |
| info.decode_finish_ms = kLongEndToEndDelay; |
| statistics_proxy_->OnTimingFrameInfoUpdated(info); |
| info.rtp_timestamp = kExpectedRtpTimestamp + 1; |
| info.capture_time_ms = 0; |
| info.decode_finish_ms = kMedEndToEndDelay; |
| statistics_proxy_->OnTimingFrameInfoUpdated(info); |
| result = FlushAndGetStats().timing_frame_info; |
| EXPECT_TRUE(result); |
| EXPECT_EQ(kExpectedRtpTimestamp, result->rtp_timestamp); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, RespectsReportingIntervalForTimingFrames) { |
| TimingFrameInfo info; |
| const int64_t kShortEndToEndDelay = 10; |
| const uint32_t kExpectedRtpTimestamp = 2; |
| const int64_t kShortDelayMs = 1000; |
| const int64_t kLongDelayMs = 10000; |
| absl::optional<TimingFrameInfo> result; |
| info.rtp_timestamp = kExpectedRtpTimestamp; |
| info.capture_time_ms = 0; |
| info.decode_finish_ms = kShortEndToEndDelay; |
| statistics_proxy_->OnTimingFrameInfoUpdated(info); |
| fake_clock_.AdvanceTimeMilliseconds(kShortDelayMs); |
| result = FlushAndGetStats().timing_frame_info; |
| EXPECT_TRUE(result); |
| EXPECT_EQ(kExpectedRtpTimestamp, result->rtp_timestamp); |
| fake_clock_.AdvanceTimeMilliseconds(kLongDelayMs); |
| result = statistics_proxy_->GetStats().timing_frame_info; |
| EXPECT_FALSE(result); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, LifetimeHistogramIsUpdated) { |
| const int64_t kTimeSec = 3; |
| fake_clock_.AdvanceTimeMilliseconds(kTimeSec * 1000); |
| // Need at least one frame to report stream lifetime. |
| statistics_proxy_->OnCompleteFrame(true, 1000, VideoContentType::UNSPECIFIED); |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.ReceiveStreamLifetimeInSeconds")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.ReceiveStreamLifetimeInSeconds", |
| kTimeSec)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| LifetimeHistogramNotReportedForEmptyStreams) { |
| const int64_t kTimeSec = 3; |
| fake_clock_.AdvanceTimeMilliseconds(kTimeSec * 1000); |
| // No frames received. |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.ReceiveStreamLifetimeInSeconds")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, BadCallHistogramsAreUpdated) { |
| // Based on the tuning parameters this will produce 7 uncertain states, |
| // then 10 certainly bad states. There has to be 10 certain states before |
| // any histograms are recorded. |
| const int kNumBadSamples = 17; |
| // We only count one sample per second. |
| const int kBadFameIntervalMs = 1100; |
| |
| StreamDataCounters counters; |
| counters.first_packet_time_ms = fake_clock_.TimeInMilliseconds(); |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kNumBadSamples; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(kBadFameIntervalMs); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| } |
| statistics_proxy_->UpdateHistograms(absl::nullopt, counters, nullptr); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.BadCall.Any")); |
| EXPECT_METRIC_EQ(1, metrics::NumEvents("WebRTC.Video.BadCall.Any", 100)); |
| |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.BadCall.FrameRate")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumEvents("WebRTC.Video.BadCall.FrameRate", 100)); |
| |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.BadCall.FrameRateVariance")); |
| |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.BadCall.Qp")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, PacketLossHistogramIsUpdated) { |
| statistics_proxy_->UpdateHistograms(10, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.ReceivedPacketsLostInPercent")); |
| |
| // Restart |
| SetUp(); |
| |
| // Min run time has passed. |
| fake_clock_.AdvanceTimeMilliseconds(metrics::kMinRunTimeInSeconds * 1000); |
| statistics_proxy_->UpdateHistograms(10, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.ReceivedPacketsLostInPercent")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.ReceivedPacketsLostInPercent", 10)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsPlayoutTimestamp) { |
| const int64_t kVideoNtpMs = 21; |
| const int64_t kSyncOffsetMs = 22; |
| const double kFreqKhz = 90.0; |
| EXPECT_EQ(absl::nullopt, |
| statistics_proxy_->GetStats().estimated_playout_ntp_timestamp_ms); |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, kFreqKhz); |
| EXPECT_EQ(kVideoNtpMs, FlushAndGetStats().estimated_playout_ntp_timestamp_ms); |
| fake_clock_.AdvanceTimeMilliseconds(13); |
| EXPECT_EQ(kVideoNtpMs + 13, |
| statistics_proxy_->GetStats().estimated_playout_ntp_timestamp_ms); |
| fake_clock_.AdvanceTimeMilliseconds(5); |
| EXPECT_EQ(kVideoNtpMs + 13 + 5, |
| statistics_proxy_->GetStats().estimated_playout_ntp_timestamp_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsAvSyncOffset) { |
| const int64_t kVideoNtpMs = 21; |
| const int64_t kSyncOffsetMs = 22; |
| const double kFreqKhz = 90.0; |
| EXPECT_EQ(std::numeric_limits<int>::max(), |
| statistics_proxy_->GetStats().sync_offset_ms); |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, kFreqKhz); |
| EXPECT_EQ(kSyncOffsetMs, FlushAndGetStats().sync_offset_ms); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, AvSyncOffsetHistogramIsUpdated) { |
| const int64_t kVideoNtpMs = 21; |
| const int64_t kSyncOffsetMs = 22; |
| const double kFreqKhz = 90.0; |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, |
| kFreqKhz); |
| } |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.AVSyncOffsetInMs")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.AVSyncOffsetInMs", kSyncOffsetMs)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, RtpToNtpFrequencyOffsetHistogramIsUpdated) { |
| const int64_t kVideoNtpMs = 21; |
| const int64_t kSyncOffsetMs = 22; |
| const double kFreqKhz = 90.0; |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, kFreqKhz); |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, |
| kFreqKhz + 2.2); |
| loop_.Flush(); |
| fake_clock_.AdvanceTimeMilliseconds(kFreqOffsetProcessIntervalInMs); |
| // Process interval passed, max diff: 2. |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, |
| kFreqKhz + 1.1); |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, |
| kFreqKhz - 4.2); |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, |
| kFreqKhz - 0.9); |
| loop_.Flush(); |
| fake_clock_.AdvanceTimeMilliseconds(kFreqOffsetProcessIntervalInMs); |
| // Process interval passed, max diff: 4. |
| statistics_proxy_->OnSyncOffsetUpdated(kVideoNtpMs, kSyncOffsetMs, kFreqKhz); |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| // Average reported: (2 + 4) / 2 = 3. |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.RtpToNtpFreqOffsetInKhz")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.RtpToNtpFreqOffsetInKhz", 3)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, Vp8QpHistogramIsUpdated) { |
| const int kQp = 22; |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) |
| statistics_proxy_->OnPreDecode(kVideoCodecVP8, kQp); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.Decoded.Vp8.Qp")); |
| EXPECT_METRIC_EQ(1, metrics::NumEvents("WebRTC.Video.Decoded.Vp8.Qp", kQp)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| Vp8QpHistogramIsNotUpdatedForTooFewSamples) { |
| const int kQp = 22; |
| |
| for (int i = 0; i < kMinRequiredSamples - 1; ++i) |
| statistics_proxy_->OnPreDecode(kVideoCodecVP8, kQp); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.Decoded.Vp8.Qp")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, Vp8QpHistogramIsNotUpdatedIfNoQpValue) { |
| for (int i = 0; i < kMinRequiredSamples; ++i) |
| statistics_proxy_->OnPreDecode(kVideoCodecVP8, -1); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.Decoded.Vp8.Qp")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| KeyFrameHistogramNotUpdatedForTooFewSamples) { |
| const bool kIsKeyFrame = false; |
| const int kFrameSizeBytes = 1000; |
| |
| for (int i = 0; i < kMinRequiredSamples - 1; ++i) |
| statistics_proxy_->OnCompleteFrame(kIsKeyFrame, kFrameSizeBytes, |
| VideoContentType::UNSPECIFIED); |
| |
| EXPECT_EQ(0, statistics_proxy_->GetStats().frame_counts.key_frames); |
| EXPECT_EQ(kMinRequiredSamples - 1, |
| statistics_proxy_->GetStats().frame_counts.delta_frames); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.KeyFramesReceivedInPermille")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| KeyFrameHistogramUpdatedForMinRequiredSamples) { |
| const bool kIsKeyFrame = false; |
| const int kFrameSizeBytes = 1000; |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) |
| statistics_proxy_->OnCompleteFrame(kIsKeyFrame, kFrameSizeBytes, |
| VideoContentType::UNSPECIFIED); |
| |
| EXPECT_EQ(0, statistics_proxy_->GetStats().frame_counts.key_frames); |
| EXPECT_EQ(kMinRequiredSamples, |
| statistics_proxy_->GetStats().frame_counts.delta_frames); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.KeyFramesReceivedInPermille")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.KeyFramesReceivedInPermille", 0)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, KeyFrameHistogramIsUpdated) { |
| const int kFrameSizeBytes = 1000; |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) |
| statistics_proxy_->OnCompleteFrame(true, kFrameSizeBytes, |
| VideoContentType::UNSPECIFIED); |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) |
| statistics_proxy_->OnCompleteFrame(false, kFrameSizeBytes, |
| VideoContentType::UNSPECIFIED); |
| |
| EXPECT_EQ(kMinRequiredSamples, |
| statistics_proxy_->GetStats().frame_counts.key_frames); |
| EXPECT_EQ(kMinRequiredSamples, |
| statistics_proxy_->GetStats().frame_counts.delta_frames); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.KeyFramesReceivedInPermille")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.KeyFramesReceivedInPermille", 500)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| TimingHistogramsNotUpdatedForTooFewSamples) { |
| const int kMaxDecodeMs = 2; |
| const int kCurrentDelayMs = 3; |
| const int kTargetDelayMs = 4; |
| const int kJitterBufferMs = 5; |
| const int kMinPlayoutDelayMs = 6; |
| const int kRenderDelayMs = 7; |
| |
| for (int i = 0; i < kMinRequiredSamples - 1; ++i) { |
| statistics_proxy_->OnFrameBufferTimingsUpdated( |
| kMaxDecodeMs, kCurrentDelayMs, kTargetDelayMs, kJitterBufferMs, |
| kMinPlayoutDelayMs, kRenderDelayMs); |
| } |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.DecodeTimeInMs")); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.JitterBufferDelayInMs")); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.TargetDelayInMs")); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.CurrentDelayInMs")); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.OnewayDelayInMs")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, TimingHistogramsAreUpdated) { |
| const int kMaxDecodeMs = 2; |
| const int kCurrentDelayMs = 3; |
| const int kTargetDelayMs = 4; |
| const int kJitterBufferMs = 5; |
| const int kMinPlayoutDelayMs = 6; |
| const int kRenderDelayMs = 7; |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnFrameBufferTimingsUpdated( |
| kMaxDecodeMs, kCurrentDelayMs, kTargetDelayMs, kJitterBufferMs, |
| kMinPlayoutDelayMs, kRenderDelayMs); |
| } |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.JitterBufferDelayInMs")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.TargetDelayInMs")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.CurrentDelayInMs")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.OnewayDelayInMs")); |
| |
| EXPECT_METRIC_EQ(1, metrics::NumEvents("WebRTC.Video.JitterBufferDelayInMs", |
| kJitterBufferMs)); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.TargetDelayInMs", kTargetDelayMs)); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.CurrentDelayInMs", kCurrentDelayMs)); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.OnewayDelayInMs", kTargetDelayMs)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, DoesNotReportStaleFramerates) { |
| const int kDefaultFps = 30; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kDefaultFps; ++i) { |
| // Since OnRenderedFrame is never called the fps in each sample will be 0, |
| // i.e. bad |
| frame.set_ntp_time_ms(fake_clock_.CurrentNtpInMilliseconds()); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| fake_clock_.AdvanceTimeMilliseconds(1000 / kDefaultFps); |
| } |
| |
| loop_.Flush(); |
| EXPECT_EQ(kDefaultFps, statistics_proxy_->GetStats().decode_frame_rate); |
| EXPECT_EQ(kDefaultFps, statistics_proxy_->GetStats().render_frame_rate); |
| |
| // FPS trackers in stats proxy have a 1000ms sliding window. |
| fake_clock_.AdvanceTimeMilliseconds(1000); |
| EXPECT_EQ(0, statistics_proxy_->GetStats().decode_frame_rate); |
| EXPECT_EQ(0, statistics_proxy_->GetStats().render_frame_rate); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, GetStatsReportsReceivedFrameStats) { |
| EXPECT_EQ(0, statistics_proxy_->GetStats().width); |
| EXPECT_EQ(0, statistics_proxy_->GetStats().height); |
| EXPECT_EQ(0u, statistics_proxy_->GetStats().frames_rendered); |
| |
| statistics_proxy_->OnRenderedFrame(MetaData(CreateFrame(kWidth, kHeight))); |
| |
| EXPECT_EQ(kWidth, statistics_proxy_->GetStats().width); |
| EXPECT_EQ(kHeight, statistics_proxy_->GetStats().height); |
| EXPECT_EQ(1u, statistics_proxy_->GetStats().frames_rendered); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| ReceivedFrameHistogramsAreNotUpdatedForTooFewSamples) { |
| for (int i = 0; i < kMinRequiredSamples - 1; ++i) { |
| statistics_proxy_->OnRenderedFrame(MetaData(CreateFrame(kWidth, kHeight))); |
| } |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.ReceivedWidthInPixels")); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.ReceivedHeightInPixels")); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.RenderFramesPerSecond")); |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.RenderSqrtPixelsPerSecond")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ReceivedFrameHistogramsAreUpdated) { |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnRenderedFrame(MetaData(CreateFrame(kWidth, kHeight))); |
| } |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.ReceivedWidthInPixels")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.ReceivedHeightInPixels")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.RenderFramesPerSecond")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.RenderSqrtPixelsPerSecond")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.ReceivedWidthInPixels", kWidth)); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.ReceivedHeightInPixels", kHeight)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, ZeroDelayReportedIfFrameNotDelayed) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| |
| // Frame not delayed, delayed frames to render: 0%. |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTime(Now()))); |
| |
| // Min run time has passed. |
| fake_clock_.AdvanceTimeMilliseconds((metrics::kMinRunTimeInSeconds * 1000)); |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.DelayedFramesToRenderer")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DelayedFramesToRenderer", 0)); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples( |
| "WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| DelayedFrameHistogramsAreNotUpdatedIfMinRuntimeHasNotPassed) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| |
| // Frame not delayed, delayed frames to render: 0%. |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTime(Now()))); |
| |
| // Min run time has not passed. |
| fake_clock_.AdvanceTimeMilliseconds((metrics::kMinRunTimeInSeconds * 1000) - |
| 1); |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.DelayedFramesToRenderer")); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples( |
| "WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| DelayedFramesHistogramsAreNotUpdatedIfNoRenderedFrames) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| |
| // Min run time has passed. No rendered frames. |
| fake_clock_.AdvanceTimeMilliseconds((metrics::kMinRunTimeInSeconds * 1000)); |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.DelayedFramesToRenderer")); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples( |
| "WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, DelayReportedIfFrameIsDelayed) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| |
| // Frame delayed 1 ms, delayed frames to render: 100%. |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTimeMs(Now().ms() - 1))); |
| |
| // Min run time has passed. |
| fake_clock_.AdvanceTimeMilliseconds((metrics::kMinRunTimeInSeconds * 1000)); |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.DelayedFramesToRenderer")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DelayedFramesToRenderer", 100)); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples( |
| "WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs", |
| 1)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, AverageDelayOfDelayedFramesIsReported) { |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, |
| VideoContentType::UNSPECIFIED); |
| |
| // Two frames delayed (6 ms, 10 ms), delayed frames to render: 50%. |
| const int64_t kNowMs = Now().ms(); |
| |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTimeMs(kNowMs - 10))); |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTimeMs(kNowMs - 6))); |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTimeMs(kNowMs))); |
| statistics_proxy_->OnRenderedFrame( |
| MetaData(CreateFrameWithRenderTimeMs(kNowMs + 1))); |
| |
| // Min run time has passed. |
| fake_clock_.AdvanceTimeMilliseconds((metrics::kMinRunTimeInSeconds * 1000)); |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.DelayedFramesToRenderer")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DelayedFramesToRenderer", 50)); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples( |
| "WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DelayedFramesToRenderer_AvgDelayInMs", |
| 8)); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, |
| RtcpHistogramsNotUpdatedIfMinRuntimeHasNotPassed) { |
| StreamDataCounters data_counters; |
| data_counters.first_packet_time_ms = fake_clock_.TimeInMilliseconds(); |
| |
| fake_clock_.AdvanceTimeMilliseconds((metrics::kMinRunTimeInSeconds * 1000) - |
| 1); |
| |
| RtcpPacketTypeCounter counter; |
| statistics_proxy_->RtcpPacketTypesCounterUpdated(kRemoteSsrc, counter); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, data_counters, nullptr); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.FirPacketsSentPerMinute")); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.PliPacketsSentPerMinute")); |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.NackPacketsSentPerMinute")); |
| } |
| |
| TEST_F(ReceiveStatisticsProxy2Test, RtcpHistogramsAreUpdated) { |
| StreamDataCounters data_counters; |
| data_counters.first_packet_time_ms = fake_clock_.TimeInMilliseconds(); |
| fake_clock_.AdvanceTimeMilliseconds(metrics::kMinRunTimeInSeconds * 1000); |
| |
| const uint32_t kFirPackets = 100; |
| const uint32_t kPliPackets = 200; |
| const uint32_t kNackPackets = 300; |
| |
| RtcpPacketTypeCounter counter; |
| counter.fir_packets = kFirPackets; |
| counter.pli_packets = kPliPackets; |
| counter.nack_packets = kNackPackets; |
| statistics_proxy_->RtcpPacketTypesCounterUpdated(kRemoteSsrc, counter); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, data_counters, nullptr); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.FirPacketsSentPerMinute")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.PliPacketsSentPerMinute")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.NackPacketsSentPerMinute")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.FirPacketsSentPerMinute", |
| kFirPackets * 60 / metrics::kMinRunTimeInSeconds)); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.PliPacketsSentPerMinute", |
| kPliPackets * 60 / metrics::kMinRunTimeInSeconds)); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.NackPacketsSentPerMinute", |
| kNackPackets * 60 / metrics::kMinRunTimeInSeconds)); |
| } |
| |
| class ReceiveStatisticsProxy2TestWithFreezeDuration |
| : public ReceiveStatisticsProxy2Test, |
| public ::testing::WithParamInterface< |
| std::tuple<uint32_t, uint32_t, uint32_t>> { |
| protected: |
| const uint32_t frame_duration_ms_ = {std::get<0>(GetParam())}; |
| const uint32_t freeze_duration_ms_ = {std::get<1>(GetParam())}; |
| const uint32_t expected_freeze_count_ = {std::get<2>(GetParam())}; |
| }; |
| |
| // It is a freeze if: |
| // frame_duration_ms >= max(3 * avg_frame_duration, avg_frame_duration + 150) |
| // where avg_frame_duration is average duration of last 30 frames including |
| // the current one. |
| // |
| // Condition 1: 3 * avg_frame_duration > avg_frame_duration + 150 |
| const auto kFreezeDetectionCond1Freeze = std::make_tuple(150, 483, 1); |
| const auto kFreezeDetectionCond1NotFreeze = std::make_tuple(150, 482, 0); |
| // Condition 2: 3 * avg_frame_duration < avg_frame_duration + 150 |
| const auto kFreezeDetectionCond2Freeze = std::make_tuple(30, 185, 1); |
| const auto kFreezeDetectionCond2NotFreeze = std::make_tuple(30, 184, 0); |
| |
| INSTANTIATE_TEST_SUITE_P(_, |
| ReceiveStatisticsProxy2TestWithFreezeDuration, |
| ::testing::Values(kFreezeDetectionCond1Freeze, |
| kFreezeDetectionCond1NotFreeze, |
| kFreezeDetectionCond2Freeze, |
| kFreezeDetectionCond2NotFreeze)); |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithFreezeDuration, FreezeDetection) { |
| VideoReceiveStream::Stats stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(0u, stats.freeze_count); |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| // Add a very long frame. This is need to verify that average frame |
| // duration, which is supposed to be calculated as mean of durations of |
| // last 30 frames, is calculated correctly. |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| fake_clock_.AdvanceTimeMilliseconds(2000); |
| |
| for (size_t i = 0; |
| i <= VideoQualityObserver::kAvgInterframeDelaysWindowSizeFrames; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(frame_duration_ms_); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| } |
| |
| fake_clock_.AdvanceTimeMilliseconds(freeze_duration_ms_); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| stats = statistics_proxy_->GetStats(); |
| EXPECT_EQ(stats.freeze_count, expected_freeze_count_); |
| } |
| |
| class ReceiveStatisticsProxy2TestWithContent |
| : public ReceiveStatisticsProxy2Test, |
| public ::testing::WithParamInterface<webrtc::VideoContentType> { |
| protected: |
| const webrtc::VideoContentType content_type_{GetParam()}; |
| }; |
| |
| INSTANTIATE_TEST_SUITE_P(ContentTypes, |
| ReceiveStatisticsProxy2TestWithContent, |
| ::testing::Values(VideoContentType::UNSPECIFIED, |
| VideoContentType::SCREENSHARE)); |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, InterFrameDelaysAreReported) { |
| const int kInterFrameDelayMs = 33; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // One extra with double the interval. |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| const int kExpectedInterFrame = |
| (kInterFrameDelayMs * (kMinRequiredSamples - 1) + |
| kInterFrameDelayMs * 2) / |
| kMinRequiredSamples; |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kExpectedInterFrame, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ( |
| kInterFrameDelayMs * 2, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayMaxInMs")); |
| } else { |
| EXPECT_METRIC_EQ(kExpectedInterFrame, |
| metrics::MinSample("WebRTC.Video.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(kInterFrameDelayMs * 2, |
| metrics::MinSample("WebRTC.Video.InterframeDelayMaxInMs")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, |
| InterFrameDelaysPercentilesAreReported) { |
| const int kInterFrameDelayMs = 33; |
| const int kLastFivePercentsSamples = kMinRequiredSamples * 5 / 100; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i <= kMinRequiredSamples - kLastFivePercentsSamples; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| } |
| // Last 5% of intervals are double in size. |
| for (int i = 0; i < kLastFivePercentsSamples; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(2 * kInterFrameDelayMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| } |
| // Final sample is outlier and 10 times as big. |
| fake_clock_.AdvanceTimeMilliseconds(10 * kInterFrameDelayMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| const int kExpectedInterFrame = kInterFrameDelayMs * 2; |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kExpectedInterFrame, |
| metrics::MinSample( |
| "WebRTC.Video.Screenshare.InterframeDelay95PercentileInMs")); |
| } else { |
| EXPECT_METRIC_EQ( |
| kExpectedInterFrame, |
| metrics::MinSample("WebRTC.Video.InterframeDelay95PercentileInMs")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, |
| MaxInterFrameDelayOnlyWithValidAverage) { |
| const int kInterFrameDelayMs = 33; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| |
| // |kMinRequiredSamples| samples, and thereby intervals, is required. That |
| // means we're one frame short of having a valid data set. |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples("WebRTC.Video.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(0, |
| metrics::NumSamples("WebRTC.Video.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ( |
| 0, metrics::NumSamples("WebRTC.Video.Screenshare.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(0, metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayMaxInMs")); |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, |
| MaxInterFrameDelayOnlyWithPause) { |
| const int kInterFrameDelayMs = 33; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i <= kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| |
| loop_.Flush(); |
| // At this state, we should have a valid inter-frame delay. |
| // Indicate stream paused and make a large jump in time. |
| statistics_proxy_->OnStreamInactive(); |
| fake_clock_.AdvanceTimeMilliseconds(5000); |
| |
| // Insert two more frames. The interval during the pause should be |
| // disregarded in the stats. |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.Screenshare.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ( |
| kInterFrameDelayMs, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ( |
| kInterFrameDelayMs, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayMaxInMs")); |
| } else { |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ(kInterFrameDelayMs, |
| metrics::MinSample("WebRTC.Video.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(kInterFrameDelayMs, |
| metrics::MinSample("WebRTC.Video.InterframeDelayMaxInMs")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, FreezesAreReported) { |
| const int kInterFrameDelayMs = 33; |
| const int kFreezeDelayMs = 200; |
| const int kCallDurationMs = |
| kMinRequiredSamples * kInterFrameDelayMs + kFreezeDelayMs; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| VideoFrameMetaData meta = MetaData(frame); |
| statistics_proxy_->OnDecodedFrame(meta, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // Add extra freeze. |
| fake_clock_.AdvanceTimeMilliseconds(kFreezeDelayMs); |
| VideoFrameMetaData meta = MetaData(frame); |
| statistics_proxy_->OnDecodedFrame(meta, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| const int kExpectedTimeBetweenFreezes = |
| kInterFrameDelayMs * (kMinRequiredSamples - 1); |
| const int kExpectedNumberFreezesPerMinute = 60 * 1000 / kCallDurationMs; |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kFreezeDelayMs + kInterFrameDelayMs, |
| metrics::MinSample("WebRTC.Video.Screenshare.MeanFreezeDurationMs")); |
| EXPECT_METRIC_EQ(kExpectedTimeBetweenFreezes, |
| metrics::MinSample( |
| "WebRTC.Video.Screenshare.MeanTimeBetweenFreezesMs")); |
| EXPECT_METRIC_EQ( |
| kExpectedNumberFreezesPerMinute, |
| metrics::MinSample("WebRTC.Video.Screenshare.NumberFreezesPerMinute")); |
| } else { |
| EXPECT_METRIC_EQ(kFreezeDelayMs + kInterFrameDelayMs, |
| metrics::MinSample("WebRTC.Video.MeanFreezeDurationMs")); |
| EXPECT_METRIC_EQ( |
| kExpectedTimeBetweenFreezes, |
| metrics::MinSample("WebRTC.Video.MeanTimeBetweenFreezesMs")); |
| EXPECT_METRIC_EQ(kExpectedNumberFreezesPerMinute, |
| metrics::MinSample("WebRTC.Video.NumberFreezesPerMinute")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, HarmonicFrameRateIsReported) { |
| const int kFrameDurationMs = 33; |
| const int kFreezeDurationMs = 200; |
| const int kPauseDurationMs = 10000; |
| const int kCallDurationMs = kMinRequiredSamples * kFrameDurationMs + |
| kFreezeDurationMs + kPauseDurationMs; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(kFrameDurationMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| } |
| |
| // Freezes and pauses should be included into harmonic frame rate. |
| // Add freeze. |
| loop_.Flush(); |
| fake_clock_.AdvanceTimeMilliseconds(kFreezeDurationMs); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| // Add pause. |
| loop_.Flush(); |
| fake_clock_.AdvanceTimeMilliseconds(kPauseDurationMs); |
| statistics_proxy_->OnStreamInactive(); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| double kSumSquaredFrameDurationSecs = |
| (kMinRequiredSamples - 1) * |
| (kFrameDurationMs / 1000.0 * kFrameDurationMs / 1000.0); |
| kSumSquaredFrameDurationSecs += |
| kFreezeDurationMs / 1000.0 * kFreezeDurationMs / 1000.0; |
| kSumSquaredFrameDurationSecs += |
| kPauseDurationMs / 1000.0 * kPauseDurationMs / 1000.0; |
| const int kExpectedHarmonicFrameRateFps = |
| std::round(kCallDurationMs / (1000 * kSumSquaredFrameDurationSecs)); |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kExpectedHarmonicFrameRateFps, |
| metrics::MinSample("WebRTC.Video.Screenshare.HarmonicFrameRate")); |
| } else { |
| EXPECT_METRIC_EQ(kExpectedHarmonicFrameRateFps, |
| metrics::MinSample("WebRTC.Video.HarmonicFrameRate")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, PausesAreIgnored) { |
| const int kInterFrameDelayMs = 33; |
| const int kPauseDurationMs = 10000; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i <= kMinRequiredSamples; ++i) { |
| VideoFrameMetaData meta = MetaData(frame); |
| statistics_proxy_->OnDecodedFrame(meta, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // Add a pause. |
| fake_clock_.AdvanceTimeMilliseconds(kPauseDurationMs); |
| statistics_proxy_->OnStreamInactive(); |
| // Second playback interval with triple the length. |
| for (int i = 0; i <= kMinRequiredSamples * 3; ++i) { |
| VideoFrameMetaData meta = MetaData(frame); |
| statistics_proxy_->OnDecodedFrame(meta, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| // Average of two playback intervals. |
| const int kExpectedTimeBetweenFreezes = |
| kInterFrameDelayMs * kMinRequiredSamples * 2; |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ(-1, metrics::MinSample( |
| "WebRTC.Video.Screenshare.MeanFreezeDurationMs")); |
| EXPECT_METRIC_EQ(kExpectedTimeBetweenFreezes, |
| metrics::MinSample( |
| "WebRTC.Video.Screenshare.MeanTimeBetweenFreezesMs")); |
| } else { |
| EXPECT_METRIC_EQ(-1, |
| metrics::MinSample("WebRTC.Video.MeanFreezeDurationMs")); |
| EXPECT_METRIC_EQ( |
| kExpectedTimeBetweenFreezes, |
| metrics::MinSample("WebRTC.Video.MeanTimeBetweenFreezesMs")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, ManyPausesAtTheBeginning) { |
| const int kInterFrameDelayMs = 33; |
| const int kPauseDurationMs = 10000; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i <= kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| |
| statistics_proxy_->OnStreamInactive(); |
| fake_clock_.AdvanceTimeMilliseconds(kPauseDurationMs); |
| |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| // No freezes should be detected, as all long inter-frame delays were |
| // pauses. |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ(-1, metrics::MinSample( |
| "WebRTC.Video.Screenshare.MeanFreezeDurationMs")); |
| } else { |
| EXPECT_METRIC_EQ(-1, |
| metrics::MinSample("WebRTC.Video.MeanFreezeDurationMs")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, TimeInHdReported) { |
| const int kInterFrameDelayMs = 20; |
| webrtc::VideoFrame frame_hd = CreateFrame(1280, 720); |
| webrtc::VideoFrame frame_sd = CreateFrame(640, 360); |
| |
| // HD frames. |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| VideoFrameMetaData meta = MetaData(frame_hd); |
| statistics_proxy_->OnDecodedFrame(meta, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // SD frames. |
| for (int i = 0; i < 2 * kMinRequiredSamples; ++i) { |
| VideoFrameMetaData meta = MetaData(frame_sd); |
| statistics_proxy_->OnDecodedFrame(meta, absl::nullopt, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // Extra last frame. |
| statistics_proxy_->OnRenderedFrame(MetaData(frame_sd)); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| const int kExpectedTimeInHdPercents = 33; |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kExpectedTimeInHdPercents, |
| metrics::MinSample("WebRTC.Video.Screenshare.TimeInHdPercentage")); |
| } else { |
| EXPECT_METRIC_EQ(kExpectedTimeInHdPercents, |
| metrics::MinSample("WebRTC.Video.TimeInHdPercentage")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, TimeInBlockyVideoReported) { |
| const int kInterFrameDelayMs = 20; |
| const int kHighQp = 80; |
| const int kLowQp = 30; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| // High quality frames. |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| VideoFrameMetaData meta = MetaData(frame); |
| statistics_proxy_->OnDecodedFrame(meta, kLowQp, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // Blocky frames. |
| for (int i = 0; i < 2 * kMinRequiredSamples; ++i) { |
| VideoFrameMetaData meta = MetaData(frame); |
| statistics_proxy_->OnDecodedFrame(meta, kHighQp, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(meta); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| // Extra last frame. |
| statistics_proxy_->OnDecodedFrame(frame, kHighQp, 0, content_type_); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame)); |
| |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| const int kExpectedTimeInHdPercents = 66; |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kExpectedTimeInHdPercents, |
| metrics::MinSample( |
| "WebRTC.Video.Screenshare.TimeInBlockyVideoPercentage")); |
| } else { |
| EXPECT_METRIC_EQ( |
| kExpectedTimeInHdPercents, |
| metrics::MinSample("WebRTC.Video.TimeInBlockyVideoPercentage")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, DownscalesReported) { |
| const int kInterFrameDelayMs = 2000; // To ensure long enough call duration. |
| |
| webrtc::VideoFrame frame_hd = CreateFrame(1280, 720); |
| webrtc::VideoFrame frame_sd = CreateFrame(640, 360); |
| webrtc::VideoFrame frame_ld = CreateFrame(320, 180); |
| |
| // Call once to pass content type. |
| statistics_proxy_->OnDecodedFrame(frame_hd, absl::nullopt, 0, content_type_); |
| |
| loop_.Flush(); |
| statistics_proxy_->OnRenderedFrame(MetaData(frame_hd)); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| |
| // Downscale. |
| statistics_proxy_->OnRenderedFrame(MetaData(frame_sd)); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| |
| // Downscale. |
| statistics_proxy_->OnRenderedFrame(MetaData(frame_ld)); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| |
| statistics_proxy_->UpdateHistograms(absl::nullopt, StreamDataCounters(), |
| nullptr); |
| const int kExpectedDownscales = 30; // 2 per 4 seconds = 30 per minute. |
| if (videocontenttypehelpers::IsScreenshare(content_type_)) { |
| EXPECT_METRIC_EQ( |
| kExpectedDownscales, |
| metrics::MinSample("WebRTC.Video.Screenshare." |
| "NumberResolutionDownswitchesPerMinute")); |
| } else { |
| EXPECT_METRIC_EQ(kExpectedDownscales, |
| metrics::MinSample( |
| "WebRTC.Video.NumberResolutionDownswitchesPerMinute")); |
| } |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, DecodeTimeReported) { |
| const int kInterFrameDelayMs = 20; |
| const int kLowQp = 30; |
| const int kDecodeMs = 7; |
| |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| for (int i = 0; i < kMinRequiredSamples; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, kLowQp, kDecodeMs, content_type_); |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs); |
| } |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumEvents("WebRTC.Video.DecodeTimeInMs", kDecodeMs)); |
| } |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithContent, |
| StatsAreSlicedOnSimulcastAndExperiment) { |
| const uint8_t experiment_id = 1; |
| webrtc::VideoContentType content_type = content_type_; |
| videocontenttypehelpers::SetExperimentId(&content_type, experiment_id); |
| const int kInterFrameDelayMs1 = 30; |
| const int kInterFrameDelayMs2 = 50; |
| webrtc::VideoFrame frame = CreateFrame(kWidth, kHeight); |
| |
| videocontenttypehelpers::SetSimulcastId(&content_type, 1); |
| for (int i = 0; i <= kMinRequiredSamples; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs1); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type); |
| } |
| |
| videocontenttypehelpers::SetSimulcastId(&content_type, 2); |
| for (int i = 0; i <= kMinRequiredSamples; ++i) { |
| fake_clock_.AdvanceTimeMilliseconds(kInterFrameDelayMs2); |
| statistics_proxy_->OnDecodedFrame(frame, absl::nullopt, 0, content_type); |
| } |
| FlushAndUpdateHistograms(absl::nullopt, StreamDataCounters(), nullptr); |
| |
| if (videocontenttypehelpers::IsScreenshare(content_type)) { |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.Screenshare.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayInMs.S0")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayMaxInMs.S0")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayInMs.S1")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples( |
| "WebRTC.Video.Screenshare.InterframeDelayMaxInMs.S1")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.Screenshare.InterframeDelayInMs" |
| ".ExperimentGroup0")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.Screenshare.InterframeDelayMaxInMs" |
| ".ExperimentGroup0")); |
| EXPECT_METRIC_EQ( |
| kInterFrameDelayMs1, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayInMs.S0")); |
| EXPECT_METRIC_EQ( |
| kInterFrameDelayMs2, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayInMs.S1")); |
| EXPECT_METRIC_EQ( |
| (kInterFrameDelayMs1 + kInterFrameDelayMs2) / 2, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ( |
| kInterFrameDelayMs2, |
| metrics::MinSample("WebRTC.Video.Screenshare.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ( |
| (kInterFrameDelayMs1 + kInterFrameDelayMs2) / 2, |
| metrics::MinSample( |
| "WebRTC.Video.Screenshare.InterframeDelayInMs.ExperimentGroup0")); |
| } else { |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.InterframeDelayInMs.S0")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.InterframeDelayMaxInMs.S0")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.InterframeDelayInMs.S1")); |
| EXPECT_METRIC_EQ( |
| 1, metrics::NumSamples("WebRTC.Video.InterframeDelayMaxInMs.S1")); |
| EXPECT_METRIC_EQ(1, metrics::NumSamples("WebRTC.Video.InterframeDelayInMs" |
| ".ExperimentGroup0")); |
| EXPECT_METRIC_EQ(1, |
| metrics::NumSamples("WebRTC.Video.InterframeDelayMaxInMs" |
| ".ExperimentGroup0")); |
| EXPECT_METRIC_EQ(kInterFrameDelayMs1, |
| metrics::MinSample("WebRTC.Video.InterframeDelayInMs.S0")); |
| EXPECT_METRIC_EQ(kInterFrameDelayMs2, |
| metrics::MinSample("WebRTC.Video.InterframeDelayInMs.S1")); |
| EXPECT_METRIC_EQ((kInterFrameDelayMs1 + kInterFrameDelayMs2) / 2, |
| metrics::MinSample("WebRTC.Video.InterframeDelayInMs")); |
| EXPECT_METRIC_EQ(kInterFrameDelayMs2, |
| metrics::MinSample("WebRTC.Video.InterframeDelayMaxInMs")); |
| EXPECT_METRIC_EQ((kInterFrameDelayMs1 + kInterFrameDelayMs2) / 2, |
| metrics::MinSample( |
| "WebRTC.Video.InterframeDelayInMs.ExperimentGroup0")); |
| } |
| } |
| |
| class DecodeTimeHistogramsKillswitch { |
| public: |
| explicit DecodeTimeHistogramsKillswitch(bool disable_histograms) |
| : field_trial_(disable_histograms |
| ? "WebRTC-DecodeTimeHistogramsKillSwitch/Enabled/" |
| : "") {} |
| |
| private: |
| webrtc::test::ScopedFieldTrials field_trial_; |
| }; |
| |
| class ReceiveStatisticsProxy2TestWithDecodeTimeHistograms |
| : public DecodeTimeHistogramsKillswitch, |
| public ::testing::WithParamInterface< |
| std::tuple<bool, int, int, int, VideoCodecType, std::string>>, |
| public ReceiveStatisticsProxy2Test { |
| public: |
| ReceiveStatisticsProxy2TestWithDecodeTimeHistograms() |
| : DecodeTimeHistogramsKillswitch(std::get<0>(GetParam())) {} |
| |
| protected: |
| const std::string kUmaPrefix = "WebRTC.Video.DecodeTimePerFrameInMs."; |
| const int expected_number_of_samples_ = {std::get<1>(GetParam())}; |
| const int width_ = {std::get<2>(GetParam())}; |
| const int height_ = {std::get<3>(GetParam())}; |
| const VideoCodecType codec_type_ = {std::get<4>(GetParam())}; |
| const std::string implementation_name_ = {std::get<5>(GetParam())}; |
| const std::string uma_histogram_name_ = |
| kUmaPrefix + (codec_type_ == kVideoCodecVP9 ? "Vp9." : "H264.") + |
| (height_ == 2160 ? "4k." : "Hd.") + |
| (implementation_name_.compare("ExternalDecoder") == 0 ? "Hw" : "Sw"); |
| }; |
| |
| TEST_P(ReceiveStatisticsProxy2TestWithDecodeTimeHistograms, |
| DecodeTimeHistogramsUpdated) { |
| constexpr int kNumberOfFrames = 10; |
| constexpr int kDecodeTimeMs = 7; |
| constexpr int kFrameDurationMs = 1000 / 60; |
| |
| webrtc::VideoFrame frame = CreateFrame(width_, height_); |
| |
| statistics_proxy_->OnDecoderImplementationName(implementation_name_.c_str()); |
| statistics_proxy_->OnPreDecode(codec_type_, /*qp=*/0); |
| |
| for (int i = 0; i < kNumberOfFrames; ++i) { |
| statistics_proxy_->OnDecodedFrame(frame, /*qp=*/absl::nullopt, |
| kDecodeTimeMs, |
| VideoContentType::UNSPECIFIED); |
| fake_clock_.AdvanceTimeMilliseconds(kFrameDurationMs); |
| } |
| |
| loop_.Flush(); |
| |
| EXPECT_METRIC_EQ(expected_number_of_samples_, |
| metrics::NumSamples(uma_histogram_name_)); |
| EXPECT_METRIC_EQ(expected_number_of_samples_, |
| metrics::NumEvents(uma_histogram_name_, kDecodeTimeMs)); |
| } |
| |
| const auto kVp94kHw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/3840, |
| /*height=*/2160, |
| kVideoCodecVP9, |
| /*implementation=*/"ExternalDecoder"); |
| const auto kVp94kSw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/3840, |
| /*height=*/2160, |
| kVideoCodecVP9, |
| /*implementation=*/"libvpx"); |
| const auto kVp9HdHw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/1920, |
| /*height=*/1080, |
| kVideoCodecVP9, |
| /*implementation=*/"ExternalDecoder"); |
| const auto kVp9HdSw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/1920, |
| /*height=*/1080, |
| kVideoCodecVP9, |
| /*implementation=*/"libvpx"); |
| const auto kH2644kHw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/3840, |
| /*height=*/2160, |
| kVideoCodecH264, |
| /*implementation=*/"ExternalDecoder"); |
| const auto kH2644kSw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/3840, |
| /*height=*/2160, |
| kVideoCodecH264, |
| /*implementation=*/"FFmpeg"); |
| const auto kH264HdHw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/1920, |
| /*height=*/1080, |
| kVideoCodecH264, |
| /*implementation=*/"ExternalDecoder"); |
| const auto kH264HdSw = std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/1920, |
| /*height=*/1080, |
| kVideoCodecH264, |
| /*implementation=*/"FFmpeg"); |
| |
| INSTANTIATE_TEST_SUITE_P(AllHistogramsPopulated, |
| ReceiveStatisticsProxy2TestWithDecodeTimeHistograms, |
| ::testing::Values(kVp94kHw, |
| kVp94kSw, |
| kVp9HdHw, |
| kVp9HdSw, |
| kH2644kHw, |
| kH2644kSw, |
| kH264HdHw, |
| kH264HdSw)); |
| |
| const auto kKillswitchDisabled = |
| std::make_tuple(/*killswitch=*/false, |
| /*expected_number_of_samples=*/10, |
| /*width=*/1920, |
| /*height=*/1080, |
| kVideoCodecVP9, |
| /*implementation=*/"libvpx"); |
| const auto kKillswitchEnabled = |
| std::make_tuple(/*killswitch=*/true, |
| /*expected_number_of_samples=*/0, |
| /*width=*/1920, |
| /*height=*/1080, |
| kVideoCodecVP9, |
| /*implementation=*/"libvpx"); |
| |
| INSTANTIATE_TEST_SUITE_P(KillswitchEffective, |
| ReceiveStatisticsProxy2TestWithDecodeTimeHistograms, |
| ::testing::Values(kKillswitchDisabled, |
| kKillswitchEnabled)); |
| |
| } // namespace internal |
| } // namespace webrtc |
