| 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 |