summaryrefslogtreecommitdiff
path: root/video_engine/vie_channel_manager.cc
diff options
context:
space:
mode:
authorpwestin@webrtc.org <pwestin@webrtc.org@4adac7df-926f-26a2-2b94-8c16560cd09d>2012-11-13 21:12:39 +0000
committerpwestin@webrtc.org <pwestin@webrtc.org@4adac7df-926f-26a2-2b94-8c16560cd09d>2012-11-13 21:12:39 +0000
commit5e87b5f032780f6941a27c2d5068ab1e89e659a6 (patch)
tree9d14b68f57bdc929d2dbb9f813dc8351b5fb6635 /video_engine/vie_channel_manager.cc
parent376495a5be5132e154f21489f4b4d4e76c334edc (diff)
downloadwebrtc-5e87b5f032780f6941a27c2d5068ab1e89e659a6.tar.gz
Enable paced sender.
Review URL: https://webrtc-codereview.appspot.com/965016 git-svn-id: http://webrtc.googlecode.com/svn/trunk/webrtc@3089 4adac7df-926f-26a2-2b94-8c16560cd09d
Diffstat (limited to 'video_engine/vie_channel_manager.cc')
-rw-r--r--video_engine/vie_channel_manager.cc25
1 files changed, 14 insertions, 11 deletions
diff --git a/video_engine/vie_channel_manager.cc b/video_engine/vie_channel_manager.cc
index b1998c3e..03509f2c 100644
--- a/video_engine/vie_channel_manager.cc
+++ b/video_engine/vie_channel_manager.cc
@@ -142,14 +142,11 @@ int ViEChannelManager::CreateChannel(int* channel_id,
if (!channel_group) {
return -1;
}
-
int new_channel_id = FreeChannelId();
if (new_channel_id == -1) {
return -1;
}
-
BitrateController* bitrate_controller = channel_group->GetBitrateController();
-
RtcpBandwidthObserver* bandwidth_observer =
bitrate_controller->CreateRtcpBandwidthObserver();
RemoteBitrateEstimator* remote_bitrate_estimator =
@@ -164,10 +161,12 @@ int ViEChannelManager::CreateChannel(int* channel_id,
*module_process_thread_,
bitrate_controller);
if (!(vie_encoder->Init() &&
- CreateChannelObject(
- new_channel_id, vie_encoder, bandwidth_observer,
- remote_bitrate_estimator,
- encoder_state_feedback->GetRtcpIntraFrameObserver(), sender))) {
+ CreateChannelObject(
+ new_channel_id,
+ vie_encoder,
+ bandwidth_observer,
+ remote_bitrate_estimator,
+ encoder_state_feedback->GetRtcpIntraFrameObserver(), sender))) {
delete vie_encoder;
vie_encoder = NULL;
}
@@ -180,18 +179,19 @@ int ViEChannelManager::CreateChannel(int* channel_id,
vie_encoder = ViEEncoderPtr(original_channel);
assert(vie_encoder);
if (!CreateChannelObject(
- new_channel_id, vie_encoder, bandwidth_observer,
+ new_channel_id,
+ vie_encoder,
+ bandwidth_observer,
remote_bitrate_estimator,
- encoder_state_feedback->GetRtcpIntraFrameObserver(), sender)) {
+ encoder_state_feedback->GetRtcpIntraFrameObserver(),
+ sender)) {
vie_encoder = NULL;
}
}
-
if (!vie_encoder) {
ReturnChannelId(new_channel_id);
return -1;
}
-
*channel_id = new_channel_id;
channel_group->AddChannel(*channel_id);
return 0;
@@ -401,6 +401,8 @@ bool ViEChannelManager::CreateChannelObject(
RemoteBitrateEstimator* remote_bitrate_estimator,
RtcpIntraFrameObserver* intra_frame_observer,
bool sender) {
+ PacedSender* paced_sender = vie_encoder->GetPacedSender();
+
// Register the channel at the encoder.
RtpRtcp* send_rtp_rtcp_module = vie_encoder->SendRtpRtcpModule();
@@ -410,6 +412,7 @@ bool ViEChannelManager::CreateChannelObject(
intra_frame_observer,
bandwidth_observer,
remote_bitrate_estimator,
+ paced_sender,
send_rtp_rtcp_module,
sender);
if (vie_channel->Init() != 0) {