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 |