| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 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 476 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 487 return false; | 487 return false; |
| 488 } | 488 } |
| 489 header.payload_type_frequency = | 489 header.payload_type_frequency = |
| 490 rtp_payload_registry_->GetPayloadTypeFrequency(header.payloadType); | 490 rtp_payload_registry_->GetPayloadTypeFrequency(header.payloadType); |
| 491 if (header.payload_type_frequency < 0) | 491 if (header.payload_type_frequency < 0) |
| 492 return false; | 492 return false; |
| 493 return ReceivePacket(rtp_packet, rtp_packet_length, header, false); | 493 return ReceivePacket(rtp_packet, rtp_packet_length, header, false); |
| 494 } | 494 } |
| 495 | 495 |
| 496 int32_t Channel::GetAudioFrame(int32_t id, AudioFrame* audioFrame) { | 496 int32_t Channel::GetAudioFrame(int32_t id, AudioFrame* audioFrame) { |
| 497 if (event_log_) { | 497 unsigned int ssrc; |
| 498 unsigned int ssrc; | 498 RTC_CHECK_EQ(GetLocalSSRC(ssrc), 0); |
| 499 RTC_CHECK_EQ(GetLocalSSRC(ssrc), 0); | 499 event_log_.LogAudioPlayout(ssrc); |
| 500 event_log_->LogAudioPlayout(ssrc); | |
| 501 } | |
| 502 // Get 10ms raw PCM data from the ACM (mixer limits output frequency) | 500 // Get 10ms raw PCM data from the ACM (mixer limits output frequency) |
| 503 if (audio_coding_->PlayoutData10Ms(audioFrame->sample_rate_hz_, audioFrame) == | 501 if (audio_coding_->PlayoutData10Ms(audioFrame->sample_rate_hz_, audioFrame) == |
| 504 -1) { | 502 -1) { |
| 505 WEBRTC_TRACE(kTraceError, kTraceVoice, VoEId(_instanceId, _channelId), | 503 WEBRTC_TRACE(kTraceError, kTraceVoice, VoEId(_instanceId, _channelId), |
| 506 "Channel::GetAudioFrame() PlayoutData10Ms() failed!"); | 504 "Channel::GetAudioFrame() PlayoutData10Ms() failed!"); |
| 507 // In all likelihood, the audio in this frame is garbage. We return an | 505 // In all likelihood, the audio in this frame is garbage. We return an |
| 508 // error so that the audio mixer module doesn't add it to the mix. As | 506 // error so that the audio mixer module doesn't add it to the mix. As |
| 509 // a result, it won't be played out and the actions skipped here are | 507 // a result, it won't be played out and the actions skipped here are |
| 510 // irrelevant. | 508 // irrelevant. |
| 511 return -1; | 509 return -1; |
| (...skipping 155 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 667 } | 665 } |
| 668 } | 666 } |
| 669 } | 667 } |
| 670 | 668 |
| 671 return (highestNeeded); | 669 return (highestNeeded); |
| 672 } | 670 } |
| 673 | 671 |
| 674 int32_t Channel::CreateChannel(Channel*& channel, | 672 int32_t Channel::CreateChannel(Channel*& channel, |
| 675 int32_t channelId, | 673 int32_t channelId, |
| 676 uint32_t instanceId, | 674 uint32_t instanceId, |
| 677 RtcEventLog* const event_log, | |
| 678 const Config& config) { | 675 const Config& config) { |
| 679 WEBRTC_TRACE(kTraceMemory, kTraceVoice, VoEId(instanceId, channelId), | 676 WEBRTC_TRACE(kTraceMemory, kTraceVoice, VoEId(instanceId, channelId), |
| 680 "Channel::CreateChannel(channelId=%d, instanceId=%d)", channelId, | 677 "Channel::CreateChannel(channelId=%d, instanceId=%d)", channelId, |
| 681 instanceId); | 678 instanceId); |
| 682 | 679 |
| 683 channel = new Channel(channelId, instanceId, event_log, config); | 680 channel = new Channel(channelId, instanceId, config); |
| 684 if (channel == NULL) { | 681 if (channel == NULL) { |
| 685 WEBRTC_TRACE(kTraceMemory, kTraceVoice, VoEId(instanceId, channelId), | 682 WEBRTC_TRACE(kTraceMemory, kTraceVoice, VoEId(instanceId, channelId), |
| 686 "Channel::CreateChannel() unable to allocate memory for" | 683 "Channel::CreateChannel() unable to allocate memory for" |
| 687 " channel"); | 684 " channel"); |
| 688 return -1; | 685 return -1; |
| 689 } | 686 } |
| 690 return 0; | 687 return 0; |
| 691 } | 688 } |
| 692 | 689 |
| 693 void Channel::PlayNotification(int32_t id, uint32_t durationMs) { | 690 void Channel::PlayNotification(int32_t id, uint32_t durationMs) { |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 730 assert(id == _outputFileRecorderId); | 727 assert(id == _outputFileRecorderId); |
| 731 | 728 |
| 732 rtc::CritScope cs(&_fileCritSect); | 729 rtc::CritScope cs(&_fileCritSect); |
| 733 | 730 |
| 734 _outputFileRecording = false; | 731 _outputFileRecording = false; |
| 735 WEBRTC_TRACE(kTraceStateInfo, kTraceVoice, VoEId(_instanceId, _channelId), | 732 WEBRTC_TRACE(kTraceStateInfo, kTraceVoice, VoEId(_instanceId, _channelId), |
| 736 "Channel::RecordFileEnded() => output file recorder module is" | 733 "Channel::RecordFileEnded() => output file recorder module is" |
| 737 " shutdown"); | 734 " shutdown"); |
| 738 } | 735 } |
| 739 | 736 |
| 740 Channel::Channel(int32_t channelId, | 737 Channel::Channel(int32_t channelId, uint32_t instanceId, const Config& config) |
| 741 uint32_t instanceId, | |
| 742 RtcEventLog* const event_log, | |
| 743 const Config& config) | |
| 744 : _instanceId(instanceId), | 738 : _instanceId(instanceId), |
| 745 _channelId(channelId), | 739 _channelId(channelId), |
| 746 event_log_(event_log), | 740 event_log_(), |
| 747 rtp_header_parser_(RtpHeaderParser::Create()), | 741 rtp_header_parser_(RtpHeaderParser::Create()), |
| 748 rtp_payload_registry_( | 742 rtp_payload_registry_( |
| 749 new RTPPayloadRegistry(RTPPayloadStrategy::CreateStrategy(true))), | 743 new RTPPayloadRegistry(RTPPayloadStrategy::CreateStrategy(true))), |
| 750 rtp_receive_statistics_( | 744 rtp_receive_statistics_( |
| 751 ReceiveStatistics::Create(Clock::GetRealTimeClock())), | 745 ReceiveStatistics::Create(Clock::GetRealTimeClock())), |
| 752 rtp_receiver_( | 746 rtp_receiver_( |
| 753 RtpReceiver::CreateAudioReceiver(Clock::GetRealTimeClock(), | 747 RtpReceiver::CreateAudioReceiver(Clock::GetRealTimeClock(), |
| 754 this, | 748 this, |
| 755 this, | 749 this, |
| 756 this, | 750 this, |
| (...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 845 configuration.outgoing_transport = this; | 839 configuration.outgoing_transport = this; |
| 846 configuration.audio_messages = this; | 840 configuration.audio_messages = this; |
| 847 configuration.receive_statistics = rtp_receive_statistics_.get(); | 841 configuration.receive_statistics = rtp_receive_statistics_.get(); |
| 848 configuration.bandwidth_callback = rtcp_observer_.get(); | 842 configuration.bandwidth_callback = rtcp_observer_.get(); |
| 849 if (pacing_enabled_) { | 843 if (pacing_enabled_) { |
| 850 configuration.paced_sender = rtp_packet_sender_proxy_.get(); | 844 configuration.paced_sender = rtp_packet_sender_proxy_.get(); |
| 851 configuration.transport_sequence_number_allocator = | 845 configuration.transport_sequence_number_allocator = |
| 852 seq_num_allocator_proxy_.get(); | 846 seq_num_allocator_proxy_.get(); |
| 853 configuration.transport_feedback_callback = feedback_observer_proxy_.get(); | 847 configuration.transport_feedback_callback = feedback_observer_proxy_.get(); |
| 854 } | 848 } |
| 855 configuration.event_log = event_log; | 849 configuration.event_log = &event_log_; |
| 856 | 850 |
| 857 _rtpRtcpModule.reset(RtpRtcp::CreateRtpRtcp(configuration)); | 851 _rtpRtcpModule.reset(RtpRtcp::CreateRtpRtcp(configuration)); |
| 858 | 852 |
| 859 statistics_proxy_.reset(new StatisticsProxy(_rtpRtcpModule->SSRC())); | 853 statistics_proxy_.reset(new StatisticsProxy(_rtpRtcpModule->SSRC())); |
| 860 rtp_receive_statistics_->RegisterRtcpStatisticsCallback( | 854 rtp_receive_statistics_->RegisterRtcpStatisticsCallback( |
| 861 statistics_proxy_.get()); | 855 statistics_proxy_.get()); |
| 862 | 856 |
| 863 Config audioproc_config; | 857 Config audioproc_config; |
| 864 audioproc_config.Set<ExperimentalAgc>(new ExperimentalAgc(false)); | 858 audioproc_config.Set<ExperimentalAgc>(new ExperimentalAgc(false)); |
| 865 rx_audioproc_.reset(AudioProcessing::Create(audioproc_config)); | 859 rx_audioproc_.reset(AudioProcessing::Create(audioproc_config)); |
| (...skipping 2784 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3650 int64_t min_rtt = 0; | 3644 int64_t min_rtt = 0; |
| 3651 if (_rtpRtcpModule->RTT(remoteSSRC, &rtt, &avg_rtt, &min_rtt, &max_rtt) != | 3645 if (_rtpRtcpModule->RTT(remoteSSRC, &rtt, &avg_rtt, &min_rtt, &max_rtt) != |
| 3652 0) { | 3646 0) { |
| 3653 return 0; | 3647 return 0; |
| 3654 } | 3648 } |
| 3655 return rtt; | 3649 return rtt; |
| 3656 } | 3650 } |
| 3657 | 3651 |
| 3658 } // namespace voe | 3652 } // namespace voe |
| 3659 } // namespace webrtc | 3653 } // namespace webrtc |
| OLD | NEW |