| Index: webrtc/modules/congestion_controller/include/congestion_controller.h
|
| diff --git a/webrtc/modules/congestion_controller/include/congestion_controller.h b/webrtc/modules/congestion_controller/include/congestion_controller.h
|
| index 02f3e3429c9cf4eae6b3bf209e2772a76a9437c5..500966b7c1ab0fc7a0fc475a9c98f8a959d3df86 100644
|
| --- a/webrtc/modules/congestion_controller/include/congestion_controller.h
|
| +++ b/webrtc/modules/congestion_controller/include/congestion_controller.h
|
| @@ -16,14 +16,12 @@
|
|
|
| #include "webrtc/base/constructormagic.h"
|
| #include "webrtc/base/criticalsection.h"
|
| -#include "webrtc/base/thread_checker.h"
|
| #include "webrtc/common_types.h"
|
| -#include "webrtc/modules/congestion_controller/delay_based_bwe.h"
|
| #include "webrtc/modules/congestion_controller/transport_feedback_adapter.h"
|
| #include "webrtc/modules/include/module.h"
|
| #include "webrtc/modules/include/module_common_types.h"
|
| +#include "webrtc/modules/pacing/packet_router.h"
|
| #include "webrtc/modules/pacing/paced_sender.h"
|
| -#include "webrtc/modules/pacing/packet_router.h"
|
| #include "webrtc/modules/remote_bitrate_estimator/remote_estimator_proxy.h"
|
|
|
| namespace rtc {
|
| @@ -39,10 +37,9 @@
|
| class RemoteBitrateEstimator;
|
| class RemoteBitrateObserver;
|
| class RtcEventLog;
|
| +class TransportFeedbackObserver;
|
|
|
| -class CongestionController : public CallStatsObserver,
|
| - public Module,
|
| - public TransportFeedbackObserver {
|
| +class CongestionController : public CallStatsObserver, public Module {
|
| public:
|
| // Observer class for bitrate changes announced due to change in bandwidth
|
| // estimate or due to that the send pacer is full. Fraction loss and rtt is
|
| @@ -94,6 +91,7 @@
|
| // TODO(nisse): Delete this accessor function. The pacer should be
|
| // internal to the congestion controller.
|
| virtual PacedSender* pacer() { return pacer_.get(); }
|
| + virtual TransportFeedbackObserver* GetTransportFeedbackObserver();
|
| RateLimiter* GetRetransmissionRateLimiter();
|
| void EnablePeriodicAlrProbing(bool enable);
|
|
|
| @@ -118,13 +116,6 @@
|
| // Implements Module.
|
| int64_t TimeUntilNextProcess() override;
|
| void Process() override;
|
| -
|
| - // Implements TransportFeedbackObserver.
|
| - void AddPacket(uint16_t sequence_number,
|
| - size_t length,
|
| - const PacedPacketInfo& pacing_info) override;
|
| - void OnTransportFeedback(const rtcp::TransportFeedback& feedback) override;
|
| - std::vector<PacketFeedback> GetTransportFeedbackVector() const override;
|
|
|
| private:
|
| class WrappingBitrateEstimator : public RemoteBitrateEstimator {
|
| @@ -174,7 +165,6 @@
|
| int64_t rtt);
|
| Clock* const clock_;
|
| Observer* const observer_;
|
| - RtcEventLog* const event_log_;
|
| PacketRouter* const packet_router_;
|
| const std::unique_ptr<PacedSender> pacer_;
|
| const std::unique_ptr<BitrateController> bitrate_controller_;
|
| @@ -185,15 +175,11 @@
|
| TransportFeedbackAdapter transport_feedback_adapter_;
|
| int min_bitrate_bps_;
|
| int max_bitrate_bps_;
|
| - rtc::CriticalSection network_state_lock_;
|
| - uint32_t last_reported_bitrate_bps_ GUARDED_BY(network_state_lock_);
|
| - uint8_t last_reported_fraction_loss_ GUARDED_BY(network_state_lock_);
|
| - int64_t last_reported_rtt_ GUARDED_BY(network_state_lock_);
|
| - NetworkState network_state_ GUARDED_BY(network_state_lock_);
|
| - rtc::CriticalSection bwe_lock_;
|
| - std::unique_ptr<DelayBasedBwe> delay_based_bwe_ GUARDED_BY(bwe_lock_);
|
| -
|
| - rtc::ThreadChecker worker_thread_checker_;
|
| + rtc::CriticalSection critsect_;
|
| + uint32_t last_reported_bitrate_bps_ GUARDED_BY(critsect_);
|
| + uint8_t last_reported_fraction_loss_ GUARDED_BY(critsect_);
|
| + int64_t last_reported_rtt_ GUARDED_BY(critsect_);
|
| + NetworkState network_state_ GUARDED_BY(critsect_);
|
|
|
| RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(CongestionController);
|
| };
|
|
|