Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(114)

Unified Diff: webrtc/video/video_receive_stream.cc

Issue 1419803002: Rename ChannelGroup to CongestionController and move to webrtc/call/. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Rebase Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webrtc/video/video_receive_stream.cc
diff --git a/webrtc/video/video_receive_stream.cc b/webrtc/video/video_receive_stream.cc
index 380466ab07ef0d2eafdb3d8672008e8cea88117e..22c9acb7fea36c87256c3c9d34d6ee7398b59f22 100644
--- a/webrtc/video/video_receive_stream.cc
+++ b/webrtc/video/video_receive_stream.cc
@@ -15,6 +15,7 @@
#include <string>
#include "webrtc/base/checks.h"
+#include "webrtc/call/congestion_controller.h"
#include "webrtc/common_video/libyuv/include/webrtc_libyuv.h"
#include "webrtc/system_wrappers/interface/clock.h"
#include "webrtc/system_wrappers/interface/logging.h"
@@ -137,30 +138,33 @@ VideoCodec CreateDecoderVideoCodec(const VideoReceiveStream::Decoder& decoder) {
}
} // namespace
-VideoReceiveStream::VideoReceiveStream(int num_cpu_cores,
- ChannelGroup* channel_group,
- const VideoReceiveStream::Config& config,
- webrtc::VoiceEngine* voice_engine,
- ProcessThread* process_thread,
- CallStats* call_stats)
+VideoReceiveStream::VideoReceiveStream(
+ int num_cpu_cores,
+ CongestionController* congestion_controller,
+ const VideoReceiveStream::Config& config,
+ webrtc::VoiceEngine* voice_engine,
+ ProcessThread* process_thread,
+ CallStats* call_stats)
: transport_adapter_(config.rtcp_send_transport),
encoded_frame_proxy_(config.pre_decode_callback),
config_(config),
clock_(Clock::GetRealTimeClock()),
- channel_group_(channel_group),
+ congestion_controller_(congestion_controller),
call_stats_(call_stats) {
LOG(LS_INFO) << "VideoReceiveStream: " << config_.ToString();
bool send_side_bwe = UseSendSideBwe(config_.rtp.extensions);
RemoteBitrateEstimator* bitrate_estimator =
- channel_group_->GetRemoteBitrateEstimator(send_side_bwe);
+ congestion_controller_->GetRemoteBitrateEstimator(send_side_bwe);
vie_channel_.reset(new ViEChannel(
num_cpu_cores, &transport_adapter_, process_thread, nullptr,
- channel_group_->GetBitrateController()->CreateRtcpBandwidthObserver(),
+ congestion_controller_->GetBitrateController()->
+ CreateRtcpBandwidthObserver(),
nullptr, bitrate_estimator, call_stats_->rtcp_rtt_stats(),
- channel_group_->pacer(), channel_group_->packet_router(), 1, false));
+ congestion_controller_->pacer(), congestion_controller_->packet_router(),
+ 1, false));
RTC_CHECK(vie_channel_->Init() == 0);
@@ -195,8 +199,8 @@ VideoReceiveStream::VideoReceiveStream(int num_cpu_cores,
vie_channel_->SetUseRtxPayloadMappingOnRestore(
config_.rtp.use_rtx_payload_mapping_on_restore);
- channel_group_->SetChannelRembStatus(false, config_.rtp.remb,
- vie_channel_->rtp_rtcp());
+ congestion_controller_->SetChannelRembStatus(false, config_.rtp.remb,
+ vie_channel_->rtp_rtcp());
for (size_t i = 0; i < config_.rtp.extensions.size(); ++i) {
const std::string& extension = config_.rtp.extensions[i].name;
@@ -287,12 +291,13 @@ VideoReceiveStream::~VideoReceiveStream() {
vie_channel_->DeRegisterExternalDecoder(config_.decoders[i].payload_type);
call_stats_->DeregisterStatsObserver(vie_channel_->GetStatsObserver());
- channel_group_->SetChannelRembStatus(false, false, vie_channel_->rtp_rtcp());
+ congestion_controller_->SetChannelRembStatus(false, false,
+ vie_channel_->rtp_rtcp());
uint32_t remote_ssrc = vie_channel_->GetRemoteSSRC();
bool send_side_bwe = UseSendSideBwe(config_.rtp.extensions);
- channel_group_->GetRemoteBitrateEstimator(send_side_bwe)->RemoveStream(
- remote_ssrc);
+ congestion_controller_->GetRemoteBitrateEstimator(send_side_bwe)->
+ RemoveStream(remote_ssrc);
}
void VideoReceiveStream::Start() {

Powered by Google App Engine
This is Rietveld 408576698