diff options
Diffstat (limited to 'modules/audio_device/linux/audio_device_pulse_linux.cc')
-rw-r--r-- | modules/audio_device/linux/audio_device_pulse_linux.cc | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/modules/audio_device/linux/audio_device_pulse_linux.cc b/modules/audio_device/linux/audio_device_pulse_linux.cc index 9faff1d021..9a7d1d0ca3 100644 --- a/modules/audio_device/linux/audio_device_pulse_linux.cc +++ b/modules/audio_device/linux/audio_device_pulse_linux.cc @@ -181,7 +181,7 @@ int32_t AudioDeviceLinuxPulse::Terminate() { return 0; } { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); quit_ = true; } _mixerManager.Close(); @@ -872,7 +872,7 @@ int32_t AudioDeviceLinuxPulse::InitPlayout() { // Create a new play stream { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); _playStream = LATE(pa_stream_new)(_paContext, "playStream", &playSampleSpec, NULL); } @@ -945,7 +945,7 @@ int32_t AudioDeviceLinuxPulse::InitPlayout() { // Mark playout side as initialized { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); _playIsInitialized = true; _sndCardPlayDelay = 0; } @@ -1066,7 +1066,7 @@ int32_t AudioDeviceLinuxPulse::StartRecording() { _timeEventRec.Set(); if (!_recStartEvent.Wait(10000)) { { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); _startRec = false; } StopRecording(); @@ -1075,7 +1075,7 @@ int32_t AudioDeviceLinuxPulse::StartRecording() { } { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); if (_recording) { // The recording state is set by the audio thread after recording // has started. @@ -1090,7 +1090,7 @@ int32_t AudioDeviceLinuxPulse::StartRecording() { int32_t AudioDeviceLinuxPulse::StopRecording() { RTC_DCHECK(thread_checker_.IsCurrent()); - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); if (!_recIsInitialized) { return 0; @@ -1170,7 +1170,7 @@ int32_t AudioDeviceLinuxPulse::StartPlayout() { // Set state to ensure that playout starts from the audio thread. { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); _startPlay = true; } @@ -1181,7 +1181,7 @@ int32_t AudioDeviceLinuxPulse::StartPlayout() { _timeEventPlay.Set(); if (!_playStartEvent.Wait(10000)) { { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); _startPlay = false; } StopPlayout(); @@ -1190,7 +1190,7 @@ int32_t AudioDeviceLinuxPulse::StartPlayout() { } { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); if (_playing) { // The playing state is set by the audio thread after playout // has started. @@ -1205,7 +1205,7 @@ int32_t AudioDeviceLinuxPulse::StartPlayout() { int32_t AudioDeviceLinuxPulse::StopPlayout() { RTC_DCHECK(thread_checker_.IsCurrent()); - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); if (!_playIsInitialized) { return 0; @@ -1259,7 +1259,7 @@ int32_t AudioDeviceLinuxPulse::StopPlayout() { } int32_t AudioDeviceLinuxPulse::PlayoutDelay(uint16_t& delayMS) const { - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); delayMS = (uint16_t)_sndCardPlayDelay; return 0; } @@ -1885,7 +1885,7 @@ int32_t AudioDeviceLinuxPulse::LatencyUsecs(pa_stream* stream) { int32_t AudioDeviceLinuxPulse::ReadRecordedData(const void* bufferData, size_t bufferSize) - RTC_EXCLUSIVE_LOCKS_REQUIRED(_critSect) { + RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_) { size_t size = bufferSize; uint32_t numRecSamples = _recordBufferSize / (2 * _recChannels); @@ -1953,7 +1953,7 @@ int32_t AudioDeviceLinuxPulse::ReadRecordedData(const void* bufferData, int32_t AudioDeviceLinuxPulse::ProcessRecordedData(int8_t* bufferData, uint32_t bufferSizeInSamples, uint32_t recDelay) - RTC_EXCLUSIVE_LOCKS_REQUIRED(_critSect) { + RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_) { _ptrAudioBuffer->SetRecordedBuffer(bufferData, bufferSizeInSamples); // TODO(andrew): this is a temporary hack, to avoid non-causal far- and @@ -1998,7 +1998,7 @@ bool AudioDeviceLinuxPulse::PlayThreadProcess() { return true; } - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); if (quit_) { return false; @@ -2170,7 +2170,7 @@ bool AudioDeviceLinuxPulse::RecThreadProcess() { return true; } - rtc::CritScope lock(&_critSect); + MutexLock lock(&mutex_); if (quit_) { return false; } |