From 60cd0a0d488e604d27fc7dbb02b00348693dfde2 Mon Sep 17 00:00:00 2001 From: Eric Laurent Date: Tue, 13 Sep 2011 11:40:21 -0700 Subject: [PATCH] Issue 4345021: Audio routed to multiple devices... There is a possiblility that the condition on which RecordThread::checkForNewParameters_l() waits after updating the command completion status is never signalled. This happens if the thread executing ThreadBase::setParameters() has timed out waiting for the status (for instance if the audio HAL takes too long to execute the setParameters() command. Then the RecordThread is stuck forever. The fix consists in waiting for the condition with a timeout in RecordThread::checkForNewParameters_l(). Change-Id: I7fc671bc2fc43ba4acb65a2beb33ee05742f091e --- services/audioflinger/AudioFlinger.cpp | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/services/audioflinger/AudioFlinger.cpp b/services/audioflinger/AudioFlinger.cpp index 94efa749e0..a58f64c3a9 100644 --- a/services/audioflinger/AudioFlinger.cpp +++ b/services/audioflinger/AudioFlinger.cpp @@ -87,6 +87,8 @@ static const nsecs_t kWarningThrottle = seconds(5); // RecordThread loop sleep time upon application overrun or audio HAL read error static const int kRecordThreadSleepUs = 5000; +static const nsecs_t kSetParametersTimeout = seconds(2); + // ---------------------------------------------------------------------------- static bool recordingAllowed() { @@ -1032,7 +1034,7 @@ status_t AudioFlinger::ThreadBase::setParameters(const String8& keyValuePairs) mWaitWorkCV.signal(); // wait condition with timeout in case the thread loop has exited // before the request could be processed - if (mParamCond.waitRelative(mLock, seconds(2)) == NO_ERROR) { + if (mParamCond.waitRelative(mLock, kSetParametersTimeout) == NO_ERROR) { status = mParamStatus; mWaitWorkCV.signal(); } else { @@ -2349,7 +2351,9 @@ bool AudioFlinger::MixerThread::checkForNewParameters_l() mParamStatus = status; mParamCond.signal(); - mWaitWorkCV.wait(mLock); + // wait for condition with time out in case the thread calling ThreadBase::setParameters() + // already timed out waiting for the status and will never signal the condition. + mWaitWorkCV.waitRelative(mLock, kSetParametersTimeout); } return reconfig; } @@ -2828,7 +2832,9 @@ bool AudioFlinger::DirectOutputThread::checkForNewParameters_l() mParamStatus = status; mParamCond.signal(); - mWaitWorkCV.wait(mLock); + // wait for condition with time out in case the thread calling ThreadBase::setParameters() + // already timed out waiting for the status and will never signal the condition. + mWaitWorkCV.waitRelative(mLock, kSetParametersTimeout); } return reconfig; } @@ -4669,7 +4675,9 @@ bool AudioFlinger::RecordThread::checkForNewParameters_l() mParamStatus = status; mParamCond.signal(); - mWaitWorkCV.wait(mLock); + // wait for condition with time out in case the thread calling ThreadBase::setParameters() + // already timed out waiting for the status and will never signal the condition. + mWaitWorkCV.waitRelative(mLock, kSetParametersTimeout); } return reconfig; } -- 2.11.0