Merge change I9cc489a2 into eclair (0aa2563b) · Commits · e / devices / smdk4412 / android_frameworks_native

libs/audioflinger/AudioFlinger.cpp

+38 −17

Original line number	Original line	Diff line number	Diff line
	@@ -3086,23 +3086,34 @@ bool AudioFlinger::RecordThread::threadLoop()
	}		}
	if (mActiveTrack != 0) {		if (mActiveTrack != 0) {
	if (mActiveTrack->mState == TrackBase::PAUSING) {		if (mActiveTrack->mState == TrackBase::PAUSING) {
			if (!mStandby) {
			mInput->standby();
			mStandby = true;
			}
	mActiveTrack.clear();		mActiveTrack.clear();
	mStartStopCond.broadcast();		mStartStopCond.broadcast();
	} else if (mActiveTrack->mState == TrackBase::RESUMING) {		} else if (mActiveTrack->mState == TrackBase::RESUMING) {
	mRsmpInIndex = mFrameCount;
	if (mReqChannelCount != mActiveTrack->channelCount()) {		if (mReqChannelCount != mActiveTrack->channelCount()) {
	mActiveTrack.clear();		mActiveTrack.clear();
	} else {		mStartStopCond.broadcast();
			} else if (mBytesRead != 0) {
			// record start succeeds only if first read from audio input
			// succeeds
			if (mBytesRead > 0) {
	mActiveTrack->mState = TrackBase::ACTIVE;		mActiveTrack->mState = TrackBase::ACTIVE;
			} else {
			mActiveTrack.clear();
	}		}
	mStartStopCond.broadcast();		mStartStopCond.broadcast();
	}		}
	mStandby = false;		mStandby = false;
	}		}
	}		}
			}

	if (mActiveTrack != 0) {		if (mActiveTrack != 0) {
	if (mActiveTrack->mState != TrackBase::ACTIVE) {		if (mActiveTrack->mState != TrackBase::ACTIVE &&
			mActiveTrack->mState != TrackBase::RESUMING) {
	usleep(5000);		usleep(5000);
	continue;		continue;
	}		}
	@@ -3140,18 +3151,19 @@ bool AudioFlinger::RecordThread::threadLoop()
	}		}
	}		}
	if (framesOut && mFrameCount == mRsmpInIndex) {		if (framesOut && mFrameCount == mRsmpInIndex) {
	ssize_t bytesRead;
	if (framesOut == mFrameCount &&		if (framesOut == mFrameCount &&
	(mChannelCount == mReqChannelCount \|\| mFormat != AudioSystem::PCM_16_BIT)) {		(mChannelCount == mReqChannelCount \|\| mFormat != AudioSystem::PCM_16_BIT)) {
	bytesRead = mInput->read(buffer.raw, mInputBytes);		mBytesRead = mInput->read(buffer.raw, mInputBytes);
	framesOut = 0;		framesOut = 0;
	} else {		} else {
	bytesRead = mInput->read(mRsmpInBuffer, mInputBytes);		mBytesRead = mInput->read(mRsmpInBuffer, mInputBytes);
	mRsmpInIndex = 0;		mRsmpInIndex = 0;
	}		}
	if (bytesRead < 0) {		if (mBytesRead < 0) {
	LOGE("Error reading audio input");		LOGE("Error reading audio input");
			if (mActiveTrack->mState == TrackBase::ACTIVE) {
	sleep(1);		sleep(1);
			}
	mRsmpInIndex = mFrameCount;		mRsmpInIndex = mFrameCount;
	framesOut = 0;		framesOut = 0;
	buffer.frameCount = 0;		buffer.frameCount = 0;
	@@ -3220,7 +3232,7 @@ status_t AudioFlinger::RecordThread::start(RecordThread::RecordTrack* recordTrac
	if (recordTrack != mActiveTrack.get()) {		if (recordTrack != mActiveTrack.get()) {
	status = -EBUSY;		status = -EBUSY;
	} else if (mActiveTrack->mState == TrackBase::PAUSING) {		} else if (mActiveTrack->mState == TrackBase::PAUSING) {
	mActiveTrack->mState = TrackBase::RESUMING;		mActiveTrack->mState = TrackBase::ACTIVE;
	}		}
	return status;		return status;
	}		}
	@@ -3235,6 +3247,8 @@ status_t AudioFlinger::RecordThread::start(RecordThread::RecordTrack* recordTrac
	return status;		return status;
	}		}
	mActiveTrack->mState = TrackBase::RESUMING;		mActiveTrack->mState = TrackBase::RESUMING;
			mRsmpInIndex = mFrameCount;
			mBytesRead = 0;
	// signal thread to start		// signal thread to start
	LOGV("Signal record thread");		LOGV("Signal record thread");
	mWaitWorkCV.signal();		mWaitWorkCV.signal();
	@@ -3275,6 +3289,7 @@ void AudioFlinger::RecordThread::stop(RecordThread::RecordTrack* recordTrack) {
	mLock.unlock();		mLock.unlock();
	AudioSystem::stopInput(mId);		AudioSystem::stopInput(mId);
	mLock.lock();		mLock.lock();
			LOGV("Record stopped OK");
	}		}
	}		}
	}		}
	@@ -3325,10 +3340,12 @@ status_t AudioFlinger::RecordThread::getNextBuffer(AudioBufferProvider::Buffer*
	int channelCount;		int channelCount;

	if (framesReady == 0) {		if (framesReady == 0) {
	ssize_t bytesRead = mInput->read(mRsmpInBuffer, mInputBytes);		mBytesRead = mInput->read(mRsmpInBuffer, mInputBytes);
	if (bytesRead < 0) {		if (mBytesRead < 0) {
	LOGE("RecordThread::getNextBuffer() Error reading audio input");		LOGE("RecordThread::getNextBuffer() Error reading audio input");
			if (mActiveTrack->mState == TrackBase::ACTIVE) {
	sleep(1);		sleep(1);
			}
	buffer->raw = 0;		buffer->raw = 0;
	buffer->frameCount = 0;		buffer->frameCount = 0;
	return NOT_ENOUGH_DATA;		return NOT_ENOUGH_DATA;
	@@ -3546,11 +3563,13 @@ int AudioFlinger::openOutput(uint32_t *pDevices,
	if (pFormat) *pFormat = format;		if (pFormat) *pFormat = format;
	if (pChannels) *pChannels = channels;		if (pChannels) *pChannels = channels;
	if (pLatencyMs) *pLatencyMs = thread->latency();		if (pLatencyMs) *pLatencyMs = thread->latency();
	}

	return mNextThreadId;		return mNextThreadId;
	}		}

			return 0;
			}

	int AudioFlinger::openDuplicateOutput(int output1, int output2)		int AudioFlinger::openDuplicateOutput(int output1, int output2)
	{		{
	Mutex::Autolock _l(mLock);		Mutex::Autolock _l(mLock);
	@@ -3694,11 +3713,13 @@ int AudioFlinger::openInput(uint32_t *pDevices,
	if (pChannels) *pChannels = reqChannels;		if (pChannels) *pChannels = reqChannels;

	input->standby();		input->standby();
	}

	return mNextThreadId;		return mNextThreadId;
	}		}

			return 0;
			}

	status_t AudioFlinger::closeInput(int input)		status_t AudioFlinger::closeInput(int input)
	{		{
	// keep strong reference on the record thread so that		// keep strong reference on the record thread so that

libs/audioflinger/AudioFlinger.h

+1 −0

Original line number	Original line	Diff line number	Diff line
	@@ -744,6 +744,7 @@ private:
	size_t mInputBytes;		size_t mInputBytes;
	int mReqChannelCount;		int mReqChannelCount;
	uint32_t mReqSampleRate;		uint32_t mReqSampleRate;
			ssize_t mBytesRead;
	};		};

	class RecordHandle : public android::BnAudioRecord {		class RecordHandle : public android::BnAudioRecord {