Remove SendPacer from ViEEncoder

webrtc/modules/bitrate_controller/bitrate_controller_unittest.cc

 /*
  *  Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
 #include <algorithm>
 #include <vector>
 
 #include "testing/gtest/include/gtest/gtest.h"
 
 #include "webrtc/modules/bitrate_controller/include/bitrate_controller.h"
+#include "webrtc/modules/pacing/mock/mock_paced_sender.h"
 #include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h"
 
+using ::testing::Exactly;
+using ::testing::Return;
+
+using webrtc::BitrateController;
+using webrtc::BitrateObserver;
+using webrtc::PacedSender;
 using webrtc::RtcpBandwidthObserver;
-using webrtc::BitrateObserver;
-using webrtc::BitrateController;
 
 uint8_t WeightedLoss(int num_packets1, uint8_t fraction_loss1,
                      int num_packets2, uint8_t fraction_loss2) {
   int weighted_sum = num_packets1 * fraction_loss1 +
       num_packets2 * fraction_loss2;
   int total_num_packets = num_packets1 + num_packets2;
   return (weighted_sum + total_num_packets / 2) / total_num_packets;
 }
 
 webrtc::RTCPReportBlock CreateReportBlock(
@@ skipping 22 matching lines @@
   uint8_t last_fraction_loss_;
   int64_t last_rtt_;
 };
 
 class BitrateControllerTest : public ::testing::Test {
  protected:
   BitrateControllerTest() : clock_(0) {}
   ~BitrateControllerTest() {}
 
   virtual void SetUp() {
-    controller_ =
-        BitrateController::CreateBitrateController(&clock_, &bitrate_observer_);
+    controller_ = BitrateController::CreateBitrateController(
+        &clock_, &bitrate_observer_, &pacer_);
     controller_->SetStartBitrate(kStartBitrateBps);
     EXPECT_EQ(kStartBitrateBps, bitrate_observer_.last_bitrate_);
     controller_->SetMinMaxBitrate(kMinBitrateBps, kMaxBitrateBps);
     EXPECT_EQ(kStartBitrateBps, bitrate_observer_.last_bitrate_);
     bandwidth_observer_ = controller_->CreateRtcpBandwidthObserver();
   }
 
   virtual void TearDown() {
     delete bandwidth_observer_;
     delete controller_;
   }
 
   const int kMinBitrateBps = 100000;
   const int kStartBitrateBps = 200000;
   const int kMaxBitrateBps = 300000;
 
   const int kDefaultMinBitrateBps = 10000;
   const int kDefaultMaxBitrateBps = 1000000000;
 
   webrtc::SimulatedClock clock_;
   TestBitrateObserver bitrate_observer_;
+  testing::NiceMock<webrtc::MockPacedSender> pacer_;
   BitrateController* controller_;
   RtcpBandwidthObserver* bandwidth_observer_;
 };
 
 TEST_F(BitrateControllerTest, DefaultMinMaxBitrate) {
   // Receive successively lower REMBs, verify the reserved bitrate is deducted.
   controller_->SetMinMaxBitrate(0, 0);
   EXPECT_EQ(kStartBitrateBps, bitrate_observer_.last_bitrate_);
   bandwidth_observer_->OnReceivedEstimatedBitrate(kDefaultMinBitrateBps / 2);
   EXPECT_EQ(kDefaultMinBitrateBps, bitrate_observer_.last_bitrate_);
@@ skipping 295 matching lines @@
   EXPECT_EQ(120000, bitrate_observer_.last_bitrate_);
   controller_->SetReservedBitrate(50000);
   bandwidth_observer_->OnReceivedEstimatedBitrate(120000);
   // Limited by min bitrate.
   EXPECT_EQ(100000, bitrate_observer_.last_bitrate_);
 
   controller_->SetReservedBitrate(10000);
   bandwidth_observer_->OnReceivedEstimatedBitrate(1);
   EXPECT_EQ(100000, bitrate_observer_.last_bitrate_);
 }
+
+TEST_F(BitrateControllerTest, OnSendQueueFull) {
+  bandwidth_observer_->OnReceivedEstimatedBitrate(200000);
+  EXPECT_EQ(200000, bitrate_observer_.last_bitrate_);
+  // Let the pacer be full next time the controller checks.
+  EXPECT_CALL(pacer_, ExpectedQueueTimeMs())
+      .WillOnce(Return(PacedSender::kMaxQueueLengthMs + 1));
+  clock_.AdvanceTimeMilliseconds(25);
+  controller_->Process();
+  EXPECT_EQ(0, bitrate_observer_.last_bitrate_);
+  // Let the pacer not be full next time the controller checks.
+  EXPECT_CALL(pacer_, ExpectedQueueTimeMs())
+      .WillOnce(Return(PacedSender::kMaxQueueLengthMs - 1));
+  clock_.AdvanceTimeMilliseconds(25);
+  controller_->Process();
+  EXPECT_EQ(200000, bitrate_observer_.last_bitrate_);
+}