1 /*
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved.
3 *
4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
11 #include "webrtc/test/gtest.h"
12 #include "webrtc/base/constructormagic.h"
13 #include "webrtc/modules/pacing/paced_sender.h"
14 #include "webrtc/modules/congestion_controller/delay_based_bwe.h"
15 #include "webrtc/modules/congestion_controller/delay_based_bwe_unittest_helper.h"
16 #include "webrtc/system_wrappers/include/clock.h"
17 #include "webrtc/test/field_trial.h"
18
19 namespace webrtc {
20
21 namespace {
22
23 constexpr int kNumProbes = 5;
24 } // namespace
25
TEST_F(DelayBasedBweTest,ProbeDetection)26 TEST_F(DelayBasedBweTest, ProbeDetection) {
27 int64_t now_ms = clock_.TimeInMilliseconds();
28 uint16_t seq_num = 0;
29
30 // First burst sent at 8 * 1000 / 10 = 800 kbps.
31 for (int i = 0; i < kNumProbes; ++i) {
32 clock_.AdvanceTimeMilliseconds(10);
33 now_ms = clock_.TimeInMilliseconds();
34 IncomingFeedback(now_ms, now_ms, seq_num++, 1000, 0);
35 }
36 EXPECT_TRUE(bitrate_observer_.updated());
37
38 // Second burst sent at 8 * 1000 / 5 = 1600 kbps.
39 for (int i = 0; i < kNumProbes; ++i) {
40 clock_.AdvanceTimeMilliseconds(5);
41 now_ms = clock_.TimeInMilliseconds();
42 IncomingFeedback(now_ms, now_ms, seq_num++, 1000, 1);
43 }
44
45 EXPECT_TRUE(bitrate_observer_.updated());
46 EXPECT_GT(bitrate_observer_.latest_bitrate(), 1500000u);
47 }
48
TEST_F(DelayBasedBweTest,ProbeDetectionNonPacedPackets)49 TEST_F(DelayBasedBweTest, ProbeDetectionNonPacedPackets) {
50 int64_t now_ms = clock_.TimeInMilliseconds();
51 uint16_t seq_num = 0;
52 // First burst sent at 8 * 1000 / 10 = 800 kbps, but with every other packet
53 // not being paced which could mess things up.
54 for (int i = 0; i < kNumProbes; ++i) {
55 clock_.AdvanceTimeMilliseconds(5);
56 now_ms = clock_.TimeInMilliseconds();
57 IncomingFeedback(now_ms, now_ms, seq_num++, 1000, 0);
58 // Non-paced packet, arriving 5 ms after.
59 clock_.AdvanceTimeMilliseconds(5);
60 IncomingFeedback(now_ms, now_ms, seq_num++,
61 PacedSender::kMinProbePacketSize + 1,
62 PacketInfo::kNotAProbe);
63 }
64
65 EXPECT_TRUE(bitrate_observer_.updated());
66 EXPECT_GT(bitrate_observer_.latest_bitrate(), 800000u);
67 }
68
TEST_F(DelayBasedBweTest,ProbeDetectionFasterArrival)69 TEST_F(DelayBasedBweTest, ProbeDetectionFasterArrival) {
70 int64_t now_ms = clock_.TimeInMilliseconds();
71 uint16_t seq_num = 0;
72 // First burst sent at 8 * 1000 / 10 = 800 kbps.
73 // Arriving at 8 * 1000 / 5 = 1600 kbps.
74 int64_t send_time_ms = 0;
75 for (int i = 0; i < kNumProbes; ++i) {
76 clock_.AdvanceTimeMilliseconds(1);
77 send_time_ms += 10;
78 now_ms = clock_.TimeInMilliseconds();
79 IncomingFeedback(now_ms, send_time_ms, seq_num++, 1000, 0);
80 }
81
82 EXPECT_FALSE(bitrate_observer_.updated());
83 }
84
TEST_F(DelayBasedBweTest,ProbeDetectionSlowerArrival)85 TEST_F(DelayBasedBweTest, ProbeDetectionSlowerArrival) {
86 int64_t now_ms = clock_.TimeInMilliseconds();
87 uint16_t seq_num = 0;
88 // First burst sent at 8 * 1000 / 5 = 1600 kbps.
89 // Arriving at 8 * 1000 / 7 = 1142 kbps.
90 int64_t send_time_ms = 0;
91 for (int i = 0; i < kNumProbes; ++i) {
92 clock_.AdvanceTimeMilliseconds(7);
93 send_time_ms += 5;
94 now_ms = clock_.TimeInMilliseconds();
95 IncomingFeedback(now_ms, send_time_ms, seq_num++, 1000, 1);
96 }
97
98 EXPECT_TRUE(bitrate_observer_.updated());
99 EXPECT_NEAR(bitrate_observer_.latest_bitrate(), 1140000u, 10000u);
100 }
101
TEST_F(DelayBasedBweTest,ProbeDetectionSlowerArrivalHighBitrate)102 TEST_F(DelayBasedBweTest, ProbeDetectionSlowerArrivalHighBitrate) {
103 int64_t now_ms = clock_.TimeInMilliseconds();
104 uint16_t seq_num = 0;
105 // Burst sent at 8 * 1000 / 1 = 8000 kbps.
106 // Arriving at 8 * 1000 / 2 = 4000 kbps.
107 int64_t send_time_ms = 0;
108 for (int i = 0; i < kNumProbes; ++i) {
109 clock_.AdvanceTimeMilliseconds(2);
110 send_time_ms += 1;
111 now_ms = clock_.TimeInMilliseconds();
112 IncomingFeedback(now_ms, send_time_ms, seq_num++, 1000, 1);
113 }
114
115 EXPECT_TRUE(bitrate_observer_.updated());
116 EXPECT_NEAR(bitrate_observer_.latest_bitrate(), 4000000u, 10000u);
117 }
118
TEST_F(DelayBasedBweTest,GetProbingInterval)119 TEST_F(DelayBasedBweTest, GetProbingInterval) {
120 int64_t default_interval_ms = bitrate_estimator_->GetProbingIntervalMs();
121 EXPECT_GT(default_interval_ms, 0);
122 CapacityDropTestHelper(1, true, 567, 0);
123 int64_t interval_ms = bitrate_estimator_->GetProbingIntervalMs();
124 EXPECT_GT(interval_ms, 0);
125 EXPECT_NE(interval_ms, default_interval_ms);
126 }
127
TEST_F(DelayBasedBweTest,InitialBehavior)128 TEST_F(DelayBasedBweTest, InitialBehavior) {
129 InitialBehaviorTestHelper(674840);
130 }
131
TEST_F(DelayBasedBweTest,RateIncreaseReordering)132 TEST_F(DelayBasedBweTest, RateIncreaseReordering) {
133 RateIncreaseReorderingTestHelper(674840);
134 }
135
TEST_F(DelayBasedBweTest,RateIncreaseRtpTimestamps)136 TEST_F(DelayBasedBweTest, RateIncreaseRtpTimestamps) {
137 RateIncreaseRtpTimestampsTestHelper(1240);
138 }
139
TEST_F(DelayBasedBweTest,CapacityDropOneStream)140 TEST_F(DelayBasedBweTest, CapacityDropOneStream) {
141 CapacityDropTestHelper(1, false, 567, 0);
142 }
143
TEST_F(DelayBasedBweTest,CapacityDropPosOffsetChange)144 TEST_F(DelayBasedBweTest, CapacityDropPosOffsetChange) {
145 CapacityDropTestHelper(1, false, 200, 30000);
146 }
147
TEST_F(DelayBasedBweTest,CapacityDropNegOffsetChange)148 TEST_F(DelayBasedBweTest, CapacityDropNegOffsetChange) {
149 CapacityDropTestHelper(1, false, 733, -30000);
150 }
151
TEST_F(DelayBasedBweTest,CapacityDropOneStreamWrap)152 TEST_F(DelayBasedBweTest, CapacityDropOneStreamWrap) {
153 CapacityDropTestHelper(1, true, 567, 0);
154 }
155
TEST_F(DelayBasedBweTest,TestTimestampGrouping)156 TEST_F(DelayBasedBweTest, TestTimestampGrouping) {
157 TestTimestampGroupingTestHelper();
158 }
159
TEST_F(DelayBasedBweTest,TestShortTimeoutAndWrap)160 TEST_F(DelayBasedBweTest, TestShortTimeoutAndWrap) {
161 // Simulate a client leaving and rejoining the call after 35 seconds. This
162 // will make abs send time wrap, so if streams aren't timed out properly
163 // the next 30 seconds of packets will be out of order.
164 TestWrappingHelper(35);
165 }
166
TEST_F(DelayBasedBweTest,TestLongTimeoutAndWrap)167 TEST_F(DelayBasedBweTest, TestLongTimeoutAndWrap) {
168 // Simulate a client leaving and rejoining the call after some multiple of
169 // 64 seconds later. This will cause a zero difference in abs send times due
170 // to the wrap, but a big difference in arrival time, if streams aren't
171 // properly timed out.
172 TestWrappingHelper(10 * 64);
173 }
174
175 class DelayBasedBweExperimentTest : public DelayBasedBweTest {
176 public:
DelayBasedBweExperimentTest()177 DelayBasedBweExperimentTest()
178 : override_field_trials_("WebRTC-ImprovedBitrateEstimate/Enabled/") {
179 bitrate_estimator_.reset(new DelayBasedBwe(&clock_));
180 }
181
182 private:
183 test::ScopedFieldTrials override_field_trials_;
184 };
185
TEST_F(DelayBasedBweExperimentTest,RateIncreaseRtpTimestamps)186 TEST_F(DelayBasedBweExperimentTest, RateIncreaseRtpTimestamps) {
187 RateIncreaseRtpTimestampsTestHelper(1288);
188 }
189
TEST_F(DelayBasedBweExperimentTest,CapacityDropOneStream)190 TEST_F(DelayBasedBweExperimentTest, CapacityDropOneStream) {
191 CapacityDropTestHelper(1, false, 333, 0);
192 }
193
TEST_F(DelayBasedBweExperimentTest,CapacityDropPosOffsetChange)194 TEST_F(DelayBasedBweExperimentTest, CapacityDropPosOffsetChange) {
195 CapacityDropTestHelper(1, false, 300, 30000);
196 }
197
TEST_F(DelayBasedBweExperimentTest,CapacityDropNegOffsetChange)198 TEST_F(DelayBasedBweExperimentTest, CapacityDropNegOffsetChange) {
199 CapacityDropTestHelper(1, false, 300, -30000);
200 }
201
TEST_F(DelayBasedBweExperimentTest,CapacityDropOneStreamWrap)202 TEST_F(DelayBasedBweExperimentTest, CapacityDropOneStreamWrap) {
203 CapacityDropTestHelper(1, true, 333, 0);
204 }
205
206 class DelayBasedBweTrendlineExperimentTest : public DelayBasedBweTest {
207 public:
DelayBasedBweTrendlineExperimentTest()208 DelayBasedBweTrendlineExperimentTest()
209 : override_field_trials_("WebRTC-BweTrendlineFilter/Enabled-15,0.9,4/") {
210 bitrate_estimator_.reset(new DelayBasedBwe(&clock_));
211 }
212
213 private:
214 test::ScopedFieldTrials override_field_trials_;
215 };
216
TEST_F(DelayBasedBweTrendlineExperimentTest,RateIncreaseRtpTimestamps)217 TEST_F(DelayBasedBweTrendlineExperimentTest, RateIncreaseRtpTimestamps) {
218 RateIncreaseRtpTimestampsTestHelper(1240);
219 }
220
TEST_F(DelayBasedBweTrendlineExperimentTest,CapacityDropOneStream)221 TEST_F(DelayBasedBweTrendlineExperimentTest, CapacityDropOneStream) {
222 CapacityDropTestHelper(1, false, 600, 0);
223 }
224
TEST_F(DelayBasedBweTrendlineExperimentTest,CapacityDropPosOffsetChange)225 TEST_F(DelayBasedBweTrendlineExperimentTest, CapacityDropPosOffsetChange) {
226 CapacityDropTestHelper(1, false, 600, 30000);
227 }
228
TEST_F(DelayBasedBweTrendlineExperimentTest,CapacityDropNegOffsetChange)229 TEST_F(DelayBasedBweTrendlineExperimentTest, CapacityDropNegOffsetChange) {
230 CapacityDropTestHelper(1, false, 1267, -30000);
231 }
232
TEST_F(DelayBasedBweTrendlineExperimentTest,CapacityDropOneStreamWrap)233 TEST_F(DelayBasedBweTrendlineExperimentTest, CapacityDropOneStreamWrap) {
234 CapacityDropTestHelper(1, true, 600, 0);
235 }
236
237 class DelayBasedBweMedianSlopeExperimentTest : public DelayBasedBweTest {
238 public:
DelayBasedBweMedianSlopeExperimentTest()239 DelayBasedBweMedianSlopeExperimentTest()
240 : override_field_trials_("WebRTC-BweMedianSlopeFilter/Enabled-20,4/") {
241 bitrate_estimator_.reset(new DelayBasedBwe(&clock_));
242 }
243
244 private:
245 test::ScopedFieldTrials override_field_trials_;
246 };
247
TEST_F(DelayBasedBweMedianSlopeExperimentTest,RateIncreaseRtpTimestamps)248 TEST_F(DelayBasedBweMedianSlopeExperimentTest, RateIncreaseRtpTimestamps) {
249 RateIncreaseRtpTimestampsTestHelper(1240);
250 }
251
TEST_F(DelayBasedBweMedianSlopeExperimentTest,CapacityDropOneStream)252 TEST_F(DelayBasedBweMedianSlopeExperimentTest, CapacityDropOneStream) {
253 CapacityDropTestHelper(1, false, 600, 0);
254 }
255
TEST_F(DelayBasedBweMedianSlopeExperimentTest,CapacityDropPosOffsetChange)256 TEST_F(DelayBasedBweMedianSlopeExperimentTest, CapacityDropPosOffsetChange) {
257 CapacityDropTestHelper(1, false, 600, 30000);
258 }
259
TEST_F(DelayBasedBweMedianSlopeExperimentTest,CapacityDropNegOffsetChange)260 TEST_F(DelayBasedBweMedianSlopeExperimentTest, CapacityDropNegOffsetChange) {
261 CapacityDropTestHelper(1, false, 1267, -30000);
262 }
263
TEST_F(DelayBasedBweMedianSlopeExperimentTest,CapacityDropOneStreamWrap)264 TEST_F(DelayBasedBweMedianSlopeExperimentTest, CapacityDropOneStreamWrap) {
265 CapacityDropTestHelper(1, true, 600, 0);
266 }
267
268 } // namespace webrtc
269