AcmReceiver: Look up last decoder in NetEq's table of decoders
AcmReceiver::decoders_ is now one step closer to being unused.
(This is a re-land of https://codereview.webrtc.org/2339953002.)
BUG=webrtc:5801
Review-Url: https://codereview.webrtc.org/2354453003
Cr-Commit-Position: refs/heads/master@{#14303}
diff --git a/webrtc/modules/audio_coding/acm2/acm_receiver.cc b/webrtc/modules/audio_coding/acm2/acm_receiver.cc
index 417a346..641818d 100644
--- a/webrtc/modules/audio_coding/acm2/acm_receiver.cc
+++ b/webrtc/modules/audio_coding/acm2/acm_receiver.cc
@@ -32,23 +32,8 @@
namespace acm2 {
-namespace {
-
-// Is the given codec a CNG codec?
-// TODO(kwiberg): Move to RentACodec.
-bool IsCng(int codec_id) {
- auto i = RentACodec::CodecIdFromIndex(codec_id);
- return (i && (*i == RentACodec::CodecId::kCNNB ||
- *i == RentACodec::CodecId::kCNWB ||
- *i == RentACodec::CodecId::kCNSWB ||
- *i == RentACodec::CodecId::kCNFB));
-}
-
-} // namespace
-
AcmReceiver::AcmReceiver(const AudioCodingModule::Config& config)
- : last_audio_decoder_(nullptr),
- last_audio_buffer_(new int16_t[AudioFrame::kMaxDataSizeSamples]),
+ : last_audio_buffer_(new int16_t[AudioFrame::kMaxDataSizeSamples]),
neteq_(NetEq::Create(config.neteq_config, config.decoder_factory)),
clock_(config.clock),
resampled_last_output_frame_(true) {
@@ -95,29 +80,25 @@
{
rtc::CritScope lock(&crit_sect_);
- const Decoder* decoder = RtpHeaderToDecoder(*header, incoming_payload[0]);
- if (!decoder) {
+ const rtc::Optional<CodecInst> ci =
+ RtpHeaderToDecoder(*header, incoming_payload[0]);
+ if (!ci) {
LOG_F(LS_ERROR) << "Payload-type "
<< static_cast<int>(header->payloadType)
<< " is not registered.";
return -1;
}
- const int sample_rate_hz = [&decoder] {
- const auto ci = RentACodec::CodecIdFromIndex(decoder->acm_codec_id);
- return ci ? RentACodec::CodecInstById(*ci)->plfreq : -1;
- }();
- receive_timestamp = NowInTimestamp(sample_rate_hz);
+ receive_timestamp = NowInTimestamp(ci->plfreq);
- // If this is a CNG while the audio codec is not mono, skip pushing in
- // packets into NetEq.
- if (IsCng(decoder->acm_codec_id) && last_audio_decoder_ &&
- last_audio_decoder_->channels > 1)
+ if (STR_CASE_CMP(ci->plname, "cn") == 0) {
+ if (last_audio_decoder_ && last_audio_decoder_->channels > 1) {
+ // This is a CNG and the audio codec is not mono, so skip pushing in
+ // packets into NetEq.
return 0;
- if (!IsCng(decoder->acm_codec_id) &&
- decoder->acm_codec_id !=
- *RentACodec::CodecIndexFromId(RentACodec::CodecId::kAVT)) {
- last_audio_decoder_ = decoder;
- last_packet_sample_rate_hz_ = rtc::Optional<int>(decoder->sample_rate_hz);
+ }
+ } else {
+ last_audio_decoder_ = ci;
+ last_packet_sample_rate_hz_ = rtc::Optional<int>(ci->plfreq);
}
} // |crit_sect_| is released.
@@ -283,7 +264,7 @@
}
// No codec is registered, invalidate last audio decoder.
- last_audio_decoder_ = nullptr;
+ last_audio_decoder_ = rtc::Optional<CodecInst>();
last_packet_sample_rate_hz_ = rtc::Optional<int>();
return ret_val;
}
@@ -298,8 +279,8 @@
LOG(LERROR) << "AcmReceiver::RemoveCodec" << static_cast<int>(payload_type);
return -1;
}
- if (last_audio_decoder_ == &it->second) {
- last_audio_decoder_ = nullptr;
+ if (last_audio_decoder_ && payload_type == last_audio_decoder_->pltype) {
+ last_audio_decoder_ = rtc::Optional<CodecInst>();
last_packet_sample_rate_hz_ = rtc::Optional<int>();
}
decoders_.erase(it);
@@ -319,11 +300,7 @@
if (!last_audio_decoder_) {
return -1;
}
- *codec = *RentACodec::CodecInstById(
- *RentACodec::CodecIdFromIndex(last_audio_decoder_->acm_codec_id));
- codec->pltype = last_audio_decoder_->payload_type;
- codec->channels = last_audio_decoder_->channels;
- codec->plfreq = last_audio_decoder_->sample_rate_hz;
+ *codec = *last_audio_decoder_;
return 0;
}
@@ -387,20 +364,17 @@
// TODO(turajs): Should NetEq Buffer be flushed?
}
-const AcmReceiver::Decoder* AcmReceiver::RtpHeaderToDecoder(
+const rtc::Optional<CodecInst> AcmReceiver::RtpHeaderToDecoder(
const RTPHeader& rtp_header,
- uint8_t payload_type) const {
- auto it = decoders_.find(rtp_header.payloadType);
- const auto red_index =
- RentACodec::CodecIndexFromId(RentACodec::CodecId::kRED);
- if (red_index && // This ensures that RED is defined in WebRTC.
- it != decoders_.end() && it->second.acm_codec_id == *red_index) {
- // This is a RED packet, get the payload of the audio codec.
- it = decoders_.find(payload_type & 0x7F);
+ uint8_t first_payload_byte) const {
+ const rtc::Optional<CodecInst> ci =
+ neteq_->GetDecoder(rtp_header.payloadType);
+ if (ci && STR_CASE_CMP(ci->plname, "red") == 0) {
+ // This is a RED packet. Get the payload of the audio codec.
+ return neteq_->GetDecoder(first_payload_byte & 0x7f);
+ } else {
+ return ci;
}
-
- // Check if the payload is registered.
- return it != decoders_.end() ? &it->second : nullptr;
}
uint32_t AcmReceiver::NowInTimestamp(int decoder_sampling_rate) const {