OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
170 remb_(remb), | 170 remb_(remb), |
171 overuse_detector_( | 171 overuse_detector_( |
172 Clock::GetRealTimeClock(), | 172 Clock::GetRealTimeClock(), |
173 GetCpuOveruseOptions(config.encoder_settings.full_overuse_time), | 173 GetCpuOveruseOptions(config.encoder_settings.full_overuse_time), |
174 this, | 174 this, |
175 config.post_encode_callback, | 175 config.post_encode_callback, |
176 &stats_proxy_), | 176 &stats_proxy_), |
177 vie_channel_(config.send_transport, | 177 vie_channel_(config.send_transport, |
178 module_process_thread_, | 178 module_process_thread_, |
179 &payload_router_, | 179 &payload_router_, |
180 nullptr, | |
181 encoder_feedback_.GetRtcpIntraFrameObserver(), | 180 encoder_feedback_.GetRtcpIntraFrameObserver(), |
182 congestion_controller_->GetBitrateController() | 181 congestion_controller_->GetBitrateController() |
183 ->CreateRtcpBandwidthObserver(), | 182 ->CreateRtcpBandwidthObserver(), |
184 congestion_controller_->GetTransportFeedbackObserver(), | 183 congestion_controller_->GetTransportFeedbackObserver(), |
185 nullptr, | 184 nullptr, |
186 call_stats_->rtcp_rtt_stats(), | 185 call_stats_->rtcp_rtt_stats(), |
187 congestion_controller_->pacer(), | 186 congestion_controller_->pacer(), |
188 congestion_controller_->packet_router(), | 187 congestion_controller_->packet_router(), |
189 config_.rtp.ssrcs.size(), | 188 config_.rtp.ssrcs.size(), |
190 true), | 189 true), |
(...skipping 13 matching lines...) Expand all Loading... |
204 &overuse_detector_) { | 203 &overuse_detector_) { |
205 LOG(LS_INFO) << "VideoSendStream: " << config_.ToString(); | 204 LOG(LS_INFO) << "VideoSendStream: " << config_.ToString(); |
206 | 205 |
207 RTC_DCHECK(!config_.rtp.ssrcs.empty()); | 206 RTC_DCHECK(!config_.rtp.ssrcs.empty()); |
208 RTC_DCHECK(module_process_thread_); | 207 RTC_DCHECK(module_process_thread_); |
209 RTC_DCHECK(call_stats_); | 208 RTC_DCHECK(call_stats_); |
210 RTC_DCHECK(congestion_controller_); | 209 RTC_DCHECK(congestion_controller_); |
211 RTC_DCHECK(remb_); | 210 RTC_DCHECK(remb_); |
212 | 211 |
213 RTC_CHECK(vie_encoder_.Init()); | 212 RTC_CHECK(vie_encoder_.Init()); |
214 RTC_CHECK(vie_channel_.Init() == 0); | 213 vie_channel_.Init(); |
215 | 214 |
216 vcm_->RegisterProtectionCallback(vie_channel_.vcm_protection_callback()); | 215 vcm_->RegisterProtectionCallback(vie_channel_.vcm_protection_callback()); |
217 | 216 |
218 call_stats_->RegisterStatsObserver(vie_channel_.GetStatsObserver()); | 217 call_stats_->RegisterStatsObserver(vie_channel_.GetStatsObserver()); |
219 | 218 |
220 vie_encoder_.SetSsrcs(std::vector<uint32_t>(1, config_.rtp.ssrcs[0])); | 219 vie_encoder_.SetSsrcs(std::vector<uint32_t>(1, config_.rtp.ssrcs[0])); |
221 | 220 |
222 for (size_t i = 0; i < config_.rtp.extensions.size(); ++i) { | 221 for (size_t i = 0; i < config_.rtp.extensions.size(); ++i) { |
223 const std::string& extension = config_.rtp.extensions[i].name; | 222 const std::string& extension = config_.rtp.extensions[i].name; |
224 int id = config_.rtp.extensions[i].id; | 223 int id = config_.rtp.extensions[i].id; |
(...skipping 403 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
628 used_ssrcs.resize(static_cast<size_t>(video_codec.numberOfSimulcastStreams)); | 627 used_ssrcs.resize(static_cast<size_t>(video_codec.numberOfSimulcastStreams)); |
629 vie_encoder_.SetSsrcs(used_ssrcs); | 628 vie_encoder_.SetSsrcs(used_ssrcs); |
630 | 629 |
631 // Restart the media flow | 630 // Restart the media flow |
632 vie_encoder_.Restart(); | 631 vie_encoder_.Restart(); |
633 | 632 |
634 return true; | 633 return true; |
635 } | 634 } |
636 } // namespace internal | 635 } // namespace internal |
637 } // namespace webrtc | 636 } // namespace webrtc |
OLD | NEW |