Chromium Code Reviews| Index: webrtc/audio/audio_send_stream.cc |
| diff --git a/webrtc/audio/audio_send_stream.cc b/webrtc/audio/audio_send_stream.cc |
| index 4dd952295667f7a231497b1202cd70ab10f5ed53..c6ad081db863412f4a06a6c26c096cfccc182fcb 100644 |
| --- a/webrtc/audio/audio_send_stream.cc |
| +++ b/webrtc/audio/audio_send_stream.cc |
| @@ -17,6 +17,10 @@ |
| #include "webrtc/audio/scoped_voe_interface.h" |
| #include "webrtc/base/checks.h" |
| #include "webrtc/base/logging.h" |
| +#include "webrtc/call/congestion_controller.h" |
| +#include "webrtc/modules/pacing/paced_sender.h" |
|
the sun
2015/12/03 11:10:28
I believe these 3 includes are unnecessary:
paced_
stefan-webrtc
2015/12/04 10:31:42
Why do you think that? I can't remove them because
the sun
2015/12/04 12:04:48
Anything needed to make calls *on* CC should be pr
stefan-webrtc
2015/12/04 13:12:39
Ah, the problem is that I'm getting a PacedSender*
the sun
2015/12/04 14:01:57
Acknowledged.
|
| +#include "webrtc/modules/pacing/packet_router.h" |
| +#include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h" |
| #include "webrtc/voice_engine/channel_proxy.h" |
| #include "webrtc/voice_engine/include/voe_audio_processing.h" |
| #include "webrtc/voice_engine/include/voe_codec.h" |
| @@ -55,22 +59,31 @@ std::string AudioSendStream::Config::ToString() const { |
| namespace internal { |
| AudioSendStream::AudioSendStream( |
| const webrtc::AudioSendStream::Config& config, |
| - const rtc::scoped_refptr<webrtc::AudioState>& audio_state) |
| + const rtc::scoped_refptr<webrtc::AudioState>& audio_state, |
| + CongestionController* congestion_controller) |
| : config_(config), audio_state_(audio_state) { |
| LOG(LS_INFO) << "AudioSendStream: " << config_.ToString(); |
| RTC_DCHECK_NE(config_.voe_channel_id, -1); |
| RTC_DCHECK(audio_state_.get()); |
| + RTC_DCHECK(congestion_controller); |
| VoiceEngineImpl* voe_impl = static_cast<VoiceEngineImpl*>(voice_engine()); |
| channel_proxy_ = voe_impl->GetChannelProxy(config_.voe_channel_id); |
| + channel_proxy_->SetCongestionControlObjects( |
| + congestion_controller->pacer(), |
| + congestion_controller->GetTransportFeedbackObserver(), |
| + congestion_controller->packet_router()); |
| channel_proxy_->SetRTCPStatus(true); |
| channel_proxy_->SetLocalSSRC(config.rtp.ssrc); |
| channel_proxy_->SetRTCP_CNAME(config.rtp.c_name); |
| + |
| for (const auto& extension : config.rtp.extensions) { |
| if (extension.name == RtpExtension::kAbsSendTime) { |
| channel_proxy_->SetSendAbsoluteSenderTimeStatus(true, extension.id); |
| } else if (extension.name == RtpExtension::kAudioLevel) { |
| channel_proxy_->SetSendAudioLevelIndicationStatus(true, extension.id); |
| + } else if (extension.name == RtpExtension::kTransportSequenceNumber) { |
| + channel_proxy_->EnableSendTransportSequenceNumber(extension.id); |
| } else { |
| RTC_NOTREACHED() << "Registering unsupported RTP extension."; |
| } |
| @@ -80,6 +93,7 @@ AudioSendStream::AudioSendStream( |
| AudioSendStream::~AudioSendStream() { |
| RTC_DCHECK(thread_checker_.CalledOnValidThread()); |
| LOG(LS_INFO) << "~AudioSendStream: " << config_.ToString(); |
| + channel_proxy_->SetCongestionControlObjects(nullptr, nullptr, nullptr); |
| } |
| void AudioSendStream::Start() { |