Index: webrtc/call/congestion_controller.cc |
diff --git a/webrtc/video_engine/vie_channel_group.cc b/webrtc/call/congestion_controller.cc |
similarity index 87% |
rename from webrtc/video_engine/vie_channel_group.cc |
rename to webrtc/call/congestion_controller.cc |
index 62d6040e01525c3b172c65a60c602317f81045be..664e53c1326ba3e9785fbb37ce3d31502c2d71e3 100644 |
--- a/webrtc/video_engine/vie_channel_group.cc |
+++ b/webrtc/call/congestion_controller.cc |
@@ -8,7 +8,7 @@ |
* be found in the AUTHORS file in the root of the source tree. |
*/ |
-#include "webrtc/video_engine/vie_channel_group.h" |
+#include "webrtc/call/congestion_controller.h" |
#include "webrtc/base/checks.h" |
#include "webrtc/base/thread_annotations.h" |
@@ -143,8 +143,8 @@ class WrappingBitrateEstimator : public RemoteBitrateEstimator { |
} // namespace |
-ChannelGroup::ChannelGroup(ProcessThread* process_thread, |
- CallStats* call_stats) |
+CongestionController::CongestionController(ProcessThread* process_thread, |
+ CallStats* call_stats) |
: remb_(new VieRemb()), |
bitrate_allocator_(new BitrateAllocator()), |
packet_router_(new PacketRouter()), |
@@ -178,7 +178,7 @@ ChannelGroup::ChannelGroup(ProcessThread* process_thread, |
process_thread->RegisterModule(bitrate_controller_.get()); |
} |
-ChannelGroup::~ChannelGroup() { |
+CongestionController::~CongestionController() { |
pacer_thread_->Stop(); |
pacer_thread_->DeRegisterModule(pacer_.get()); |
process_thread_->DeRegisterModule(bitrate_controller_.get()); |
@@ -191,12 +191,12 @@ ChannelGroup::~ChannelGroup() { |
RTC_DCHECK(encoders_.empty()); |
} |
-void ChannelGroup::AddEncoder(ViEEncoder* encoder) { |
+void CongestionController::AddEncoder(ViEEncoder* encoder) { |
rtc::CritScope lock(&encoder_crit_); |
encoders_.push_back(encoder); |
} |
-void ChannelGroup::RemoveEncoder(ViEEncoder* encoder) { |
+void CongestionController::RemoveEncoder(ViEEncoder* encoder) { |
rtc::CritScope lock(&encoder_crit_); |
for (auto it = encoders_.begin(); it != encoders_.end(); ++it) { |
if (*it == encoder) { |
@@ -206,9 +206,9 @@ void ChannelGroup::RemoveEncoder(ViEEncoder* encoder) { |
} |
} |
-void ChannelGroup::SetBweBitrates(int min_bitrate_bps, |
- int start_bitrate_bps, |
- int max_bitrate_bps) { |
+void CongestionController::SetBweBitrates(int min_bitrate_bps, |
+ int start_bitrate_bps, |
+ int max_bitrate_bps) { |
if (start_bitrate_bps > 0) |
bitrate_controller_->SetStartBitrate(start_bitrate_bps); |
bitrate_controller_->SetMinMaxBitrate(min_bitrate_bps, max_bitrate_bps); |
@@ -220,11 +220,11 @@ void ChannelGroup::SetBweBitrates(int min_bitrate_bps, |
min_bitrate_bps_ = min_bitrate_bps; |
} |
-BitrateController* ChannelGroup::GetBitrateController() const { |
+BitrateController* CongestionController::GetBitrateController() const { |
return bitrate_controller_.get(); |
} |
-RemoteBitrateEstimator* ChannelGroup::GetRemoteBitrateEstimator( |
+RemoteBitrateEstimator* CongestionController::GetRemoteBitrateEstimator( |
bool send_side_bwe) const { |
if (send_side_bwe) |
@@ -233,7 +233,8 @@ RemoteBitrateEstimator* ChannelGroup::GetRemoteBitrateEstimator( |
return remote_bitrate_estimator_.get(); |
} |
-TransportFeedbackObserver* ChannelGroup::GetTransportFeedbackObserver() { |
+TransportFeedbackObserver* |
+CongestionController::GetTransportFeedbackObserver() { |
if (transport_feedback_adapter_.get() == nullptr) { |
transport_feedback_adapter_.reset(new TransportFeedbackAdapter( |
bitrate_controller_->CreateRtcpBandwidthObserver(), |
@@ -248,14 +249,14 @@ TransportFeedbackObserver* ChannelGroup::GetTransportFeedbackObserver() { |
return transport_feedback_adapter_.get(); |
} |
-int64_t ChannelGroup::GetPacerQueuingDelayMs() const { |
+int64_t CongestionController::GetPacerQueuingDelayMs() const { |
return pacer_->QueueInMs(); |
} |
// TODO(mflodman): Move out of this class. |
-void ChannelGroup::SetChannelRembStatus(bool sender, |
- bool receiver, |
- RtpRtcp* rtp_module) { |
+void CongestionController::SetChannelRembStatus(bool sender, |
+ bool receiver, |
+ RtpRtcp* rtp_module) { |
rtp_module->SetREMBStatus(sender || receiver); |
if (sender) { |
remb_->AddRembSender(rtp_module); |
@@ -269,7 +270,7 @@ void ChannelGroup::SetChannelRembStatus(bool sender, |
} |
} |
-void ChannelGroup::SignalNetworkState(NetworkState state) { |
+void CongestionController::SignalNetworkState(NetworkState state) { |
if (state == kNetworkUp) { |
pacer_->Resume(); |
} else { |
@@ -277,10 +278,10 @@ void ChannelGroup::SignalNetworkState(NetworkState state) { |
} |
} |
-// TODO(mflodman): Move this logic out from ChannelGroup. |
-void ChannelGroup::OnNetworkChanged(uint32_t target_bitrate_bps, |
- uint8_t fraction_loss, |
- int64_t rtt) { |
+// TODO(mflodman): Move this logic out from CongestionController. |
+void CongestionController::OnNetworkChanged(uint32_t target_bitrate_bps, |
+ uint8_t fraction_loss, |
+ int64_t rtt) { |
bitrate_allocator_->OnNetworkChanged(target_bitrate_bps, fraction_loss, rtt); |
int pad_up_to_bitrate_bps = 0; |
{ |
@@ -294,7 +295,7 @@ void ChannelGroup::OnNetworkChanged(uint32_t target_bitrate_bps, |
pad_up_to_bitrate_bps / 1000); |
} |
-void ChannelGroup::OnSentPacket(const rtc::SentPacket& sent_packet) { |
+void CongestionController::OnSentPacket(const rtc::SentPacket& sent_packet) { |
if (transport_feedback_adapter_) { |
transport_feedback_adapter_->UpdateSendTime(sent_packet.packet_id, |
sent_packet.send_time_ms); |