| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2014 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2014 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 224 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 235 RateCounterFilter counter1(&uplink_, 0, "sender_output", | 235 RateCounterFilter counter1(&uplink_, 0, "sender_output", |
| 236 bwe_names[GetParam()]); | 236 bwe_names[GetParam()]); |
| 237 TraceBasedDeliveryFilter filter(&uplink_, 0, "link_capacity"); | 237 TraceBasedDeliveryFilter filter(&uplink_, 0, "link_capacity"); |
| 238 filter.set_max_delay_ms(500); | 238 filter.set_max_delay_ms(500); |
| 239 RateCounterFilter counter2(&uplink_, 0, "Receiver", bwe_names[GetParam()]); | 239 RateCounterFilter counter2(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
| 240 PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); | 240 PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
| 241 ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); | 241 ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); |
| 242 RunFor(300 * 1000); | 242 RunFor(300 * 1000); |
| 243 } | 243 } |
| 244 | 244 |
| 245 TEST_P(BweSimulation, PacerGoogleWifiTrace3MbpsLowFramerate) { |
| 246 PeriodicKeyFrameSource source(0, 5, 300, 0, 0, 1000); |
| 247 PacedVideoSender sender(&uplink_, &source, GetParam()); |
| 248 RateCounterFilter counter1(&uplink_, 0, "sender_output", |
| 249 bwe_names[GetParam()]); |
| 250 TraceBasedDeliveryFilter filter(&uplink_, 0, "link_capacity"); |
| 251 filter.set_max_delay_ms(500); |
| 252 RateCounterFilter counter2(&uplink_, 0, "Receiver", bwe_names[GetParam()]); |
| 253 PacketReceiver receiver(&uplink_, 0, GetParam(), true, true); |
| 254 ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); |
| 255 RunFor(300 * 1000); |
| 256 } |
| 257 |
| 245 TEST_P(BweSimulation, SelfFairnessTest) { | 258 TEST_P(BweSimulation, SelfFairnessTest) { |
| 246 Random prng(Clock::GetRealTimeClock()->TimeInMicroseconds()); | 259 Random prng(Clock::GetRealTimeClock()->TimeInMicroseconds()); |
| 247 const int kAllFlowIds[] = {0, 1, 2, 3}; | 260 const int kAllFlowIds[] = {0, 1, 2, 3}; |
| 248 const size_t kNumFlows = sizeof(kAllFlowIds) / sizeof(kAllFlowIds[0]); | 261 const size_t kNumFlows = sizeof(kAllFlowIds) / sizeof(kAllFlowIds[0]); |
| 249 std::unique_ptr<VideoSource> sources[kNumFlows]; | 262 std::unique_ptr<VideoSource> sources[kNumFlows]; |
| 250 std::unique_ptr<VideoSender> senders[kNumFlows]; | 263 std::unique_ptr<VideoSender> senders[kNumFlows]; |
| 251 for (size_t i = 0; i < kNumFlows; ++i) { | 264 for (size_t i = 0; i < kNumFlows; ++i) { |
| 252 // Streams started 20 seconds apart to give them different advantage when | 265 // Streams started 20 seconds apart to give them different advantage when |
| 253 // competing for the bandwidth. | 266 // competing for the bandwidth. |
| 254 sources[i].reset(new AdaptiveVideoSource(kAllFlowIds[i], 30, 300, 0, | 267 sources[i].reset(new AdaptiveVideoSource(kAllFlowIds[i], 30, 300, 0, |
| (...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 442 RunChoke(GetParam(), capacities_kbps); | 455 RunChoke(GetParam(), capacities_kbps); |
| 443 | 456 |
| 444 BweTest gcc_test(false); | 457 BweTest gcc_test(false); |
| 445 gcc_test.RunChoke(kSendSideEstimator, capacities_kbps); | 458 gcc_test.RunChoke(kSendSideEstimator, capacities_kbps); |
| 446 } | 459 } |
| 447 | 460 |
| 448 } // namespace bwe | 461 } // namespace bwe |
| 449 } // namespace testing | 462 } // namespace testing |
| 450 } // namespace webrtc | 463 } // namespace webrtc |
| 451 | 464 |
| OLD | NEW |