Voe::Channel: Turned GetPlayoutFrequency into GetRtpTimestampRateHz.

This gets rid of a bit of codec-specific code in VoE.

BUG=webrtc:5805

Review-Url: https://codereview.webrtc.org/2355483003
Cr-Commit-Position: refs/heads/master@{#14614}
This commit is contained in:
ossu
2016-10-12 11:04:10 -07:00
committed by Commit bot
parent 872f614111
commit e280cdeb74
6 changed files with 42 additions and 22 deletions

View File

@ -98,6 +98,8 @@ int AcmReceiver::InsertPacket(const WebRtcRTPHeader& rtp_header,
} }
} else { } else {
last_audio_decoder_ = ci; last_audio_decoder_ = ci;
last_audio_format_ = neteq_->GetDecoderFormat(ci->pltype);
RTC_DCHECK(last_audio_format_);
last_packet_sample_rate_hz_ = rtc::Optional<int>(ci->plfreq); last_packet_sample_rate_hz_ = rtc::Optional<int>(ci->plfreq);
} }
@ -263,6 +265,7 @@ void AcmReceiver::RemoveAllCodecs() {
rtc::CritScope lock(&crit_sect_); rtc::CritScope lock(&crit_sect_);
neteq_->RemoveAllPayloadTypes(); neteq_->RemoveAllPayloadTypes();
last_audio_decoder_ = rtc::Optional<CodecInst>(); last_audio_decoder_ = rtc::Optional<CodecInst>();
last_audio_format_ = rtc::Optional<SdpAudioFormat>();
last_packet_sample_rate_hz_ = rtc::Optional<int>(); last_packet_sample_rate_hz_ = rtc::Optional<int>();
} }
@ -275,6 +278,7 @@ int AcmReceiver::RemoveCodec(uint8_t payload_type) {
} }
if (last_audio_decoder_ && payload_type == last_audio_decoder_->pltype) { if (last_audio_decoder_ && payload_type == last_audio_decoder_->pltype) {
last_audio_decoder_ = rtc::Optional<CodecInst>(); last_audio_decoder_ = rtc::Optional<CodecInst>();
last_audio_format_ = rtc::Optional<SdpAudioFormat>();
last_packet_sample_rate_hz_ = rtc::Optional<int>(); last_packet_sample_rate_hz_ = rtc::Optional<int>();
} }
return 0; return 0;
@ -297,6 +301,11 @@ int AcmReceiver::LastAudioCodec(CodecInst* codec) const {
return 0; return 0;
} }
rtc::Optional<SdpAudioFormat> AcmReceiver::LastAudioFormat() const {
rtc::CritScope lock(&crit_sect_);
return last_audio_format_;
}
void AcmReceiver::GetNetworkStatistics(NetworkStatistics* acm_stat) { void AcmReceiver::GetNetworkStatistics(NetworkStatistics* acm_stat) {
NetEqNetworkStatistics neteq_stat; NetEqNetworkStatistics neteq_stat;
// NetEq function always returns zero, so we don't check the return value. // NetEq function always returns zero, so we don't check the return value.

View File

@ -209,6 +209,8 @@ class AcmReceiver {
// //
int LastAudioCodec(CodecInst* codec) const; int LastAudioCodec(CodecInst* codec) const;
rtc::Optional<SdpAudioFormat> LastAudioFormat() const;
// //
// Get a decoder given its registered payload-type. // Get a decoder given its registered payload-type.
// //
@ -273,6 +275,7 @@ class AcmReceiver {
rtc::CriticalSection crit_sect_; rtc::CriticalSection crit_sect_;
rtc::Optional<CodecInst> last_audio_decoder_ GUARDED_BY(crit_sect_); rtc::Optional<CodecInst> last_audio_decoder_ GUARDED_BY(crit_sect_);
rtc::Optional<SdpAudioFormat> last_audio_format_ GUARDED_BY(crit_sect_);
ACMResampler resampler_ GUARDED_BY(crit_sect_); ACMResampler resampler_ GUARDED_BY(crit_sect_);
std::unique_ptr<int16_t[]> last_audio_buffer_ GUARDED_BY(crit_sect_); std::unique_ptr<int16_t[]> last_audio_buffer_ GUARDED_BY(crit_sect_);
CallStatistics call_stats_ GUARDED_BY(crit_sect_); CallStatistics call_stats_ GUARDED_BY(crit_sect_);

View File

@ -138,6 +138,8 @@ class AudioCodingModuleImpl final : public AudioCodingModule {
// Get current received codec. // Get current received codec.
int ReceiveCodec(CodecInst* current_codec) const override; int ReceiveCodec(CodecInst* current_codec) const override;
rtc::Optional<SdpAudioFormat> ReceiveFormat() const override;
// Incoming packet from network parsed and ready for decode. // Incoming packet from network parsed and ready for decode.
int IncomingPacket(const uint8_t* incoming_payload, int IncomingPacket(const uint8_t* incoming_payload,
const size_t payload_length, const size_t payload_length,
@ -1087,6 +1089,11 @@ int AudioCodingModuleImpl::ReceiveCodec(CodecInst* current_codec) const {
return receiver_.LastAudioCodec(current_codec); return receiver_.LastAudioCodec(current_codec);
} }
rtc::Optional<SdpAudioFormat> AudioCodingModuleImpl::ReceiveFormat() const {
rtc::CritScope lock(&acm_crit_sect_);
return receiver_.LastAudioFormat();
}
// Incoming packet from network parsed and ready for decode. // Incoming packet from network parsed and ready for decode.
int AudioCodingModuleImpl::IncomingPacket(const uint8_t* incoming_payload, int AudioCodingModuleImpl::IncomingPacket(const uint8_t* incoming_payload,
const size_t payload_length, const size_t payload_length,

View File

@ -552,6 +552,17 @@ class AudioCodingModule {
// //
virtual int32_t ReceiveCodec(CodecInst* curr_receive_codec) const = 0; virtual int32_t ReceiveCodec(CodecInst* curr_receive_codec) const = 0;
///////////////////////////////////////////////////////////////////////////
// rtc::Optional<SdpAudioFormat> ReceiveFormat()
// Get the format associated with last received payload.
//
// Return value:
// An SdpAudioFormat describing the format associated with the last
// received payload.
// An empty Optional if no payload has yet been received.
//
virtual rtc::Optional<SdpAudioFormat> ReceiveFormat() const = 0;
/////////////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////////////////
// int32_t IncomingPacket() // int32_t IncomingPacket()
// Call this function to insert a parsed RTP packet into ACM. // Call this function to insert a parsed RTP packet into ACM.

View File

@ -718,7 +718,7 @@ MixerParticipant::AudioFrameInfo Channel::GetAudioFrameWithMuted(
rtp_ts_wraparound_handler_->Unwrap(audioFrame->timestamp_); rtp_ts_wraparound_handler_->Unwrap(audioFrame->timestamp_);
audioFrame->elapsed_time_ms_ = audioFrame->elapsed_time_ms_ =
(unwrap_timestamp - capture_start_rtp_time_stamp_) / (unwrap_timestamp - capture_start_rtp_time_stamp_) /
(GetPlayoutFrequency() / 1000); (GetRtpTimestampRateHz() / 1000);
{ {
rtc::CritScope lock(&ts_stats_lock_); rtc::CritScope lock(&ts_stats_lock_);
@ -3162,7 +3162,7 @@ void Channel::UpdatePlayoutTimestamp(bool rtcp) {
uint32_t playout_timestamp = *jitter_buffer_playout_timestamp_; uint32_t playout_timestamp = *jitter_buffer_playout_timestamp_;
// Remove the playout delay. // Remove the playout delay.
playout_timestamp -= (delay_ms * (GetPlayoutFrequency() / 1000)); playout_timestamp -= (delay_ms * (GetRtpTimestampRateHz() / 1000));
WEBRTC_TRACE(kTraceStream, kTraceVoice, VoEId(_instanceId, _channelId), WEBRTC_TRACE(kTraceStream, kTraceVoice, VoEId(_instanceId, _channelId),
"Channel::UpdatePlayoutTimestamp() => playoutTimestamp = %lu", "Channel::UpdatePlayoutTimestamp() => playoutTimestamp = %lu",
@ -3222,25 +3222,15 @@ int Channel::SetSendRtpHeaderExtension(bool enable,
return error; return error;
} }
int32_t Channel::GetPlayoutFrequency() const { int Channel::GetRtpTimestampRateHz() const {
int32_t playout_frequency = audio_coding_->PlayoutFrequency(); const auto format = audio_coding_->ReceiveFormat();
CodecInst current_recive_codec; // Default to the playout frequency if we've not gotten any packets yet.
if (audio_coding_->ReceiveCodec(&current_recive_codec) == 0) { // TODO(ossu): Zero clockrate can only happen if we've added an external
if (STR_CASE_CMP("G722", current_recive_codec.plname) == 0) { // decoder for a format we don't support internally. Remove once that way of
// Even though the actual sampling rate for G.722 audio is // adding decoders is gone!
// 16,000 Hz, the RTP clock rate for the G722 payload format is return (format && format->clockrate_hz != 0)
// 8,000 Hz because that value was erroneously assigned in ? format->clockrate_hz
// RFC 1890 and must remain unchanged for backward compatibility. : audio_coding_->PlayoutFrequency();
playout_frequency = 8000;
} else if (STR_CASE_CMP("opus", current_recive_codec.plname) == 0) {
// We are resampling Opus internally to 32,000 Hz until all our
// DSP routines can operate at 48,000 Hz, but the RTP clock
// rate for the Opus payload format is standardized to 48,000 Hz,
// because that is the maximum supported decoding sampling rate.
playout_frequency = 48000;
}
}
return playout_frequency;
} }
int64_t Channel::GetRTT(bool allow_associate_channel) const { int64_t Channel::GetRTT(bool allow_associate_channel) const {

View File

@ -446,7 +446,7 @@ class Channel
RTPExtensionType type, RTPExtensionType type,
unsigned char id); unsigned char id);
int32_t GetPlayoutFrequency() const; int GetRtpTimestampRateHz() const;
int64_t GetRTT(bool allow_associate_channel) const; int64_t GetRTT(bool allow_associate_channel) const;
rtc::CriticalSection _fileCritSect; rtc::CriticalSection _fileCritSect;