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