| 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 620 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 631 } | 631 } |
| 632 | 632 |
| 633 UpdateAggregateNetworkState(); | 633 UpdateAggregateNetworkState(); |
| 634 delete send_stream_impl; | 634 delete send_stream_impl; |
| 635 } | 635 } |
| 636 | 636 |
| 637 webrtc::VideoReceiveStream* Call::CreateVideoReceiveStream( | 637 webrtc::VideoReceiveStream* Call::CreateVideoReceiveStream( |
| 638 webrtc::VideoReceiveStream::Config configuration) { | 638 webrtc::VideoReceiveStream::Config configuration) { |
| 639 TRACE_EVENT0("webrtc", "Call::CreateVideoReceiveStream"); | 639 TRACE_EVENT0("webrtc", "Call::CreateVideoReceiveStream"); |
| 640 RTC_DCHECK(configuration_thread_checker_.CalledOnValidThread()); | 640 RTC_DCHECK(configuration_thread_checker_.CalledOnValidThread()); |
| 641 |
| 642 bool protected_by_flexfec = false; |
| 643 { |
| 644 ReadLockScoped read_lock(*receive_crit_); |
| 645 protected_by_flexfec = |
| 646 flexfec_receive_ssrcs_media_.find(configuration.rtp.remote_ssrc) != |
| 647 flexfec_receive_ssrcs_media_.end(); |
| 648 } |
| 641 VideoReceiveStream* receive_stream = new VideoReceiveStream( | 649 VideoReceiveStream* receive_stream = new VideoReceiveStream( |
| 642 num_cpu_cores_, congestion_controller_.get(), &packet_router_, | 650 num_cpu_cores_, protected_by_flexfec, congestion_controller_.get(), |
| 643 std::move(configuration), voice_engine(), module_process_thread_.get(), | 651 &packet_router_, std::move(configuration), voice_engine(), |
| 644 call_stats_.get(), &remb_); | 652 module_process_thread_.get(), call_stats_.get(), &remb_); |
| 645 | 653 |
| 646 const webrtc::VideoReceiveStream::Config& config = receive_stream->config(); | 654 const webrtc::VideoReceiveStream::Config& config = receive_stream->config(); |
| 647 { | 655 { |
| 648 WriteLockScoped write_lock(*receive_crit_); | 656 WriteLockScoped write_lock(*receive_crit_); |
| 649 RTC_DCHECK(video_receive_ssrcs_.find(config.rtp.remote_ssrc) == | 657 RTC_DCHECK(video_receive_ssrcs_.find(config.rtp.remote_ssrc) == |
| 650 video_receive_ssrcs_.end()); | 658 video_receive_ssrcs_.end()); |
| 651 video_receive_ssrcs_[config.rtp.remote_ssrc] = receive_stream; | 659 video_receive_ssrcs_[config.rtp.remote_ssrc] = receive_stream; |
| 652 if (config.rtp.rtx_ssrc) | 660 if (config.rtp.rtx_ssrc) |
| 653 video_receive_ssrcs_[config.rtp.rtx_ssrc] = receive_stream; | 661 video_receive_ssrcs_[config.rtp.rtx_ssrc] = receive_stream; |
| 654 video_receive_streams_.insert(receive_stream); | 662 video_receive_streams_.insert(receive_stream); |
| (...skipping 544 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1199 | 1207 |
| 1200 void Call::NotifyBweOfReceivedPacket(const RtpPacketReceived& packet) { | 1208 void Call::NotifyBweOfReceivedPacket(const RtpPacketReceived& packet) { |
| 1201 RTPHeader header; | 1209 RTPHeader header; |
| 1202 packet.GetHeader(&header); | 1210 packet.GetHeader(&header); |
| 1203 congestion_controller_->OnReceivedPacket(packet.arrival_time_ms(), | 1211 congestion_controller_->OnReceivedPacket(packet.arrival_time_ms(), |
| 1204 packet.payload_size(), header); | 1212 packet.payload_size(), header); |
| 1205 } | 1213 } |
| 1206 | 1214 |
| 1207 } // namespace internal | 1215 } // namespace internal |
| 1208 } // namespace webrtc | 1216 } // namespace webrtc |
| OLD | NEW |