diff options
Diffstat (limited to 'third_party/libwebrtc/modules/rtp_rtcp/source/absolute_capture_time_interpolator_unittest.cc')
-rw-r--r-- | third_party/libwebrtc/modules/rtp_rtcp/source/absolute_capture_time_interpolator_unittest.cc | 353 |
1 files changed, 353 insertions, 0 deletions
diff --git a/third_party/libwebrtc/modules/rtp_rtcp/source/absolute_capture_time_interpolator_unittest.cc b/third_party/libwebrtc/modules/rtp_rtcp/source/absolute_capture_time_interpolator_unittest.cc new file mode 100644 index 0000000000..6a312f9b43 --- /dev/null +++ b/third_party/libwebrtc/modules/rtp_rtcp/source/absolute_capture_time_interpolator_unittest.cc @@ -0,0 +1,353 @@ +/* + * Copyright (c) 2019 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 "modules/rtp_rtcp/source/absolute_capture_time_interpolator.h" + +#include "system_wrappers/include/ntp_time.h" +#include "test/gmock.h" +#include "test/gtest.h" + +namespace webrtc { + +TEST(AbsoluteCaptureTimeInterpolatorTest, GetSourceWithoutCsrcs) { + constexpr uint32_t kSsrc = 12; + + EXPECT_EQ(AbsoluteCaptureTimeInterpolator::GetSource(kSsrc, nullptr), kSsrc); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, GetSourceWithCsrcs) { + constexpr uint32_t kSsrc = 12; + constexpr uint32_t kCsrcs[] = {34, 56, 78, 90}; + + EXPECT_EQ(AbsoluteCaptureTimeInterpolator::GetSource(kSsrc, kCsrcs), + kCsrcs[0]); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, ReceiveExtensionReturnsExtension) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 1280; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9020), absl::nullopt}; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp1, + kRtpClockFrequency, kExtension1), + kExtension1); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, + ReceiveNoExtensionReturnsNoExtension) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 1280; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + absl::nullopt); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp1, + kRtpClockFrequency, kExtension1), + absl::nullopt); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, InterpolateLaterPacketArrivingLater) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 1280; + constexpr uint32_t kRtpTimestamp2 = kRtpTimestamp0 + 2560; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension2 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + absl::optional<AbsoluteCaptureTime> extension = interpolator.OnReceivePacket( + kSource, kRtpTimestamp1, kRtpClockFrequency, kExtension1); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) + 20); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); + + extension = interpolator.OnReceivePacket(kSource, kRtpTimestamp2, + kRtpClockFrequency, kExtension2); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) + 40); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, + InterpolateEarlierPacketArrivingLater) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 - 1280; + constexpr uint32_t kRtpTimestamp2 = kRtpTimestamp0 - 2560; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension2 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + absl::optional<AbsoluteCaptureTime> extension = interpolator.OnReceivePacket( + kSource, kRtpTimestamp1, kRtpClockFrequency, kExtension1); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) - 20); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); + + extension = interpolator.OnReceivePacket(kSource, kRtpTimestamp2, + kRtpClockFrequency, kExtension2); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) - 40); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, + InterpolateLaterPacketArrivingLaterWithRtpTimestampWrapAround) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = ~uint32_t{0} - 79; + constexpr uint32_t kRtpTimestamp1 = 1280 - 80; + constexpr uint32_t kRtpTimestamp2 = 2560 - 80; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension2 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + absl::optional<AbsoluteCaptureTime> extension = interpolator.OnReceivePacket( + kSource, kRtpTimestamp1, kRtpClockFrequency, kExtension1); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) + 20); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); + + extension = interpolator.OnReceivePacket(kSource, kRtpTimestamp2, + kRtpClockFrequency, kExtension2); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) + 40); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, + InterpolateEarlierPacketArrivingLaterWithRtpTimestampWrapAround) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 799; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 - 1280; + constexpr uint32_t kRtpTimestamp2 = kRtpTimestamp0 - 2560; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension2 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + absl::optional<AbsoluteCaptureTime> extension = interpolator.OnReceivePacket( + kSource, kRtpTimestamp1, kRtpClockFrequency, kExtension1); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) - 20); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); + + extension = interpolator.OnReceivePacket(kSource, kRtpTimestamp2, + kRtpClockFrequency, kExtension2); + EXPECT_TRUE(extension.has_value()); + EXPECT_EQ(UQ32x32ToInt64Ms(extension->absolute_capture_timestamp), + UQ32x32ToInt64Ms(kExtension0->absolute_capture_timestamp) - 40); + EXPECT_EQ(extension->estimated_capture_clock_offset, + kExtension0->estimated_capture_clock_offset); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, SkipInterpolateIfTooLate) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 1280; + constexpr uint32_t kRtpTimestamp2 = kRtpTimestamp1 + 1280; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension2 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + clock.AdvanceTime(AbsoluteCaptureTimeInterpolator::kInterpolationMaxInterval); + + EXPECT_TRUE(interpolator + .OnReceivePacket(kSource, kRtpTimestamp1, kRtpClockFrequency, + kExtension1) + .has_value()); + + clock.AdvanceTimeMilliseconds(1); + + EXPECT_FALSE(interpolator + .OnReceivePacket(kSource, kRtpTimestamp2, kRtpClockFrequency, + kExtension2) + .has_value()); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, SkipInterpolateIfSourceChanged) { + constexpr uint32_t kSource0 = 1337; + constexpr uint32_t kSource1 = 1338; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 1280; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource0, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + EXPECT_FALSE(interpolator + .OnReceivePacket(kSource1, kRtpTimestamp1, + kRtpClockFrequency, kExtension1) + .has_value()); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, + SkipInterpolateIfRtpClockFrequencyChanged) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency0 = 64000; + constexpr uint32_t kRtpClockFrequency1 = 32000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 640; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency0, kExtension0), + kExtension0); + + EXPECT_FALSE(interpolator + .OnReceivePacket(kSource, kRtpTimestamp1, + kRtpClockFrequency1, kExtension1) + .has_value()); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, + SkipInterpolateIfRtpClockFrequencyIsInvalid) { + constexpr uint32_t kSource = 1337; + constexpr uint32_t kRtpClockFrequency = 0; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 640; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + EXPECT_FALSE(interpolator + .OnReceivePacket(kSource, kRtpTimestamp1, kRtpClockFrequency, + kExtension1) + .has_value()); +} + +TEST(AbsoluteCaptureTimeInterpolatorTest, SkipInterpolateIsSticky) { + constexpr uint32_t kSource0 = 1337; + constexpr uint32_t kSource1 = 1338; + constexpr uint32_t kSource2 = 1337; + constexpr uint32_t kRtpClockFrequency = 64000; + constexpr uint32_t kRtpTimestamp0 = 1020300000; + constexpr uint32_t kRtpTimestamp1 = kRtpTimestamp0 + 1280; + constexpr uint32_t kRtpTimestamp2 = kRtpTimestamp1 + 1280; + static const absl::optional<AbsoluteCaptureTime> kExtension0 = + AbsoluteCaptureTime{Int64MsToUQ32x32(9000), Int64MsToQ32x32(-350)}; + static const absl::optional<AbsoluteCaptureTime> kExtension1 = absl::nullopt; + static const absl::optional<AbsoluteCaptureTime> kExtension2 = absl::nullopt; + + SimulatedClock clock(0); + AbsoluteCaptureTimeInterpolator interpolator(&clock); + + EXPECT_EQ(interpolator.OnReceivePacket(kSource0, kRtpTimestamp0, + kRtpClockFrequency, kExtension0), + kExtension0); + + EXPECT_FALSE(interpolator + .OnReceivePacket(kSource1, kRtpTimestamp1, + kRtpClockFrequency, kExtension1) + .has_value()); + + EXPECT_FALSE(interpolator + .OnReceivePacket(kSource2, kRtpTimestamp2, + kRtpClockFrequency, kExtension2) + .has_value()); +} + +} // namespace webrtc |