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 395 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
406 return this; | 406 return this; |
407 } | 407 } |
408 | 408 |
409 webrtc::AudioSendStream* Call::CreateAudioSendStream( | 409 webrtc::AudioSendStream* Call::CreateAudioSendStream( |
410 const webrtc::AudioSendStream::Config& config) { | 410 const webrtc::AudioSendStream::Config& config) { |
411 TRACE_EVENT0("webrtc", "Call::CreateAudioSendStream"); | 411 TRACE_EVENT0("webrtc", "Call::CreateAudioSendStream"); |
412 RTC_DCHECK(configuration_thread_checker_.CalledOnValidThread()); | 412 RTC_DCHECK(configuration_thread_checker_.CalledOnValidThread()); |
413 event_log_->LogAudioSendStreamConfig(config); | 413 event_log_->LogAudioSendStreamConfig(config); |
414 AudioSendStream* send_stream = new AudioSendStream( | 414 AudioSendStream* send_stream = new AudioSendStream( |
415 config, config_.audio_state, &worker_queue_, congestion_controller_.get(), | 415 config, config_.audio_state, &worker_queue_, congestion_controller_.get(), |
416 bitrate_allocator_.get(), event_log_); | 416 bitrate_allocator_.get(), event_log_, call_stats_->rtcp_rtt_stats()); |
417 { | 417 { |
418 WriteLockScoped write_lock(*send_crit_); | 418 WriteLockScoped write_lock(*send_crit_); |
419 RTC_DCHECK(audio_send_ssrcs_.find(config.rtp.ssrc) == | 419 RTC_DCHECK(audio_send_ssrcs_.find(config.rtp.ssrc) == |
420 audio_send_ssrcs_.end()); | 420 audio_send_ssrcs_.end()); |
421 audio_send_ssrcs_[config.rtp.ssrc] = send_stream; | 421 audio_send_ssrcs_[config.rtp.ssrc] = send_stream; |
422 } | 422 } |
423 { | 423 { |
424 ReadLockScoped read_lock(*receive_crit_); | 424 ReadLockScoped read_lock(*receive_crit_); |
425 for (const auto& kv : audio_receive_ssrcs_) { | 425 for (const auto& kv : audio_receive_ssrcs_) { |
426 if (kv.second->config().rtp.local_ssrc == config.rtp.ssrc) { | 426 if (kv.second->config().rtp.local_ssrc == config.rtp.ssrc) { |
(...skipping 673 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1100 uint32_t ssrc = ByteReader<uint32_t>::ReadBigEndian(&packet[8]); | 1100 uint32_t ssrc = ByteReader<uint32_t>::ReadBigEndian(&packet[8]); |
1101 ReadLockScoped read_lock(*receive_crit_); | 1101 ReadLockScoped read_lock(*receive_crit_); |
1102 auto it = video_receive_ssrcs_.find(ssrc); | 1102 auto it = video_receive_ssrcs_.find(ssrc); |
1103 if (it == video_receive_ssrcs_.end()) | 1103 if (it == video_receive_ssrcs_.end()) |
1104 return false; | 1104 return false; |
1105 return it->second->OnRecoveredPacket(packet, length); | 1105 return it->second->OnRecoveredPacket(packet, length); |
1106 } | 1106 } |
1107 | 1107 |
1108 } // namespace internal | 1108 } // namespace internal |
1109 } // namespace webrtc | 1109 } // namespace webrtc |
OLD | NEW |