src/third_party/webrtc/modules/remote_bitrate_estimator/bwe_simulations.cc

   1 /*
   2  *  Copyright (c) 2014 The WebRTC project authors. All Rights Reserved.
   3  *
   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
   6  *  tree. An additional intellectual property rights grant can be found
   7  *  in the file PATENTS.  All contributing project authors may
   8  *  be found in the AUTHORS file in the root of the source tree.
   9  */
  10
  11 #include "gtest/gtest.h"
  12 #include "webrtc/modules/remote_bitrate_estimator/include/remote_bitrate_estimator.h"
  13 #include "webrtc/modules/remote_bitrate_estimator/test/bwe_test.h"
  14 #include "webrtc/test/testsupport/fileutils.h"
  15
  16 using std::string;
  17
  18 namespace webrtc {
  19 namespace testing {
  20 namespace bwe {
  21 #if BWE_TEST_LOGGING_COMPILE_TIME_ENABLE
  22 BweTestConfig::EstimatorConfig CreateEstimatorConfig(
  23     int flow_id, bool plot_delay, bool plot_estimate) {
  24   static const AbsoluteSendTimeRemoteBitrateEstimatorFactory factory =
  25       AbsoluteSendTimeRemoteBitrateEstimatorFactory();
  26
  27   return BweTestConfig::EstimatorConfig("AST", flow_id, &factory, kAimdControl,
  28                                         plot_delay, plot_estimate);
  29 }
  30
  31 BweTestConfig MakeAdaptiveBweTestConfig() {
  32   BweTestConfig result;
  33   result.estimator_configs.push_back(CreateEstimatorConfig(0, true, true));
  34   return result;
  35 }
  36
  37 BweTestConfig MakeMultiFlowBweTestConfig(int flow_count) {
  38   BweTestConfig result;
  39   for (int i = 0; i < flow_count; ++i) {
  40     result.estimator_configs.push_back(CreateEstimatorConfig(i, false, true));
  41   }
  42   return result;
  43 }
  44
  45 // This test fixture is used to instantiate tests running with adaptive video
  46 // senders.
  47 class BweSimulation : public BweTest,
  48                       public ::testing::TestWithParam<BweTestConfig> {
  49  public:
  50   BweSimulation() : BweTest() {}
  51   virtual ~BweSimulation() {}
  52
  53   virtual void SetUp() {
  54     const BweTestConfig& config = GetParam();
  55     SetupTestFromConfig(config);
  56   }
  57
  58  private:
  59   DISALLOW_COPY_AND_ASSIGN(BweSimulation);
  60 };
  61
  62 INSTANTIATE_TEST_CASE_P(VideoSendersTest, BweSimulation,
  63     ::testing::Values(MakeAdaptiveBweTestConfig()));
  64
  65 TEST_P(BweSimulation, SprintUplinkTest) {
  66   VerboseLogging(true);
  67   AdaptiveVideoSender sender(0, this, 30, 300, 0, 0);
  68   RateCounterFilter counter1(this, "sender_output");
  69   TraceBasedDeliveryFilter filter(this, "link_capacity");
  70   RateCounterFilter counter2(this, "receiver_input");
  71   ASSERT_TRUE(filter.Init(test::ResourcePath("sprint-uplink", "rx")));
  72   RunFor(60 * 1000);
  73 }
  74
  75 TEST_P(BweSimulation, Verizon4gDownlinkTest) {
  76   VerboseLogging(true);
  77   AdaptiveVideoSender sender(0, this, 30, 300, 0, 0);
  78   RateCounterFilter counter1(this, "sender_output");
  79   TraceBasedDeliveryFilter filter(this, "link_capacity");
  80   RateCounterFilter counter2(this, "receiver_input");
  81   ASSERT_TRUE(filter.Init(test::ResourcePath("verizon4g-downlink", "rx")));
  82   RunFor(22 * 60 * 1000);
  83 }
  84
  85 TEST_P(BweSimulation, Choke1000kbps500kbps1000kbps) {
  86   VerboseLogging(true);
  87   AdaptiveVideoSender sender(0, this, 30, 300, 0, 0);
  88   ChokeFilter filter(this);
  89   RateCounterFilter counter(this, "receiver_input");
  90   filter.SetCapacity(1000);
  91   filter.SetMaxDelay(500);
  92   RunFor(60 * 1000);
  93   filter.SetCapacity(500);
  94   RunFor(60 * 1000);
  95   filter.SetCapacity(1000);
  96   RunFor(60 * 1000);
  97 }
  98
  99 TEST_P(BweSimulation, Choke200kbps30kbps200kbps) {
 100   VerboseLogging(true);
 101   AdaptiveVideoSender sender(0, this, 30, 300, 0, 0);
 102   ChokeFilter filter(this);
 103   RateCounterFilter counter(this, "receiver_input");
 104   filter.SetCapacity(200);
 105   filter.SetMaxDelay(500);
 106   RunFor(60 * 1000);
 107   filter.SetCapacity(30);
 108   RunFor(60 * 1000);
 109   filter.SetCapacity(200);
 110   RunFor(60 * 1000);
 111 }
 112
 113 TEST_P(BweSimulation, GoogleWifiTrace3Mbps) {
 114   VerboseLogging(true);
 115   AdaptiveVideoSender sender(0, this, 30, 300, 0, 0);
 116   RateCounterFilter counter1(this, "sender_output");
 117   TraceBasedDeliveryFilter filter(this, "link_capacity");
 118   filter.SetMaxDelay(500);
 119   RateCounterFilter counter2(this, "receiver_input");
 120   ASSERT_TRUE(filter.Init(test::ResourcePath("google-wifi-3mbps", "rx")));
 121   RunFor(300 * 1000);
 122 }
 123
 124 class MultiFlowBweSimulation : public BweSimulation {
 125  public:
 126   MultiFlowBweSimulation() : BweSimulation() {}
 127   virtual ~MultiFlowBweSimulation() {}
 128
 129  private:
 130   DISALLOW_COPY_AND_ASSIGN(MultiFlowBweSimulation);
 131 };
 132
 133 INSTANTIATE_TEST_CASE_P(VideoSendersTest, MultiFlowBweSimulation,
 134     ::testing::Values(MakeMultiFlowBweTestConfig(3)));
 135
 136 TEST_P(MultiFlowBweSimulation, SelfFairnessTest) {
 137   VerboseLogging(true);
 138   const int kAllFlowIds[] = {0, 1, 2};
 139   const size_t kNumFlows = sizeof(kAllFlowIds) / sizeof(kAllFlowIds[0]);
 140   scoped_ptr<AdaptiveVideoSender> senders[kNumFlows];
 141   for (size_t i = 0; i < kNumFlows; ++i) {
 142     senders[i].reset(new AdaptiveVideoSender(kAllFlowIds[i], this, 30, 300, 0,
 143                                              0));
 144   }
 145   // Second and third flow.
 146   ChokeFilter choke(this, CreateFlowIds(&kAllFlowIds[1], 2));
 147   choke.SetCapacity(1500);
 148   // First flow.
 149   ChokeFilter choke2(this, CreateFlowIds(&kAllFlowIds[0], 1));
 150   choke2.SetCapacity(1000);
 151
 152   scoped_ptr<RateCounterFilter> rate_counters[kNumFlows];
 153   for (size_t i = 0; i < kNumFlows; ++i) {
 154     rate_counters[i].reset(new RateCounterFilter(
 155         this, CreateFlowIds(&kAllFlowIds[i], 1), "receiver_input"));
 156   }
 157   RunFor(30 * 60 * 1000);
 158 }
 159 #endif  // BWE_TEST_LOGGING_COMPILE_TIME_ENABLE
 160 }  // namespace bwe
 161 }  // namespace testing
 162 }  // namespace webrtc