OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 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 330 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
341 filter.set_max_delay_ms(500); | 341 filter.set_max_delay_ms(500); |
342 RateCounterFilter counter2(&uplink_, 0, "receiver_input"); | 342 RateCounterFilter counter2(&uplink_, 0, "receiver_input"); |
343 PacketReceiver receiver(&uplink_, 0, GetParam(), false, false); | 343 PacketReceiver receiver(&uplink_, 0, GetParam(), false, false); |
344 ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); | 344 ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx"))); |
345 RunFor(300 * 1000); | 345 RunFor(300 * 1000); |
346 PrintResults(filter.GetBitrateStats().GetMean(), counter2.GetBitrateStats(), | 346 PrintResults(filter.GetBitrateStats().GetMean(), counter2.GetBitrateStats(), |
347 0, receiver.GetDelayStats(), counter2.GetBitrateStats()); | 347 0, receiver.GetDelayStats(), counter2.GetBitrateStats()); |
348 } | 348 } |
349 | 349 |
350 TEST_P(BweFeedbackTest, PacedSelfFairness50msTest) { | 350 TEST_P(BweFeedbackTest, PacedSelfFairness50msTest) { |
351 RunFairnessTest(GetParam(), 4, 0, 300, 3000, 50); | 351 int64_t kRttMs = 100; |
| 352 int64_t kMaxJitterMs = 15; |
| 353 |
| 354 const int kNumRmcatFlows = 4; |
| 355 int64_t offset_ms[kNumRmcatFlows]; |
| 356 for (int i = 0; i < kNumRmcatFlows; ++i) { |
| 357 offset_ms[i] = std::max(0, 5000 * i + rand() % 2001 - 1000); |
| 358 } |
| 359 |
| 360 RunFairnessTest(GetParam(), kNumRmcatFlows, 0, 300, 3000, 50, kRttMs, |
| 361 kMaxJitterMs, offset_ms); |
352 } | 362 } |
353 | 363 |
354 TEST_P(BweFeedbackTest, PacedSelfFairness500msTest) { | 364 TEST_P(BweFeedbackTest, PacedSelfFairness500msTest) { |
355 RunFairnessTest(GetParam(), 4, 0, 300, 3000, 500); | 365 int64_t kRttMs = 100; |
| 366 int64_t kMaxJitterMs = 15; |
| 367 |
| 368 const int kNumRmcatFlows = 4; |
| 369 int64_t offset_ms[kNumRmcatFlows]; |
| 370 for (int i = 0; i < kNumRmcatFlows; ++i) { |
| 371 offset_ms[i] = std::max(0, 5000 * i + rand() % 2001 - 1000); |
| 372 } |
| 373 |
| 374 RunFairnessTest(GetParam(), kNumRmcatFlows, 0, 300, 3000, 500, kRttMs, |
| 375 kMaxJitterMs, offset_ms); |
356 } | 376 } |
357 | 377 |
358 TEST_P(BweFeedbackTest, PacedSelfFairness1000msTest) { | 378 TEST_P(BweFeedbackTest, PacedSelfFairness1000msTest) { |
359 RunFairnessTest(GetParam(), 4, 0, 300, 3000, 1000); | 379 int64_t kRttMs = 100; |
| 380 int64_t kMaxJitterMs = 15; |
| 381 |
| 382 const int kNumRmcatFlows = 4; |
| 383 int64_t offset_ms[kNumRmcatFlows]; |
| 384 for (int i = 0; i < kNumRmcatFlows; ++i) { |
| 385 offset_ms[i] = std::max(0, 5000 * i + rand() % 2001 - 1000); |
| 386 } |
| 387 |
| 388 RunFairnessTest(GetParam(), kNumRmcatFlows, 0, 300, 3000, 1000, kRttMs, |
| 389 kMaxJitterMs, offset_ms); |
360 } | 390 } |
361 | 391 |
362 TEST_P(BweFeedbackTest, TcpFairness50msTest) { | 392 TEST_P(BweFeedbackTest, TcpFairness50msTest) { |
363 RunFairnessTest(GetParam(), 1, 1, 300, 2000, 50); | 393 int64_t kRttMs = 100; |
| 394 int64_t kMaxJitterMs = 15; |
| 395 |
| 396 int64_t offset_ms[2]; // One TCP, one RMCAT flow. |
| 397 for (int i = 0; i < 2; ++i) { |
| 398 offset_ms[i] = std::max(0, 5000 * i + rand() % 2001 - 1000); |
| 399 } |
| 400 |
| 401 RunFairnessTest(GetParam(), 1, 1, 300, 2000, 50, kRttMs, kMaxJitterMs, |
| 402 offset_ms); |
364 } | 403 } |
365 | 404 |
366 TEST_P(BweFeedbackTest, TcpFairness500msTest) { | 405 TEST_P(BweFeedbackTest, TcpFairness500msTest) { |
367 RunFairnessTest(GetParam(), 1, 1, 300, 2000, 500); | 406 int64_t kRttMs = 100; |
| 407 int64_t kMaxJitterMs = 15; |
| 408 |
| 409 int64_t offset_ms[2]; // One TCP, one RMCAT flow. |
| 410 for (int i = 0; i < 2; ++i) { |
| 411 offset_ms[i] = std::max(0, 5000 * i + rand() % 2001 - 1000); |
| 412 } |
| 413 |
| 414 RunFairnessTest(GetParam(), 1, 1, 300, 2000, 500, kRttMs, kMaxJitterMs, |
| 415 offset_ms); |
368 } | 416 } |
369 | 417 |
370 TEST_P(BweFeedbackTest, TcpFairness1000msTest) { | 418 TEST_P(BweFeedbackTest, TcpFairness1000msTest) { |
371 RunFairnessTest(GetParam(), 1, 1, 300, 2000, 1000); | 419 int64_t kRttMs = 100; |
| 420 int64_t kMaxJitterMs = 15; |
| 421 |
| 422 int64_t offset_ms[2]; // One TCP, one RMCAT flow. |
| 423 for (int i = 0; i < 2; ++i) { |
| 424 offset_ms[i] = std::max(0, 5000 * i + rand() % 2001 - 1000); |
| 425 } |
| 426 |
| 427 RunFairnessTest(GetParam(), 1, 1, 300, 2000, 1000, kRttMs, kMaxJitterMs, |
| 428 offset_ms); |
372 } | 429 } |
373 } // namespace bwe | 430 } // namespace bwe |
374 } // namespace testing | 431 } // namespace testing |
375 } // namespace webrtc | 432 } // namespace webrtc |
OLD | NEW |