Index: webrtc/media/engine/webrtcvideoengine2.cc |
diff --git a/webrtc/media/engine/webrtcvideoengine2.cc b/webrtc/media/engine/webrtcvideoengine2.cc |
index 3cff1e6fbd63778fa4a72721d0d4beac49f4a51e..9846af93cbd84f92a87a2a78b89f4a68d76fbbe1 100644 |
--- a/webrtc/media/engine/webrtcvideoengine2.cc |
+++ b/webrtc/media/engine/webrtcvideoengine2.cc |
@@ -990,10 +990,11 @@ bool WebRtcVideoChannel2::SetSend(bool send) { |
LOG(LS_ERROR) << "SetSend(true) called before setting codec."; |
return false; |
} |
- if (send) { |
- StartAllSendStreams(); |
- } else { |
- StopAllSendStreams(); |
+ { |
+ rtc::CritScope stream_lock(&stream_crit_); |
+ for (const auto& kv : send_streams_) { |
+ kv.second->SetSend(send); |
+ } |
} |
sending_ = send; |
return true; |
@@ -1076,7 +1077,7 @@ bool WebRtcVideoChannel2::AddSendStream(const StreamParams& sp) { |
default_send_ssrc_ = ssrc; |
} |
if (sending_) { |
- stream->Start(); |
+ stream->SetSend(true); |
} |
return true; |
@@ -1482,24 +1483,6 @@ bool WebRtcVideoChannel2::SendRtcp(const uint8_t* data, size_t len) { |
return MediaChannel::SendRtcp(&packet, rtc::PacketOptions()); |
} |
-void WebRtcVideoChannel2::StartAllSendStreams() { |
- rtc::CritScope stream_lock(&stream_crit_); |
- for (std::map<uint32_t, WebRtcVideoSendStream*>::iterator it = |
- send_streams_.begin(); |
- it != send_streams_.end(); ++it) { |
- it->second->Start(); |
- } |
-} |
- |
-void WebRtcVideoChannel2::StopAllSendStreams() { |
- rtc::CritScope stream_lock(&stream_crit_); |
- for (std::map<uint32_t, WebRtcVideoSendStream*>::iterator it = |
- send_streams_.begin(); |
- it != send_streams_.end(); ++it) { |
- it->second->Stop(); |
- } |
-} |
- |
WebRtcVideoChannel2::WebRtcVideoSendStream::VideoSendStreamParameters:: |
VideoSendStreamParameters( |
const webrtc::VideoSendStream::Config& config, |
@@ -1882,6 +1865,8 @@ bool WebRtcVideoChannel2::WebRtcVideoSendStream::SetRtpParameters( |
pending_encoder_reconfiguration_ = true; |
} |
rtp_parameters_ = new_parameters; |
+ // Encoding may have been activated/deactivated. |
+ UpdateSendState(); |
return true; |
} |
@@ -1994,19 +1979,23 @@ void WebRtcVideoChannel2::WebRtcVideoSendStream::SetDimensions( |
parameters_.encoder_config = encoder_config; |
} |
-void WebRtcVideoChannel2::WebRtcVideoSendStream::Start() { |
+void WebRtcVideoChannel2::WebRtcVideoSendStream::SetSend(bool send) { |
rtc::CritScope cs(&lock_); |
- RTC_DCHECK(stream_ != NULL); |
- stream_->Start(); |
- sending_ = true; |
+ RTC_DCHECK(stream_ != nullptr); |
+ sending_ = send; |
+ UpdateSendState(); |
} |
-void WebRtcVideoChannel2::WebRtcVideoSendStream::Stop() { |
+void WebRtcVideoChannel2::WebRtcVideoSendStream::UpdateSendState() { |
rtc::CritScope cs(&lock_); |
pbos-webrtc
2016/03/22 18:13:43
Don't take the lock here. (see header comment)
Al
Taylor Brandstetter
2016/03/22 18:32:43
Done.
|
- if (stream_ != NULL) { |
- stream_->Stop(); |
+ if (sending_ && rtp_parameters_.encodings[0].active) { |
+ RTC_DCHECK(stream_ != nullptr); |
+ stream_->Start(); |
+ } else { |
+ if (stream_ != nullptr) { |
+ stream_->Stop(); |
+ } |
} |
- sending_ = false; |
} |
void WebRtcVideoChannel2::WebRtcVideoSendStream::OnLoadUpdate(Load load) { |