1 files changed, 108 insertions, 0 deletions
diff --git a/third_party/libwebrtc/test/jitter/delay_variation_calculator_unittest.cc b/third_party/libwebrtc/test/jitter/delay_variation_calculator_unittest.cc
new file mode 100644
index 0000000000..41db376ed6
--- /dev/null
+++ b/third_party/libwebrtc/test/jitter/delay_variation_calculator_unittest.cc
@@ -0,0 +1,108 @@
+/*
+ *  Copyright 2023 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 "test/jitter/delay_variation_calculator.h"
+
+#include "api/numerics/samples_stats_counter.h"
+#include "api/units/timestamp.h"
+#include "test/gmock.h"
+#include "test/gtest.h"
+
+namespace webrtc {
+namespace test {
+
+MATCHER_P(HasLength, s, "") {
+  bool c1 = arg.rtp_timestamps.NumSamples() == s;
+  bool c2 = arg.arrival_times_ms.NumSamples() == s;
+  bool c3 = arg.sizes_bytes.NumSamples() == s;
+  bool c4 = arg.inter_departure_times_ms.NumSamples() == s;
+  bool c5 = arg.inter_arrival_times_ms.NumSamples() == s;
+  bool c6 = arg.inter_delay_variations_ms.NumSamples() == s;
+  bool c7 = arg.inter_size_variations_bytes.NumSamples() == s;
+  *result_listener << "c: " << c1 << c2 << c3 << c4 << c5 << c6 << c7;
+  return c1 && c2 && c3 && c4 && c5 && c6 && c7;
+}
+
+TEST(DelayVariationCalculatorTest, NoTimeSeriesWithoutFrame) {
+  DelayVariationCalculator calc;
+
+  EXPECT_THAT(calc.time_series(), HasLength(0));
+}
+
+TEST(DelayVariationCalculatorTest, PartialTimeSeriesWithOneFrame) {
+  DelayVariationCalculator calc;
+
+  calc.Insert(3000, Timestamp::Millis(33), DataSize::Bytes(100));
+
+  DelayVariationCalculator::TimeSeries ts = calc.time_series();
+  ASSERT_THAT(ts, HasLength(1));
+  auto v0 = [](const SamplesStatsCounter& c) {
+    return c.GetTimedSamples()[0].value;
+  };
+  EXPECT_EQ(v0(ts.rtp_timestamps), 3000);
+  EXPECT_EQ(v0(ts.arrival_times_ms), 33);
+  EXPECT_EQ(v0(ts.sizes_bytes), 100);
+  EXPECT_EQ(v0(ts.inter_departure_times_ms), 0);
+  EXPECT_EQ(v0(ts.inter_arrival_times_ms), 0);
+  EXPECT_EQ(v0(ts.inter_delay_variations_ms), 0);
+  EXPECT_EQ(v0(ts.inter_size_variations_bytes), 0);
+}
+
+TEST(DelayVariationCalculatorTest, TimeSeriesWithTwoFrames) {
+  DelayVariationCalculator calc;
+
+  calc.Insert(3000, Timestamp::Millis(33), DataSize::Bytes(100));
+  calc.Insert(6000, Timestamp::Millis(66), DataSize::Bytes(100));
+
+  DelayVariationCalculator::TimeSeries ts = calc.time_series();
+  ASSERT_THAT(ts, HasLength(2));
+  auto v1 = [](const SamplesStatsCounter& c) {
+    return c.GetTimedSamples()[1].value;
+  };
+  EXPECT_EQ(v1(ts.rtp_timestamps), 6000);
+  EXPECT_EQ(v1(ts.arrival_times_ms), 66);
+  EXPECT_EQ(v1(ts.sizes_bytes), 100);
+  EXPECT_EQ(v1(ts.inter_departure_times_ms), 33.333);
+  EXPECT_EQ(v1(ts.inter_arrival_times_ms), 33);
+  EXPECT_EQ(v1(ts.inter_delay_variations_ms), -0.333);
+  EXPECT_EQ(v1(ts.inter_size_variations_bytes), 0);
+}
+
+TEST(DelayVariationCalculatorTest, MetadataRecordedForAllTimeSeriesAndFrames) {
+  DelayVariationCalculator calc;
+
+  calc.Insert(3000, Timestamp::Millis(33), DataSize::Bytes(100), /*sl=*/0,
+              /*tl=*/0, VideoFrameType::kVideoFrameKey);
+  calc.Insert(6000, Timestamp::Millis(66), DataSize::Bytes(100), /*sl=*/0,
+              /*tl=*/1, VideoFrameType::kVideoFrameDelta);
+
+  DelayVariationCalculator::TimeSeries ts = calc.time_series();
+  ASSERT_THAT(ts, HasLength(2));
+  auto v = [](const SamplesStatsCounter* c, int n, std::string key) {
+    return c->GetTimedSamples()[n].metadata.at(key);
+  };
+  for (const auto* c :
+       {&ts.rtp_timestamps, &ts.arrival_times_ms, &ts.sizes_bytes,
+        &ts.inter_departure_times_ms, &ts.inter_arrival_times_ms,
+        &ts.inter_delay_variations_ms, &ts.inter_size_variations_bytes}) {
+    EXPECT_EQ(v(c, 0, "sl"), "0");
+    EXPECT_EQ(v(c, 0, "tl"), "0");
+    EXPECT_EQ(v(c, 0, "frame_type"), "key");
+    EXPECT_EQ(v(c, 1, "sl_prev"), "0");
+    EXPECT_EQ(v(c, 1, "tl_prev"), "0");
+    EXPECT_EQ(v(c, 1, "frame_type_prev"), "key");
+    EXPECT_EQ(v(c, 1, "sl"), "0");
+    EXPECT_EQ(v(c, 1, "tl"), "1");
+    EXPECT_EQ(v(c, 1, "frame_type"), "delta");
+  }
+}
+
+}  // namespace test
+}  // namespace webrtc