| 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 10 matching lines...) Expand all Loading... |
| 21 | 21 |
| 22 DecoderDatabase::DecoderDatabase( | 22 DecoderDatabase::DecoderDatabase( |
| 23 const rtc::scoped_refptr<AudioDecoderFactory>& decoder_factory) | 23 const rtc::scoped_refptr<AudioDecoderFactory>& decoder_factory) |
| 24 : active_decoder_type_(-1), | 24 : active_decoder_type_(-1), |
| 25 active_cng_decoder_type_(-1), | 25 active_cng_decoder_type_(-1), |
| 26 decoder_factory_(decoder_factory) {} | 26 decoder_factory_(decoder_factory) {} |
| 27 | 27 |
| 28 DecoderDatabase::~DecoderDatabase() = default; | 28 DecoderDatabase::~DecoderDatabase() = default; |
| 29 | 29 |
| 30 DecoderDatabase::DecoderInfo::DecoderInfo(NetEqDecoder ct, | 30 DecoderDatabase::DecoderInfo::DecoderInfo(NetEqDecoder ct, |
| 31 const std::string& nm) |
| 32 : codec_type(ct), |
| 33 name(nm), |
| 34 audio_format_(acm2::RentACodec::NetEqDecoderToSdpAudioFormat(ct)), |
| 35 cng_decoder_(CngDecoder::Create(ct)) {} |
| 36 |
| 37 DecoderDatabase::DecoderInfo::DecoderInfo(NetEqDecoder ct, |
| 31 const std::string& nm, | 38 const std::string& nm, |
| 32 int fs, | 39 int sample_rate_hz, |
| 33 AudioDecoder* ext_dec) | 40 AudioDecoder* ext_dec) |
| 34 : codec_type(ct), | 41 : codec_type(ct), |
| 35 name(nm), | 42 name(nm), |
| 36 fs_hz(fs), | 43 audio_format_(acm2::RentACodec::NetEqDecoderToSdpAudioFormat(ct)), |
| 37 external_decoder(ext_dec), | 44 external_decoder({sample_rate_hz, ext_dec}) { |
| 38 audio_format_(acm2::RentACodec::NetEqDecoderToSdpAudioFormat(ct)) {} | 45 RTC_CHECK(ext_dec); |
| 46 } |
| 39 | 47 |
| 40 DecoderDatabase::DecoderInfo::DecoderInfo(DecoderInfo&&) = default; | 48 DecoderDatabase::DecoderInfo::DecoderInfo(DecoderInfo&&) = default; |
| 41 DecoderDatabase::DecoderInfo::~DecoderInfo() = default; | 49 DecoderDatabase::DecoderInfo::~DecoderInfo() = default; |
| 42 | 50 |
| 43 AudioDecoder* DecoderDatabase::DecoderInfo::GetDecoder( | 51 AudioDecoder* DecoderDatabase::DecoderInfo::GetDecoder( |
| 44 AudioDecoderFactory* factory) { | 52 AudioDecoderFactory* factory) { |
| 45 if (external_decoder) { | 53 if (external_decoder) { |
| 46 RTC_DCHECK(!decoder_); | 54 RTC_DCHECK(!decoder_); |
| 47 return external_decoder; | 55 RTC_DCHECK(external_decoder->decoder); |
| 56 return external_decoder->decoder; |
| 48 } | 57 } |
| 49 RTC_DCHECK(audio_format_); | 58 RTC_DCHECK(audio_format_); |
| 50 if (!decoder_) { | 59 if (!decoder_) { |
| 51 decoder_ = factory->MakeAudioDecoder(*audio_format_); | 60 decoder_ = factory->MakeAudioDecoder(*audio_format_); |
| 52 } | 61 } |
| 53 RTC_DCHECK(decoder_) << "Failed to create: " << *audio_format_; | 62 RTC_DCHECK(decoder_) << "Failed to create: " << *audio_format_; |
| 54 return decoder_.get(); | 63 return decoder_.get(); |
| 55 } | 64 } |
| 56 | 65 |
| 66 rtc::Optional<DecoderDatabase::DecoderInfo::CngDecoder> |
| 67 DecoderDatabase::DecoderInfo::CngDecoder::Create(NetEqDecoder ct) { |
| 68 const auto cng = [](int sample_rate_hz) { |
| 69 return rtc::Optional<DecoderDatabase::DecoderInfo::CngDecoder>( |
| 70 {sample_rate_hz}); |
| 71 }; |
| 72 switch (ct) { |
| 73 case NetEqDecoder::kDecoderCNGnb: |
| 74 return cng(8000); |
| 75 case NetEqDecoder::kDecoderCNGwb: |
| 76 return cng(16000); |
| 77 case NetEqDecoder::kDecoderCNGswb32kHz: |
| 78 return cng(32000); |
| 79 case NetEqDecoder::kDecoderCNGswb48kHz: |
| 80 return cng(48000); |
| 81 default: |
| 82 return rtc::Optional<DecoderDatabase::DecoderInfo::CngDecoder>(); |
| 83 } |
| 84 } |
| 85 |
| 57 bool DecoderDatabase::Empty() const { return decoders_.empty(); } | 86 bool DecoderDatabase::Empty() const { return decoders_.empty(); } |
| 58 | 87 |
| 59 int DecoderDatabase::Size() const { return static_cast<int>(decoders_.size()); } | 88 int DecoderDatabase::Size() const { return static_cast<int>(decoders_.size()); } |
| 60 | 89 |
| 61 void DecoderDatabase::Reset() { | 90 void DecoderDatabase::Reset() { |
| 62 decoders_.clear(); | 91 decoders_.clear(); |
| 63 active_decoder_type_ = -1; | 92 active_decoder_type_ = -1; |
| 64 active_cng_decoder_type_ = -1; | 93 active_cng_decoder_type_ = -1; |
| 65 } | 94 } |
| 66 | 95 |
| 67 int DecoderDatabase::RegisterPayload(uint8_t rtp_payload_type, | 96 int DecoderDatabase::RegisterPayload(uint8_t rtp_payload_type, |
| 68 NetEqDecoder codec_type, | 97 NetEqDecoder codec_type, |
| 69 const std::string& name) { | 98 const std::string& name) { |
| 70 if (rtp_payload_type > 0x7F) { | 99 if (rtp_payload_type > 0x7F) { |
| 71 return kInvalidRtpPayloadType; | 100 return kInvalidRtpPayloadType; |
| 72 } | 101 } |
| 73 if (!CodecSupported(codec_type)) { | 102 if (!CodecSupported(codec_type)) { |
| 74 return kCodecNotSupported; | 103 return kCodecNotSupported; |
| 75 } | 104 } |
| 76 const int fs_hz = CodecSampleRateHz(codec_type); | 105 DecoderInfo info(codec_type, name); |
| 77 DecoderInfo info(codec_type, name, fs_hz, nullptr); | |
| 78 auto ret = | 106 auto ret = |
| 79 decoders_.insert(std::make_pair(rtp_payload_type, std::move(info))); | 107 decoders_.insert(std::make_pair(rtp_payload_type, std::move(info))); |
| 80 if (ret.second == false) { | 108 if (ret.second == false) { |
| 81 // Database already contains a decoder with type |rtp_payload_type|. | 109 // Database already contains a decoder with type |rtp_payload_type|. |
| 82 return kDecoderExists; | 110 return kDecoderExists; |
| 83 } | 111 } |
| 84 return kOK; | 112 return kOK; |
| 85 } | 113 } |
| 86 | 114 |
| 87 int DecoderDatabase::InsertExternal(uint8_t rtp_payload_type, | 115 int DecoderDatabase::InsertExternal(uint8_t rtp_payload_type, |
| (...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 240 } | 268 } |
| 241 if (active_cng_decoder_type_ >= 0 && | 269 if (active_cng_decoder_type_ >= 0 && |
| 242 active_cng_decoder_type_ != rtp_payload_type) { | 270 active_cng_decoder_type_ != rtp_payload_type) { |
| 243 // Moving from one active CNG decoder to another. Delete the first one. | 271 // Moving from one active CNG decoder to another. Delete the first one. |
| 244 DecoderMap::iterator it = decoders_.find(active_cng_decoder_type_); | 272 DecoderMap::iterator it = decoders_.find(active_cng_decoder_type_); |
| 245 if (it == decoders_.end()) { | 273 if (it == decoders_.end()) { |
| 246 // Decoder not found. This should not be possible. | 274 // Decoder not found. This should not be possible. |
| 247 assert(false); | 275 assert(false); |
| 248 return kDecoderNotFound; | 276 return kDecoderNotFound; |
| 249 } | 277 } |
| 250 // The CNG decoder should never be provided externally. | |
| 251 RTC_CHECK(!it->second.external_decoder); | |
| 252 active_cng_decoder_.reset(); | 278 active_cng_decoder_.reset(); |
| 253 } | 279 } |
| 254 active_cng_decoder_type_ = rtp_payload_type; | 280 active_cng_decoder_type_ = rtp_payload_type; |
| 255 return kOK; | 281 return kOK; |
| 256 } | 282 } |
| 257 | 283 |
| 258 ComfortNoiseDecoder* DecoderDatabase::GetActiveCngDecoder() { | 284 ComfortNoiseDecoder* DecoderDatabase::GetActiveCngDecoder() { |
| 259 if (active_cng_decoder_type_ < 0) { | 285 if (active_cng_decoder_type_ < 0) { |
| 260 // No active CNG decoder. | 286 // No active CNG decoder. |
| 261 return NULL; | 287 return NULL; |
| (...skipping 12 matching lines...) Expand all Loading... |
| 274 LOG(LS_WARNING) << "CheckPayloadTypes: unknown RTP payload type " | 300 LOG(LS_WARNING) << "CheckPayloadTypes: unknown RTP payload type " |
| 275 << static_cast<int>((*it)->header.payloadType); | 301 << static_cast<int>((*it)->header.payloadType); |
| 276 return kDecoderNotFound; | 302 return kDecoderNotFound; |
| 277 } | 303 } |
| 278 } | 304 } |
| 279 return kOK; | 305 return kOK; |
| 280 } | 306 } |
| 281 | 307 |
| 282 | 308 |
| 283 } // namespace webrtc | 309 } // namespace webrtc |
| OLD | NEW |