Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(314)

Unified Diff: webrtc/voice_engine/transport_feedback_packet_loss_tracker_unittest.cc

Issue 2579613003: Add TransportFeedbackPacketLossTracker. (Closed)
Patch Set: adding a missing file (continuation of PS7) Created 4 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webrtc/voice_engine/transport_feedback_packet_loss_tracker_unittest.cc
diff --git a/webrtc/voice_engine/transport_feedback_packet_loss_tracker_unittest.cc b/webrtc/voice_engine/transport_feedback_packet_loss_tracker_unittest.cc
new file mode 100644
index 0000000000000000000000000000000000000000..3706fca748f3d0a40ef1097db02b97e64e497293
--- /dev/null
+++ b/webrtc/voice_engine/transport_feedback_packet_loss_tracker_unittest.cc
@@ -0,0 +1,719 @@
+/*
+ * Copyright (c) 2015 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 <limits>
+#include <memory>
+#include <vector>
+
+#include "webrtc/base/checks.h"
+#include "webrtc/base/mod_ops.h"
+#include "webrtc/modules/rtp_rtcp/mocks/mock_transport_feedback.h"
+#include "webrtc/test/gmock.h"
+#include "webrtc/test/gtest.h"
+#include "webrtc/voice_engine/transport_feedback_packet_loss_tracker.h"
+
+using webrtc::rtcp::MockTransportFeedback;
+using webrtc::rtcp::TransportFeedback;
+using testing::Return;
+using testing::StrictMock;
+
+namespace webrtc {
+
+namespace {
+
+constexpr size_t kMaxConsecutiveOldReports = 4;
+
+// All tests are run multiple times with various baseline sequence number,
+// to weed out potential bugs with wrap-around handling.
+constexpr uint16_t kBases[] = {0x0000, 0x3456, 0xc032, 0xfffe};
+
+void AddTransportFeedbackAndValidate(
+ TransportFeedbackPacketLossTracker* tracker,
+ uint16_t base_sequence_num,
+ const std::vector<bool>& reception_status_vec) {
+ std::vector<TransportFeedback::StatusSymbol> statuses;
+ for (bool status : reception_status_vec) {
+ if (!status) {
+ statuses.push_back(TransportFeedback::StatusSymbol::kNotReceived);
+ } else {
+ // |kReceivedSmallDelta| and |kReceivedLargeDelta| make no difference to
+ // TransportFeedbackPacketLossTracker. So we test only one case.
+ statuses.push_back(TransportFeedback::StatusSymbol::kReceivedSmallDelta);
+ }
+ }
+ StrictMock<MockTransportFeedback> mock_feedback;
+ EXPECT_CALL(mock_feedback, GetBaseSequence())
+ .WillOnce(Return(base_sequence_num));
+ EXPECT_CALL(mock_feedback, GetStatusVector()).WillOnce(Return(statuses));
+ tracker->OnReceivedTransportFeedback(mock_feedback);
+ tracker->Validate();
+}
+
+} // namespace
+
+// Sanity check on an empty window.
+TEST(TransportFeedbackPacketLossTrackerTest, EmptyWindow) {
+ std::unique_ptr<TransportFeedback> feedback;
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // PLR and CPLR reported as unknown before reception of first feedback.
+ EXPECT_FALSE(tracker.GetPacketLossRates(&plr, &cplr));
+}
+
+// Sanity check on partially filled window.
+TEST(TransportFeedbackPacketLossTrackerTest, PartiallyFilledWindow) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // PLR and CPLR reported as unknown before minimum window size reached.
+ // Expected window contents: [] -> [1001].
+ AddTransportFeedbackAndValidate(&tracker, base, {true, false, false, true});
+ EXPECT_FALSE(tracker.GetPacketLossRates(&plr, &cplr));
+ }
+}
+
+// Sanity check on minimum filled window.
+TEST(TransportFeedbackPacketLossTrackerTest, MinimumFilledWindow) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // PLR and CPLR correctly calculated after minimum window size reached.
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+}
+
+// Additional reports update PLR and CPLR.
+TEST(TransportFeedbackPacketLossTrackerTest, ExtendWindow) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Expected window contents: [10011] -> [10011-10101].
+ AddTransportFeedbackAndValidate(&tracker, base + 5,
+ {true, false, true, false, true});
+
+ // Expected window contents: [10011-10101] -> [10011-10101-10001].
+ AddTransportFeedbackAndValidate(&tracker, base + 10,
+ {true, false, false, false, true});
+
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 7.0f / 15.0f);
+ EXPECT_EQ(cplr, 3.0f / 15.0f);
+ }
+}
+
+TEST(TransportFeedbackPacketLossTrackerTest, AllReceived) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // PLR and CPLR correctly calculated after minimum window size reached.
+ // Expected window contents: [] -> [11111].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, true, true, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 0.0f);
+ EXPECT_EQ(cplr, 0.0f);
+ }
+}
+
+TEST(TransportFeedbackPacketLossTrackerTest, AllLost) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // PLR and CPLR correctly calculated after minimum window size reached.
+ // Expected window contents: [] -> [00000].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {false, false, false, false, false});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 5.0f / 5.0f);
+ EXPECT_EQ(cplr, 4.0f / 5.0f);
+ }
+}
+
+// Repeated reports are ignored.
+TEST(TransportFeedbackPacketLossTrackerTest, ReportRepetition) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Repeat entire previous feedback
+ // Expected window contents: [10011] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+}
+
+// Report overlap.
+TEST(TransportFeedbackPacketLossTrackerTest, ReportOverlap) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Expected window contents: [10011] -> [10011-01].
+ AddTransportFeedbackAndValidate(&tracker, base + 3,
+ {true, true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 3.0f / 7.0f);
+ EXPECT_EQ(cplr, 1.0f / 7.0f);
+ }
+}
+
+// Report conflict.
+TEST(TransportFeedbackPacketLossTrackerTest, ReportConflict) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // Expected window contents: [] -> [01001].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {false, true, false, false, true});
+
+ // Expected window contents: [01001] -> [11101].
+ // While false->true will be applied, true -> false will be ignored.
+ AddTransportFeedbackAndValidate(&tracker, base, {true, false, true});
+
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 1.0f / 5.0f);
+ EXPECT_EQ(cplr, 0.0f / 5.0f);
+ }
+}
+
+// Skipped packets treated as unknown (not lost).
+TEST(TransportFeedbackPacketLossTrackerTest, SkippedPackets) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 10);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Expected window contents: [10011] -> [10011-101].
+ AddTransportFeedbackAndValidate(&tracker, base + 100, {true, false, true});
+
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 3.0f / 8.0f);
+ EXPECT_EQ(cplr, 1.0f / 8.0f);
+ }
+}
+
+// The window retain information up to the configured max-window-size, but
+// starts discarding after that.
+TEST(TransportFeedbackPacketLossTrackerTest, MaxWindowSize) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(10, 10);
+
+ // Expected window contents: [] -> [10101-00001].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, true, false, true, false, false, false, false, true});
+
+ // Up to max-window-size retained.
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 6.0f / 10.0f);
+ EXPECT_EQ(cplr, 3.0f / 10.0f);
+
+ // Expected window contents: [10101-00001] -> [00001-10111].
+ AddTransportFeedbackAndValidate(&tracker, base + 10,
+ {true, false, true, true, true});
+
+ // After max-window-size, older entries discarded to accommodate newer ones.
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 5.0f / 10.0f);
+ EXPECT_EQ(cplr, 3.0f / 10.0f);
+ }
+}
+
+// Inserting into the middle of a full window works correctly.
+TEST(TransportFeedbackPacketLossTrackerTest, InsertIntoMiddle) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(10, 10);
+
+ // Expected window contents: [] -> [10101].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, true, false, true});
+
+ // Expected window contents: [10101] -> [10101-10001].
+ AddTransportFeedbackAndValidate(&tracker, base + 100,
+ {true, false, false, false, true});
+
+ // Setup sanity
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 5.0f / 10.0f);
+ EXPECT_EQ(cplr, 2.0f / 10.0f);
+
+ // Insert into the middle of this full window - it discards the older data.
+ // Expected window contents: [10101-10001] -> [11111-10001].
+ AddTransportFeedbackAndValidate(&tracker, base + 50,
+ {true, true, true, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 3.0f / 10.0f);
+ EXPECT_EQ(cplr, 2.0f / 10.0f);
+ }
+}
+
+// Entries in the second quadrant treated like those in the first.
+// The sequence number is used in a looped manner. 0xFFFF is followed by 0x0000.
kwiberg-webrtc 2017/01/05 02:51:12 I think the usual term is "wrapped", as in "after
minyue-webrtc 2017/01/19 10:57:55 the word was chosen to explain why "quadrant", as
+// In many tests, we divide the circle of sequence number into 4 quadrants, and
+// verify the behavior of TransportFeedbackPacketLossTracker over them.
kwiberg-webrtc 2017/01/05 02:51:12 So each quadrant is 14 bits' worth of sequence num
minyue-webrtc 2017/01/19 10:57:55 I updated the wording here. See if that helps.
+TEST(TransportFeedbackPacketLossTrackerTest, SecondQuadrant) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Window *does* get updated with inputs from quadrant #2.
+ // Expected window contents: [10011] -> [10011-1].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x4321, {true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 6.0f);
+ EXPECT_EQ(cplr, 1.0f / 6.0f);
+
+ // Correct recognition of quadrant #2: up to, but not including, base +
+ // 0x8000
+ // Expected window contents: [10011-1] -> [10011-11].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x7fff, {true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 7.0f);
+ EXPECT_EQ(cplr, 1.0f / 7.0f);
+ }
+}
+
+// Insertion into the third quadrant moves the base of the window.
+TEST(TransportFeedbackPacketLossTrackerTest, ThirdQuadrantMovesBase) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Seed the test.
+ // Expected window contents: [] -> [10011-01].
+ AddTransportFeedbackAndValidate(
+ &tracker, base, {true, false, false, true, true, false, true});
+
+ // Quadrant #3 begins at base + 0x8000. It triggers moving the window so
+ // that
+ // at least one (oldest) report shifts out of window.
+ // Expected window contents: [10011-01] -> [10110-01].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8000,
+ {true, false, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 3.0f / 7.0f);
+ EXPECT_EQ(cplr, 1.0f / 7.0f);
+
+ // The base can move more than once, because the minimum quadrant-1 packets
+ // were dropped out of the window, and some remain.
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8000 + 4, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 7.0f);
+ EXPECT_EQ(cplr, 1.0f / 7.0f);
+ }
+}
+
+// After the base has moved due to insertion into the third quadrant, it is
+// still possible to insert into the middle of the window and obtain the correct
+// PLR and CPLR. Insertion into the middle before the max window size has been
+// achieved does not cause older packets to be dropped.
+TEST(TransportFeedbackPacketLossTrackerTest, InsertIntoMiddleAfterBaseMove) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Seed the test.
+ // Expected window contents: [] -> [10011-01].
+ AddTransportFeedbackAndValidate(
+ &tracker, base, {true, false, false, true, true, false, true});
+
+ // Expected window contents: [10011-01] -> [10110-01].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8000,
+ {true, false, false, true});
+
+ // Inserting into the middle still works after the base has shifted.
+ // Expected window contents: [10110-01] -> [10110-01011-001].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x5000,
+ {true, false, false, true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 6.0f / 13.0f);
+ EXPECT_EQ(cplr, 2.0f / 13.0f);
+
+ // The base can keep moving after inserting into the middle.
+ // Expected window contents: [10110-01011-001] -> [11001-01100-111].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8000 + 4, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 5.0f / 13.0f);
+ EXPECT_EQ(cplr, 2.0f / 13.0f);
+ }
+}
+
+// After moving the base of the window, the max window size is still observed.
+TEST(TransportFeedbackPacketLossTrackerTest, ThirdQuadrantObservesMaxWindow) {
kwiberg-webrtc 2017/01/05 02:51:12 Aha, who's the eagle eye, I wonder...
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(10, 15);
+
+ // Expected window contents: [] -> [10011-10101].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, false, true, true, true, false, true, false, true});
+
+ // Expected window contents: [10011-10101] -> [11101-01101].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8000,
+ {true, false, true});
+
+ // Push into middle until max window is reached.
+ // Expected window contents: [11101-01101] -> [11101-01100-01101].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x4000,
+ {true, false, false, false, true});
+
+ // Setup sanity
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 6.0f / 15.0f);
+ EXPECT_EQ(cplr, 2.0f / 15.0f);
+
+ // Pushing new packets into the middle would discard older packets.
+ // Expected window contents: [11101-01100-01101] -> [01011-00011-01101].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x4000 + 5,
+ {true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 7.0f / 15.0f);
+ EXPECT_EQ(cplr, 2.0f / 15.0f);
+ }
+}
+
+// A new feedback in quadrant #3 might shift enough old feedbacks out of window,
+// that we'd go back to an unknown PLR and CPLR.
+TEST(TransportFeedbackPacketLossTrackerTest, QuadrantThreeMovedBaseMinWindow) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011-10101].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, false, true, true, true, false, true, false, true});
+ EXPECT_TRUE(
+ tracker.GetPacketLossRates(&plr, &cplr)); // Min window reached.
+
+ // A new feedback in quadrant #3 might shift enough old feedbacks out of
+ // window, that we'd go back to an unknown PLR and CPLR. This *doesn't*
+ // necessarily mean all of the old ones were discarded, though.
+ // Expected window contents: [10011-10101] -> [0111].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8006, {true, true});
+ EXPECT_FALSE(tracker.GetPacketLossRates(&plr, &cplr));
+
+ // Inserting in the middle shows that though some of the elements were
+ // ejected, some were retained.
+ // Expected window contents: [] -> [01101-11].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x4000,
+ {true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 7.0f);
+ EXPECT_EQ(cplr, 0.0f / 7.0f);
+ }
+}
+
+// Quadrant four reports ignored for up to kMaxConsecutiveOldReports times.
+TEST(TransportFeedbackPacketLossTrackerTest, QuadrantFourInitiallyIgnored) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Feedbacks in quadrant #4 are discarded (up to kMaxConsecutiveOldReports
+ // consecutive reports).
+ // Expected window contents: [10011] -> [10011].
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+ }
+}
+
+// Receiving a packet from quadrant #1 resets the counter for quadrant #4.
+TEST(TransportFeedbackPacketLossTrackerTest, QuadrantFourCounterResetByQ1) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Feedbacks in quadrant #4 are discarded (up to kMaxConsecutiveOldReports
+ // consecutive reports).
+ // Expected window contents: [10011] -> [10011].
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+
+ // If we receive a feedback in quadrant #1, the above counter is reset.
+ // Expected window contents: [10011] -> [10011-1].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x000f, {true});
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ // Note: though the feedback message reports three packets, it only gets
+ // counted once.
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000,
+ {true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 6.0f);
+ EXPECT_EQ(cplr, 1.0f / 6.0f);
+ }
+ }
+}
+
+// Receiving a packet from quadrant #2 resets the counter for quadrant #4.
+TEST(TransportFeedbackPacketLossTrackerTest, QuadrantFourCounterResetByQ2) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+
+ // Feedbacks in quadrant #4 are discarded (up to kMaxConsecutiveOldReports
+ // consecutive reports).
+ // Expected window contents: [10011] -> [10011].
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+
+ // If we receive a feedback in quadrant #1, the above counter is reset.
+ // Expected window contents: [10011] -> [10011-1].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x400f, {true});
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ // Note: though the feedback message reports three packets, it only gets
+ // counted once.
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000,
+ {true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 6.0f);
+ EXPECT_EQ(cplr, 1.0f / 6.0f);
+ }
+ }
+}
+
+// Receiving a packet from quadrant #3 resets the counter for quadrant #4.
+TEST(TransportFeedbackPacketLossTrackerTest, QuadrantFourCounterResetByQ3) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011-10001].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, false, true, true, true, false, false, false, true});
+
+ // Feedbacks in quadrant #4 are discarded (up to kMaxConsecutiveOldReports
+ // consecutive reports).
+ // Expected window contents: [10011-10001] -> [10011-10001].
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 5.0f / 10.0f);
+ EXPECT_EQ(cplr, 3.0f / 10.0f);
+ }
+
+ // If we receive a feedback in quadrant #1, the above counter is reset.
+ // Expected window contents: [10011-10001] -> [11100-01111].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x8000,
+ {true, true, true});
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ // Note: though the feedback message reports three packets, it only gets
+ // counted once.
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000 + 10,
+ {true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 3.0f / 10.0f);
+ EXPECT_EQ(cplr, 2.0f / 10.0f);
+ }
+ }
+}
+
+// Quadrant four reports ignored for up to kMaxConsecutiveOldReports times.
+// After that, the window is reset.
+TEST(TransportFeedbackPacketLossTrackerTest, QuadrantFourReset) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011-10001].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, false, true, true, true, false, false, false, true});
+
+ // The first kMaxConsecutiveOldReports quadrant #4 reports are ignored.
+ // It doesn't matter that they consist of multiple packets - each report
+ // is only counted once.
+ for (size_t i = 0; i < kMaxConsecutiveOldReports; i++) {
+ // Expected window contents: [10011-10001] -> [10011-10001].
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000,
+ {true, true, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 5.0f / 10.0f);
+ EXPECT_EQ(cplr, 3.0f / 10.0f);
+ }
+
+ // One additional feedback in quadrant #4 brings us over
+ // kMaxConsecutiveOldReports consecutive "old" reports, resetting the
+ // window.
+ // Note: The report doesn't have to be the same as the previous ones.
+ // Expected window contents: [10011-10001] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base + 0xc000,
+ {true, false, false, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+
+ // The new window is not completely empty - it's been seeded with the
+ // packets reported in the feedback that has triggered the reset.
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+}
+
+// Feedbacks spanning multiple quadrant are treated correctly (Q1-Q2).
+TEST(TransportFeedbackPacketLossTrackerTest, MultiQuadrantQ1Q2) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base,
+ {true, false, false, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+
+ // A feedback with entries in both quadrant #1 and #2 gets both counted:
+ // Expected window contents: [10011] -> [10011-11].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x3fff, {true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 7.0f);
+ EXPECT_EQ(cplr, 1.0f / 7.0f);
+ }
+}
+
+// Feedbacks spanning multiple quadrant are treated correctly (Q2-Q3).
+TEST(TransportFeedbackPacketLossTrackerTest, MultiQuadrantQ2Q3) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011-00001].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, false, true, true, false, false, false, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 6.0f / 10.0f);
+ EXPECT_EQ(cplr, 4.0f / 10.0f);
+
+ // A feedback with entries in both quadrant #2 and #3 gets both counted,
+ // but only those from #3 trigger throwing out old entries from quadrant #1:
+ // Expected window contents: [10011-00001] -> [01100-00110-01].
+ AddTransportFeedbackAndValidate(&tracker, base + 0x7ffe,
+ {true, false, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 7.0f / 12.0f);
+ EXPECT_EQ(cplr, 4.0f / 12.0f);
+ }
+}
+
+// Feedbacks spanning multiple quadrant are treated correctly (Q2-Q3).
+TEST(TransportFeedbackPacketLossTrackerTest, MultiQuadrantQ3Q4) {
+ for (uint16_t base : kBases) {
+ float plr = 0.0f; // Packet-loss-rate
+ float cplr = 0.0f; // Consecutive-packet-loss-rate
+
+ TransportFeedbackPacketLossTracker tracker(5, 20);
+
+ // Expected window contents: [] -> [10011-00001].
+ AddTransportFeedbackAndValidate(
+ &tracker, base,
+ {true, false, false, true, true, false, false, false, false, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 6.0f / 10.0f);
+ EXPECT_EQ(cplr, 4.0f / 10.0f);
+
+ // A feedback with entries in both quadrant #3 and #4 would have the entries
+ // from quadrant #3 shift enough quadrant #1 entries out of window, that
+ // by the time the #4 packets are examined, the moving baseline has made
+ // them into quadrant #3 packets.
+ // Expected window contents: [10011-00001] -> [10011].
+ AddTransportFeedbackAndValidate(&tracker, base + 0xbfff,
+ {true, false, false, true, true});
+ EXPECT_TRUE(tracker.GetPacketLossRates(&plr, &cplr));
+ EXPECT_EQ(plr, 2.0f / 5.0f);
+ EXPECT_EQ(cplr, 1.0f / 5.0f);
+ }
+}
+
+} // namespace webrtc

Powered by Google App Engine
This is Rietveld 408576698