OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
91 allocator_->OnNetworkChanged(4000000, 0, 0, kDefaultProbingIntervalMs); | 91 allocator_->OnNetworkChanged(4000000, 0, 0, kDefaultProbingIntervalMs); |
92 EXPECT_EQ(3000000, allocator_->GetStartBitrate(&bitrate_observer)); | 92 EXPECT_EQ(3000000, allocator_->GetStartBitrate(&bitrate_observer)); |
93 | 93 |
94 // Expect |max_padding_bitrate_bps| to change to 0 if the observer is updated. | 94 // Expect |max_padding_bitrate_bps| to change to 0 if the observer is updated. |
95 EXPECT_CALL(limit_observer_, | 95 EXPECT_CALL(limit_observer_, |
96 OnAllocationLimitsChanged(kMinSendBitrateBps, 0)); | 96 OnAllocationLimitsChanged(kMinSendBitrateBps, 0)); |
97 allocator_->AddObserver(&bitrate_observer, kMinSendBitrateBps, 4000000, 0, | 97 allocator_->AddObserver(&bitrate_observer, kMinSendBitrateBps, 4000000, 0, |
98 true); | 98 true); |
99 EXPECT_EQ(4000000, allocator_->GetStartBitrate(&bitrate_observer)); | 99 EXPECT_EQ(4000000, allocator_->GetStartBitrate(&bitrate_observer)); |
100 | 100 |
| 101 EXPECT_CALL(limit_observer_, |
| 102 OnAllocationLimitsChanged(kMinSendBitrateBps, 0)); |
101 allocator_->AddObserver(&bitrate_observer, kMinSendBitrateBps, 1500000, 0, | 103 allocator_->AddObserver(&bitrate_observer, kMinSendBitrateBps, 1500000, 0, |
102 true); | 104 true); |
103 EXPECT_EQ(3000000, allocator_->GetStartBitrate(&bitrate_observer)); | 105 EXPECT_EQ(3000000, allocator_->GetStartBitrate(&bitrate_observer)); |
104 EXPECT_EQ(3000000u, bitrate_observer.last_bitrate_bps_); | 106 EXPECT_EQ(3000000u, bitrate_observer.last_bitrate_bps_); |
105 allocator_->OnNetworkChanged(1500000, 0, 0, kDefaultProbingIntervalMs); | 107 allocator_->OnNetworkChanged(1500000, 0, 0, kDefaultProbingIntervalMs); |
106 EXPECT_EQ(1500000u, bitrate_observer.last_bitrate_bps_); | 108 EXPECT_EQ(1500000u, bitrate_observer.last_bitrate_bps_); |
107 } | 109 } |
108 | 110 |
109 TEST_F(BitrateAllocatorTest, TwoBitrateObserversOneRtcpObserver) { | 111 TEST_F(BitrateAllocatorTest, TwoBitrateObserversOneRtcpObserver) { |
110 TestBitrateObserver bitrate_observer_1; | 112 TestBitrateObserver bitrate_observer_1; |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
174 NiceMock<MockLimitObserver> limit_observer_; | 176 NiceMock<MockLimitObserver> limit_observer_; |
175 std::unique_ptr<BitrateAllocator> allocator_; | 177 std::unique_ptr<BitrateAllocator> allocator_; |
176 }; | 178 }; |
177 | 179 |
178 // The following three tests verify enforcing a minimum bitrate works as | 180 // The following three tests verify enforcing a minimum bitrate works as |
179 // intended. | 181 // intended. |
180 TEST_F(BitrateAllocatorTestNoEnforceMin, OneBitrateObserver) { | 182 TEST_F(BitrateAllocatorTestNoEnforceMin, OneBitrateObserver) { |
181 TestBitrateObserver bitrate_observer_1; | 183 TestBitrateObserver bitrate_observer_1; |
182 // Expect OnAllocationLimitsChanged with |min_send_bitrate_bps| = 0 since | 184 // Expect OnAllocationLimitsChanged with |min_send_bitrate_bps| = 0 since |
183 // AddObserver is called with |enforce_min_bitrate| = false. | 185 // AddObserver is called with |enforce_min_bitrate| = false. |
184 EXPECT_CALL(limit_observer_, OnAllocationLimitsChanged(0, 120000)); | 186 EXPECT_CALL(limit_observer_, OnAllocationLimitsChanged(0, 0)); |
185 allocator_->AddObserver(&bitrate_observer_1, 100000, 400000, 0, false); | 187 allocator_->AddObserver(&bitrate_observer_1, 100000, 400000, 0, false); |
186 EXPECT_EQ(300000, allocator_->GetStartBitrate(&bitrate_observer_1)); | 188 EXPECT_EQ(300000, allocator_->GetStartBitrate(&bitrate_observer_1)); |
187 | 189 |
188 // High BWE. | 190 // High BWE. |
189 allocator_->OnNetworkChanged(150000, 0, 0, kDefaultProbingIntervalMs); | 191 allocator_->OnNetworkChanged(150000, 0, 0, kDefaultProbingIntervalMs); |
190 EXPECT_EQ(150000u, bitrate_observer_1.last_bitrate_bps_); | 192 EXPECT_EQ(150000u, bitrate_observer_1.last_bitrate_bps_); |
191 | 193 |
192 // Low BWE. | 194 // Low BWE. |
193 allocator_->OnNetworkChanged(10000, 0, 0, kDefaultProbingIntervalMs); | 195 allocator_->OnNetworkChanged(10000, 0, 0, kDefaultProbingIntervalMs); |
194 EXPECT_EQ(0u, bitrate_observer_1.last_bitrate_bps_); | 196 EXPECT_EQ(0u, bitrate_observer_1.last_bitrate_bps_); |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
255 | 257 |
256 allocator_->RemoveObserver(&bitrate_observer_1); | 258 allocator_->RemoveObserver(&bitrate_observer_1); |
257 allocator_->RemoveObserver(&bitrate_observer_2); | 259 allocator_->RemoveObserver(&bitrate_observer_2); |
258 allocator_->RemoveObserver(&bitrate_observer_3); | 260 allocator_->RemoveObserver(&bitrate_observer_3); |
259 } | 261 } |
260 | 262 |
261 TEST_F(BitrateAllocatorTestNoEnforceMin, OneBitrateObserverWithPacketLoss) { | 263 TEST_F(BitrateAllocatorTestNoEnforceMin, OneBitrateObserverWithPacketLoss) { |
262 TestBitrateObserver bitrate_observer; | 264 TestBitrateObserver bitrate_observer; |
263 // Expect OnAllocationLimitsChanged with |min_send_bitrate_bps| = 0 since | 265 // Expect OnAllocationLimitsChanged with |min_send_bitrate_bps| = 0 since |
264 // AddObserver is called with |enforce_min_bitrate| = false. | 266 // AddObserver is called with |enforce_min_bitrate| = false. |
265 EXPECT_CALL(limit_observer_, OnAllocationLimitsChanged(0, 168000)); | 267 EXPECT_CALL(limit_observer_, OnAllocationLimitsChanged(0, 0)); |
266 allocator_->AddObserver( | 268 allocator_->AddObserver( |
267 &bitrate_observer, 100000, 400000, 0, false); | 269 &bitrate_observer, 100000, 400000, 0, false); |
268 EXPECT_EQ(300000, allocator_->GetStartBitrate(&bitrate_observer)); | 270 EXPECT_EQ(300000, allocator_->GetStartBitrate(&bitrate_observer)); |
269 | 271 |
270 // High BWE. | 272 // High BWE. |
271 allocator_->OnNetworkChanged(150000, 0, 0, kDefaultProbingIntervalMs); | 273 allocator_->OnNetworkChanged(150000, 0, 0, kDefaultProbingIntervalMs); |
272 EXPECT_EQ(150000u, bitrate_observer.last_bitrate_bps_); | 274 EXPECT_EQ(150000u, bitrate_observer.last_bitrate_bps_); |
273 | 275 |
274 // Add loss and use a part of the bitrate for protection. | 276 // Add loss and use a part of the bitrate for protection. |
275 double protection_ratio = 0.4; | 277 double protection_ratio = 0.4; |
276 uint8_t fraction_loss = protection_ratio * 256; | 278 uint8_t fraction_loss = protection_ratio * 256; |
277 bitrate_observer.SetBitrateProtectionRatio(protection_ratio); | 279 bitrate_observer.SetBitrateProtectionRatio(protection_ratio); |
278 allocator_->OnNetworkChanged(200000, 0, fraction_loss, | 280 allocator_->OnNetworkChanged(200000, 0, fraction_loss, |
279 kDefaultProbingIntervalMs); | 281 kDefaultProbingIntervalMs); |
280 EXPECT_EQ(200000u, bitrate_observer.last_bitrate_bps_); | 282 EXPECT_EQ(200000u, bitrate_observer.last_bitrate_bps_); |
281 | 283 |
282 // Above the min threshold, but not enough given the protection used. | 284 // Above the min threshold, but not enough given the protection used. |
283 allocator_->OnNetworkChanged(139000, 0, fraction_loss, | 285 allocator_->OnNetworkChanged(139000, 0, fraction_loss, |
284 kDefaultProbingIntervalMs); | 286 kDefaultProbingIntervalMs); |
285 EXPECT_EQ(0u, bitrate_observer.last_bitrate_bps_); | 287 EXPECT_EQ(0u, bitrate_observer.last_bitrate_bps_); |
286 | 288 |
287 // Verify the hysteresis is added for the protection. | 289 // Verify the hysteresis is added for the protection. |
288 allocator_->OnNetworkChanged(150000, 0, fraction_loss, | 290 allocator_->OnNetworkChanged(150000, 0, fraction_loss, |
289 kDefaultProbingIntervalMs); | 291 kDefaultProbingIntervalMs); |
290 EXPECT_EQ(0u, bitrate_observer.last_bitrate_bps_); | 292 EXPECT_EQ(0u, bitrate_observer.last_bitrate_bps_); |
291 | 293 |
292 // Just enough to enable video again. | 294 // Just enough to enable video again. |
293 EXPECT_CALL(limit_observer_, OnAllocationLimitsChanged(0, 0)); | |
294 allocator_->OnNetworkChanged(168000, 0, fraction_loss, | 295 allocator_->OnNetworkChanged(168000, 0, fraction_loss, |
295 kDefaultProbingIntervalMs); | 296 kDefaultProbingIntervalMs); |
296 EXPECT_EQ(168000u, bitrate_observer.last_bitrate_bps_); | 297 EXPECT_EQ(168000u, bitrate_observer.last_bitrate_bps_); |
297 | 298 |
298 // Remove all protection and make sure video is not paused as earlier. | 299 // Remove all protection and make sure video is not paused as earlier. |
299 bitrate_observer.SetBitrateProtectionRatio(0.0); | 300 bitrate_observer.SetBitrateProtectionRatio(0.0); |
300 allocator_->OnNetworkChanged(140000, 0, 0, kDefaultProbingIntervalMs); | 301 allocator_->OnNetworkChanged(140000, 0, 0, kDefaultProbingIntervalMs); |
301 EXPECT_EQ(140000u, bitrate_observer.last_bitrate_bps_); | 302 EXPECT_EQ(140000u, bitrate_observer.last_bitrate_bps_); |
302 | 303 |
303 allocator_->OnNetworkChanged(139000, 0, 0, kDefaultProbingIntervalMs); | 304 allocator_->OnNetworkChanged(139000, 0, 0, kDefaultProbingIntervalMs); |
304 EXPECT_EQ(139000u, bitrate_observer.last_bitrate_bps_); | 305 EXPECT_EQ(139000u, bitrate_observer.last_bitrate_bps_); |
305 | 306 |
| 307 EXPECT_CALL(limit_observer_, OnAllocationLimitsChanged(0, 0)); |
306 allocator_->RemoveObserver(&bitrate_observer); | 308 allocator_->RemoveObserver(&bitrate_observer); |
307 } | 309 } |
308 | 310 |
309 TEST_F(BitrateAllocatorTestNoEnforceMin, TwoBitrateObserverWithPacketLoss) { | 311 TEST_F(BitrateAllocatorTestNoEnforceMin, TwoBitrateObserverWithPacketLoss) { |
310 TestBitrateObserver bitrate_observer_1; | 312 TestBitrateObserver bitrate_observer_1; |
311 TestBitrateObserver bitrate_observer_2; | 313 TestBitrateObserver bitrate_observer_2; |
312 | 314 |
313 allocator_->AddObserver(&bitrate_observer_1, 100000, 400000, 0, false); | 315 allocator_->AddObserver(&bitrate_observer_1, 100000, 400000, 0, false); |
314 EXPECT_EQ(300000, allocator_->GetStartBitrate(&bitrate_observer_1)); | 316 EXPECT_EQ(300000, allocator_->GetStartBitrate(&bitrate_observer_1)); |
315 allocator_->AddObserver(&bitrate_observer_2, 200000, 400000, 0, false); | 317 allocator_->AddObserver(&bitrate_observer_2, 200000, 400000, 0, false); |
(...skipping 197 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
513 allocator_->AddObserver(&observer, 300000, 600000, 0, false); | 515 allocator_->AddObserver(&observer, 300000, 600000, 0, false); |
514 EXPECT_EQ(300000, allocator_->GetStartBitrate(&observer)); | 516 EXPECT_EQ(300000, allocator_->GetStartBitrate(&observer)); |
515 | 517 |
516 allocator_->OnNetworkChanged(300000, 0, 50, 5000); | 518 allocator_->OnNetworkChanged(300000, 0, 50, 5000); |
517 EXPECT_EQ(5000, observer.last_probing_interval_ms_); | 519 EXPECT_EQ(5000, observer.last_probing_interval_ms_); |
518 | 520 |
519 allocator_->RemoveObserver(&observer); | 521 allocator_->RemoveObserver(&observer); |
520 } | 522 } |
521 | 523 |
522 } // namespace webrtc | 524 } // namespace webrtc |
OLD | NEW |