Index: webrtc/video_engine/vie_channel_group.cc |
diff --git a/webrtc/video_engine/vie_channel_group.cc b/webrtc/video_engine/vie_channel_group.cc |
index 5c55aaaf995ef706af52a7eb9fd043938bfb975a..9d8615b3f98b46bde1cafb4baf02ea309040320d 100644 |
--- a/webrtc/video_engine/vie_channel_group.cc |
+++ b/webrtc/video_engine/vie_channel_group.cc |
@@ -18,6 +18,7 @@ |
#include "webrtc/modules/remote_bitrate_estimator/include/send_time_history.h" |
#include "webrtc/modules/remote_bitrate_estimator/remote_bitrate_estimator_abs_send_time.h" |
#include "webrtc/modules/remote_bitrate_estimator/remote_bitrate_estimator_single_stream.h" |
+#include "webrtc/modules/remote_bitrate_estimator/remote_estimator_proxy.h" |
#include "webrtc/modules/remote_bitrate_estimator/transport_feedback_adapter.h" |
#include "webrtc/modules/rtp_rtcp/interface/rtp_rtcp.h" |
#include "webrtc/modules/utility/interface/process_thread.h" |
@@ -160,14 +161,18 @@ ChannelGroup::ChannelGroup(ProcessThread* process_thread) |
bitrate_controller_( |
BitrateController::CreateBitrateController(Clock::GetRealTimeClock(), |
this)) { |
- remote_bitrate_estimator_.reset(new WrappingBitrateEstimator( |
- remb_.get(), Clock::GetRealTimeClock())); |
+ Clock* clock = Clock::GetRealTimeClock(); |
+ remote_bitrate_estimator_.reset( |
+ new WrappingBitrateEstimator(remb_.get(), clock)); |
+ remote_estimator_proxy_.reset( |
+ new RemoteEstimatorProxy(clock, packet_router_.get())); |
stefan-webrtc
2015/09/18 10:57:23
Can't these be instantiated in the initializer lis
sprang_webrtc
2015/09/21 10:44:10
Done.
|
call_stats_->RegisterStatsObserver(remote_bitrate_estimator_.get()); |
pacer_thread_->RegisterModule(pacer_.get()); |
pacer_thread_->Start(); |
+ process_thread->RegisterModule(remote_estimator_proxy_.get()); |
process_thread->RegisterModule(remote_bitrate_estimator_.get()); |
process_thread->RegisterModule(call_stats_.get()); |
process_thread->RegisterModule(bitrate_controller_.get()); |
@@ -179,7 +184,10 @@ ChannelGroup::~ChannelGroup() { |
process_thread_->DeRegisterModule(bitrate_controller_.get()); |
process_thread_->DeRegisterModule(call_stats_.get()); |
process_thread_->DeRegisterModule(remote_bitrate_estimator_.get()); |
+ process_thread_->DeRegisterModule(remote_estimator_proxy_.get()); |
call_stats_->DeregisterStatsObserver(remote_bitrate_estimator_.get()); |
+ if (transport_feedback_adapter_.get()) |
+ call_stats_->DeregisterStatsObserver(transport_feedback_adapter_.get()); |
RTC_DCHECK(channel_map_.empty()); |
RTC_DCHECK(!remb_->InUse()); |
RTC_DCHECK(vie_encoder_map_.empty()); |
@@ -189,7 +197,30 @@ bool ChannelGroup::CreateSendChannel(int channel_id, |
int engine_id, |
Transport* transport, |
int number_of_cores, |
- const std::vector<uint32_t>& ssrcs) { |
+ const VideoSendStream::Config& config) { |
+ TransportFeedbackObserver* transport_feedback_observer = nullptr; |
+ bool transport_seq_enabled = false; |
+ for (const RtpExtension& extension : config.rtp.extensions) { |
+ if (extension.name == RtpExtension::kTransportSequenceNumber) { |
+ transport_seq_enabled = true; |
+ break; |
+ } |
+ } |
+ if (transport_seq_enabled) { |
+ if (transport_feedback_adapter_.get() == nullptr) { |
+ transport_feedback_adapter_.reset(new TransportFeedbackAdapter( |
+ bitrate_controller_->CreateRtcpBandwidthObserver(), |
+ Clock::GetRealTimeClock(), process_thread_)); |
+ transport_feedback_adapter_->SetBitrateEstimator( |
+ new RemoteBitrateEstimatorAbsSendTime( |
+ transport_feedback_adapter_.get(), Clock::GetRealTimeClock(), |
+ RemoteBitrateEstimator::kDefaultMinBitrateBps)); |
+ call_stats_->RegisterStatsObserver(transport_feedback_adapter_.get()); |
+ } |
+ transport_feedback_observer = transport_feedback_adapter_.get(); |
+ } |
+ |
+ const std::vector<uint32_t>& ssrcs = config.rtp.ssrcs; |
RTC_DCHECK(!ssrcs.empty()); |
rtc::scoped_ptr<ViEEncoder> vie_encoder( |
new ViEEncoder(channel_id, number_of_cores, *process_thread_, |
@@ -199,7 +230,9 @@ bool ChannelGroup::CreateSendChannel(int channel_id, |
} |
ViEEncoder* encoder = vie_encoder.get(); |
if (!CreateChannel(channel_id, engine_id, transport, number_of_cores, |
- vie_encoder.release(), ssrcs.size(), true)) { |
+ vie_encoder.release(), ssrcs.size(), true, |
+ remote_bitrate_estimator_.get(), |
+ transport_feedback_observer)) { |
return false; |
} |
ViEChannel* channel = channel_map_[channel_id]; |
@@ -213,12 +246,28 @@ bool ChannelGroup::CreateSendChannel(int channel_id, |
return true; |
} |
-bool ChannelGroup::CreateReceiveChannel(int channel_id, |
- int engine_id, |
- Transport* transport, |
- int number_of_cores) { |
+bool ChannelGroup::CreateReceiveChannel( |
+ int channel_id, |
+ int engine_id, |
+ Transport* transport, |
+ int number_of_cores, |
+ const VideoReceiveStream::Config& config) { |
+ bool send_side_bwe = false; |
+ for (const RtpExtension& extension : config.rtp.extensions) { |
+ if (extension.name == RtpExtension::kTransportSequenceNumber) { |
+ send_side_bwe = true; |
+ break; |
+ } |
+ } |
stefan-webrtc
2015/09/18 10:57:23
Maybe it would be good to DCHECK that we don't run
sprang_webrtc
2015/09/21 10:44:10
Right now a mix is supported. So the not very expl
stefan-webrtc
2015/09/21 11:12:07
Well, at least we could make that a requirement if
sprang_webrtc
2015/09/21 13:42:53
Is suspect there might. It's also gonna be kinda m
stefan-webrtc
2015/09/21 14:06:30
Yes, that may be so. Let's leave it as is for the
|
+ |
+ RemoteBitrateEstimator* bitrate_estimator; |
+ if (send_side_bwe) { |
+ bitrate_estimator = remote_estimator_proxy_.get(); |
+ } else { |
+ bitrate_estimator = remote_bitrate_estimator_.get(); |
+ } |
return CreateChannel(channel_id, engine_id, transport, number_of_cores, |
- nullptr, 1, false); |
+ nullptr, 1, false, bitrate_estimator, nullptr); |
} |
bool ChannelGroup::CreateChannel(int channel_id, |
@@ -227,13 +276,15 @@ bool ChannelGroup::CreateChannel(int channel_id, |
int number_of_cores, |
ViEEncoder* vie_encoder, |
size_t max_rtp_streams, |
- bool sender) { |
+ bool sender, |
+ RemoteBitrateEstimator* bitrate_estimator, |
+ TransportFeedbackObserver* feedback_observer) { |
rtc::scoped_ptr<ViEChannel> channel(new ViEChannel( |
channel_id, engine_id, number_of_cores, transport, process_thread_, |
encoder_state_feedback_->GetRtcpIntraFrameObserver(), |
- bitrate_controller_->CreateRtcpBandwidthObserver(), nullptr, |
- remote_bitrate_estimator_.get(), call_stats_->rtcp_rtt_stats(), |
- pacer_.get(), packet_router_.get(), max_rtp_streams, sender)); |
+ bitrate_controller_->CreateRtcpBandwidthObserver(), feedback_observer, |
+ bitrate_estimator, call_stats_->rtcp_rtt_stats(), pacer_.get(), |
+ packet_router_.get(), max_rtp_streams, sender)); |
if (channel->Init() != 0) { |
return false; |
} |