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 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
117 | 117 |
118 // Get current receive frequency. | 118 // Get current receive frequency. |
119 int ReceiveFrequency() const override; | 119 int ReceiveFrequency() const override; |
120 | 120 |
121 // Get current playout frequency. | 121 // Get current playout frequency. |
122 int PlayoutFrequency() const override; | 122 int PlayoutFrequency() const override; |
123 | 123 |
124 bool RegisterReceiveCodec(int rtp_payload_type, | 124 bool RegisterReceiveCodec(int rtp_payload_type, |
125 const SdpAudioFormat& audio_format) override; | 125 const SdpAudioFormat& audio_format) override; |
126 | 126 |
127 int RegisterReceiveCodec(const CodecInst& receive_codec) override; | |
128 int RegisterReceiveCodec( | |
129 const CodecInst& receive_codec, | |
130 rtc::FunctionView<std::unique_ptr<AudioDecoder>()> isac_factory) override; | |
131 | |
132 int RegisterExternalReceiveCodec(int rtp_payload_type, | |
133 AudioDecoder* external_decoder, | |
134 int sample_rate_hz, | |
135 int num_channels, | |
136 const std::string& name) override; | |
137 | |
138 // Get current received codec. | 127 // Get current received codec. |
139 int ReceiveCodec(CodecInst* current_codec) const override; | 128 int ReceiveCodec(CodecInst* current_codec) const override; |
140 | 129 |
141 rtc::Optional<SdpAudioFormat> ReceiveFormat() const override; | 130 rtc::Optional<SdpAudioFormat> ReceiveFormat() const override; |
142 | 131 |
143 // Incoming packet from network parsed and ready for decode. | 132 // Incoming packet from network parsed and ready for decode. |
144 int IncomingPacket(const uint8_t* incoming_payload, | 133 int IncomingPacket(const uint8_t* incoming_payload, |
145 const size_t payload_length, | 134 const size_t payload_length, |
146 const WebRtcRTPHeader& rtp_info) override; | 135 const WebRtcRTPHeader& rtp_info) override; |
147 | 136 |
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
220 // Logs the new value if it is different from the last logged value, or if | 209 // Logs the new value if it is different from the last logged value, or if |
221 // this is the first call. | 210 // this is the first call. |
222 void MaybeLog(int value); | 211 void MaybeLog(int value); |
223 | 212 |
224 private: | 213 private: |
225 int last_value_ = 0; | 214 int last_value_ = 0; |
226 int first_time_ = true; | 215 int first_time_ = true; |
227 const std::string histogram_name_; | 216 const std::string histogram_name_; |
228 }; | 217 }; |
229 | 218 |
230 int RegisterReceiveCodecUnlocked( | |
231 const CodecInst& codec, | |
232 rtc::FunctionView<std::unique_ptr<AudioDecoder>()> isac_factory) | |
233 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); | |
234 | |
235 int Add10MsDataInternal(const AudioFrame& audio_frame, InputData* input_data) | 219 int Add10MsDataInternal(const AudioFrame& audio_frame, InputData* input_data) |
236 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); | 220 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); |
237 int Encode(const InputData& input_data) | 221 int Encode(const InputData& input_data) |
238 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); | 222 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); |
239 | 223 |
240 int InitializeReceiverSafe() EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); | 224 int InitializeReceiverSafe() EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); |
241 | 225 |
242 bool HaveValidEncoder(const char* caller_name) const | 226 bool HaveValidEncoder(const char* caller_name) const |
243 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); | 227 EXCLUSIVE_LOCKS_REQUIRED(acm_crit_sect_); |
244 | 228 |
(...skipping 755 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1000 | 984 |
1001 if (!acm2::RentACodec::IsPayloadTypeValid(rtp_payload_type)) { | 985 if (!acm2::RentACodec::IsPayloadTypeValid(rtp_payload_type)) { |
1002 LOG_F(LS_ERROR) << "Invalid payload-type " << rtp_payload_type | 986 LOG_F(LS_ERROR) << "Invalid payload-type " << rtp_payload_type |
1003 << " for decoder."; | 987 << " for decoder."; |
1004 return false; | 988 return false; |
1005 } | 989 } |
1006 | 990 |
1007 return receiver_.AddCodec(rtp_payload_type, audio_format); | 991 return receiver_.AddCodec(rtp_payload_type, audio_format); |
1008 } | 992 } |
1009 | 993 |
1010 int AudioCodingModuleImpl::RegisterReceiveCodec(const CodecInst& codec) { | |
1011 rtc::CritScope lock(&acm_crit_sect_); | |
1012 auto* ef = encoder_factory_.get(); | |
1013 return RegisterReceiveCodecUnlocked( | |
1014 codec, [&] { return ef->rent_a_codec.RentIsacDecoder(codec.plfreq); }); | |
1015 } | |
1016 | |
1017 int AudioCodingModuleImpl::RegisterReceiveCodec( | |
1018 const CodecInst& codec, | |
1019 rtc::FunctionView<std::unique_ptr<AudioDecoder>()> isac_factory) { | |
1020 rtc::CritScope lock(&acm_crit_sect_); | |
1021 return RegisterReceiveCodecUnlocked(codec, isac_factory); | |
1022 } | |
1023 | |
1024 int AudioCodingModuleImpl::RegisterReceiveCodecUnlocked( | |
1025 const CodecInst& codec, | |
1026 rtc::FunctionView<std::unique_ptr<AudioDecoder>()> isac_factory) { | |
1027 RTC_DCHECK(receiver_initialized_); | |
1028 if (codec.channels > 2) { | |
1029 LOG_F(LS_ERROR) << "Unsupported number of channels: " << codec.channels; | |
1030 return -1; | |
1031 } | |
1032 | |
1033 auto codec_id = acm2::RentACodec::CodecIdByParams(codec.plname, codec.plfreq, | |
1034 codec.channels); | |
1035 if (!codec_id) { | |
1036 LOG_F(LS_ERROR) << "Wrong codec params to be registered as receive codec"; | |
1037 return -1; | |
1038 } | |
1039 auto codec_index = acm2::RentACodec::CodecIndexFromId(*codec_id); | |
1040 RTC_CHECK(codec_index) << "Invalid codec ID: " << static_cast<int>(*codec_id); | |
1041 | |
1042 // Check if the payload-type is valid. | |
1043 if (!acm2::RentACodec::IsPayloadTypeValid(codec.pltype)) { | |
1044 LOG_F(LS_ERROR) << "Invalid payload type " << codec.pltype << " for " | |
1045 << codec.plname; | |
1046 return -1; | |
1047 } | |
1048 | |
1049 AudioDecoder* isac_decoder = nullptr; | |
1050 if (STR_CASE_CMP(codec.plname, "isac") == 0) { | |
1051 std::unique_ptr<AudioDecoder>& saved_isac_decoder = | |
1052 codec.plfreq == 16000 ? isac_decoder_16k_ : isac_decoder_32k_; | |
1053 if (!saved_isac_decoder) { | |
1054 saved_isac_decoder = isac_factory(); | |
1055 } | |
1056 isac_decoder = saved_isac_decoder.get(); | |
1057 } | |
1058 return receiver_.AddCodec(*codec_index, codec.pltype, codec.channels, | |
1059 codec.plfreq, isac_decoder, codec.plname); | |
1060 } | |
1061 | |
1062 int AudioCodingModuleImpl::RegisterExternalReceiveCodec( | |
1063 int rtp_payload_type, | |
1064 AudioDecoder* external_decoder, | |
1065 int sample_rate_hz, | |
1066 int num_channels, | |
1067 const std::string& name) { | |
1068 rtc::CritScope lock(&acm_crit_sect_); | |
1069 RTC_DCHECK(receiver_initialized_); | |
1070 if (num_channels > 2 || num_channels < 0) { | |
1071 LOG_F(LS_ERROR) << "Unsupported number of channels: " << num_channels; | |
1072 return -1; | |
1073 } | |
1074 | |
1075 // Check if the payload-type is valid. | |
1076 if (!acm2::RentACodec::IsPayloadTypeValid(rtp_payload_type)) { | |
1077 LOG_F(LS_ERROR) << "Invalid payload-type " << rtp_payload_type | |
1078 << " for external decoder."; | |
1079 return -1; | |
1080 } | |
1081 | |
1082 return receiver_.AddCodec(-1 /* external */, rtp_payload_type, num_channels, | |
1083 sample_rate_hz, external_decoder, name); | |
1084 } | |
1085 | |
1086 // Get current received codec. | 994 // Get current received codec. |
1087 int AudioCodingModuleImpl::ReceiveCodec(CodecInst* current_codec) const { | 995 int AudioCodingModuleImpl::ReceiveCodec(CodecInst* current_codec) const { |
1088 rtc::CritScope lock(&acm_crit_sect_); | 996 rtc::CritScope lock(&acm_crit_sect_); |
1089 return receiver_.LastAudioCodec(current_codec); | 997 return receiver_.LastAudioCodec(current_codec); |
1090 } | 998 } |
1091 | 999 |
1092 rtc::Optional<SdpAudioFormat> AudioCodingModuleImpl::ReceiveFormat() const { | 1000 rtc::Optional<SdpAudioFormat> AudioCodingModuleImpl::ReceiveFormat() const { |
1093 rtc::CritScope lock(&acm_crit_sect_); | 1001 rtc::CritScope lock(&acm_crit_sect_); |
1094 return receiver_.LastAudioFormat(); | 1002 return receiver_.LastAudioFormat(); |
1095 } | 1003 } |
(...skipping 285 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1381 // Checks the validity of the parameters of the given codec | 1289 // Checks the validity of the parameters of the given codec |
1382 bool AudioCodingModule::IsCodecValid(const CodecInst& codec) { | 1290 bool AudioCodingModule::IsCodecValid(const CodecInst& codec) { |
1383 bool valid = acm2::RentACodec::IsCodecValid(codec); | 1291 bool valid = acm2::RentACodec::IsCodecValid(codec); |
1384 if (!valid) | 1292 if (!valid) |
1385 WEBRTC_TRACE(webrtc::kTraceError, webrtc::kTraceAudioCoding, -1, | 1293 WEBRTC_TRACE(webrtc::kTraceError, webrtc::kTraceAudioCoding, -1, |
1386 "Invalid codec setting"); | 1294 "Invalid codec setting"); |
1387 return valid; | 1295 return valid; |
1388 } | 1296 } |
1389 | 1297 |
1390 } // namespace webrtc | 1298 } // namespace webrtc |
OLD | NEW |