Tweaked version of BBR for WebRTC.

webrtc/modules/remote_bitrate_estimator/test/packet_sender.h

 /*
  *  Copyright (c) 2015 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.
  */
 
@@ skipping 63 matching lines @@
   void RunFor(int64_t time_ms, Packets* in_out) override;
 
   virtual VideoSource* source() const { return source_; }
 
   uint32_t TargetBitrateKbps() override;
 
   // Implements BitrateObserver.
   void OnNetworkChanged(uint32_t target_bitrate_bps,
                         uint8_t fraction_lost,
                         int64_t rtt) override;
-
   void Pause() override;
   void Resume(int64_t paused_time_ms) override;
 
  protected:
   void ProcessFeedbackAndGeneratePackets(int64_t time_ms,
                                          std::list<FeedbackPacket*>* feedbacks,
                                          Packets* generated);
 
   VideoSource* source_;
   std::unique_ptr<BweSender> bwe_;
@@ skipping 21 matching lines @@
                         bool retransmission,
                         const PacedPacketInfo& pacing_info) override;
   size_t TimeToSendPadding(size_t bytes,
                            const PacedPacketInfo& pacing_info) override;
 
   // Implements BitrateObserver.
   void OnNetworkChanged(uint32_t target_bitrate_bps,
                         uint8_t fraction_lost,
                         int64_t rtt) override;
 
+  void OnNetworkChanged(uint32_t bitrate_for_encoder_bps,
+                        uint32_t bitrate_for_pacer_bps,
+                        bool in_probe_rtt,
+                        int64_t rtt,
+                        uint64_t congestion_window) override;
+  size_t pacer_queue_size_in_bytes() override {
+    return pacer_queue_size_in_bytes_;
+  }
+  void OnBytesAcked(size_t bytes) override;
+
  private:
   int64_t TimeUntilNextProcess(const std::list<Module*>& modules);
   void CallProcess(const std::list<Module*>& modules);
   void QueuePackets(Packets* batch, int64_t end_of_batch_time_us);
 
-  PacedSender pacer_;
+  size_t pacer_queue_size_in_bytes_ = 0;
+  std::unique_ptr<Pacer> pacer_;
   Packets queue_;
   Packets pacer_queue_;
 
   RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(PacedVideoSender);
 };
 
 class TcpSender : public PacketSender {
  public:
   TcpSender(PacketProcessorListener* listener, int flow_id, int64_t offset_ms);
   TcpSender(PacketProcessorListener* listener,
@@ skipping 46 matching lines @@
   int total_sent_bytes_;
   int send_limit_bytes_;  // Initialized by default as kNoLimit.
   int64_t last_generated_packets_ms_;
   size_t num_recent_sent_packets_;
   uint32_t bitrate_kbps_;
 };
 }  // namespace bwe
 }  // namespace testing
 }  // namespace webrtc
 #endif  // WEBRTC_MODULES_REMOTE_BITRATE_ESTIMATOR_TEST_PACKET_SENDER_H_