Index: webrtc/modules/audio_coding/acm2/acm_receiver.cc |
diff --git a/webrtc/modules/audio_coding/acm2/acm_receiver.cc b/webrtc/modules/audio_coding/acm2/acm_receiver.cc |
index f45d5d34149acea5c693c1aa36cc73dc06fad8c3..53ec8841e50c9a2b6e6b694a119d535ff236dfc9 100644 |
--- a/webrtc/modules/audio_coding/acm2/acm_receiver.cc |
+++ b/webrtc/modules/audio_coding/acm2/acm_receiver.cc |
@@ -25,7 +25,6 @@ |
#include "webrtc/modules/audio_coding/acm2/call_statistics.h" |
#include "webrtc/modules/audio_coding/neteq/include/neteq.h" |
#include "webrtc/system_wrappers/include/clock.h" |
-#include "webrtc/system_wrappers/include/critical_section_wrapper.h" |
#include "webrtc/system_wrappers/include/tick_util.h" |
#include "webrtc/system_wrappers/include/trace.h" |
@@ -119,8 +118,7 @@ bool IsCng(int codec_id) { |
} // namespace |
AcmReceiver::AcmReceiver(const AudioCodingModule::Config& config) |
- : crit_sect_(CriticalSectionWrapper::CreateCriticalSection()), |
- id_(config.id), |
+ : id_(config.id), |
last_audio_decoder_(nullptr), |
previous_audio_activity_(AudioFrame::kVadPassive), |
audio_buffer_(new int16_t[AudioFrame::kMaxDataSizeSamples]), |
@@ -157,7 +155,7 @@ int AcmReceiver::LeastRequiredDelayMs() const { |
} |
rtc::Optional<int> AcmReceiver::last_packet_sample_rate_hz() const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
return last_packet_sample_rate_hz_; |
} |
@@ -171,7 +169,7 @@ int AcmReceiver::InsertPacket(const WebRtcRTPHeader& rtp_header, |
const RTPHeader* header = &rtp_header.header; // Just a shorthand. |
{ |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
const Decoder* decoder = RtpHeaderToDecoder(*header, incoming_payload[0]); |
if (!decoder) { |
@@ -216,7 +214,7 @@ int AcmReceiver::GetAudio(int desired_freq_hz, AudioFrame* audio_frame) { |
size_t num_channels; |
// Accessing members, take the lock. |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
// Always write the output to |audio_buffer_| first. |
if (neteq_->GetAudio(AudioFrame::kMaxDataSizeSamples, |
@@ -317,7 +315,7 @@ int32_t AcmReceiver::AddCodec(int acm_codec_id, |
return *ned; |
}(); |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
// The corresponding NetEq decoder ID. |
// If this codec has been registered before. |
@@ -366,13 +364,13 @@ int32_t AcmReceiver::AddCodec(int acm_codec_id, |
void AcmReceiver::EnableVad() { |
neteq_->EnableVad(); |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
vad_enabled_ = true; |
} |
void AcmReceiver::DisableVad() { |
neteq_->DisableVad(); |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
vad_enabled_ = false; |
} |
@@ -384,7 +382,7 @@ void AcmReceiver::FlushBuffers() { |
// many as it can. |
int AcmReceiver::RemoveAllCodecs() { |
int ret_val = 0; |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
for (auto it = decoders_.begin(); it != decoders_.end(); ) { |
auto cur = it; |
++it; // it will be valid even if we erase cur |
@@ -404,7 +402,7 @@ int AcmReceiver::RemoveAllCodecs() { |
} |
int AcmReceiver::RemoveCodec(uint8_t payload_type) { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
auto it = decoders_.find(payload_type); |
if (it == decoders_.end()) { // Such a payload-type is not registered. |
return 0; |
@@ -422,7 +420,7 @@ int AcmReceiver::RemoveCodec(uint8_t payload_type) { |
} |
void AcmReceiver::set_id(int id) { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
id_ = id; |
} |
@@ -431,7 +429,7 @@ bool AcmReceiver::GetPlayoutTimestamp(uint32_t* timestamp) { |
} |
int AcmReceiver::LastAudioCodec(CodecInst* codec) const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
if (!last_audio_decoder_) { |
return -1; |
} |
@@ -468,7 +466,7 @@ void AcmReceiver::GetNetworkStatistics(NetworkStatistics* acm_stat) { |
int AcmReceiver::DecoderByPayloadType(uint8_t payload_type, |
CodecInst* codec) const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
auto it = decoders_.find(payload_type); |
if (it == decoders_.end()) { |
LOG(LERROR) << "AcmReceiver::DecoderByPayloadType " |
@@ -532,7 +530,7 @@ uint32_t AcmReceiver::NowInTimestamp(int decoder_sampling_rate) const { |
void AcmReceiver::GetDecodingCallStatistics( |
AudioDecodingCallStats* stats) const { |
- CriticalSectionScoped lock(crit_sect_.get()); |
+ rtc::CritScope lock(&crit_sect_); |
*stats = call_stats_.GetDecodingStatistics(); |
} |