1010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten/* 2010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * Copyright (C) 2012 The Android Open Source Project 3010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * 4010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * Licensed under the Apache License, Version 2.0 (the "License"); 5010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * you may not use this file except in compliance with the License. 6010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * You may obtain a copy of the License at 7010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * 8010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * http://www.apache.org/licenses/LICENSE-2.0 9010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * 10010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * Unless required by applicable law or agreed to in writing, software 11010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * distributed under the License is distributed on an "AS IS" BASIS, 12010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * See the License for the specific language governing permissions and 14010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * limitations under the License. 15010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten */ 16010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 17010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#define LOG_TAG "AudioBufferProviderSource" 18010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten//#define LOG_NDEBUG 0 19010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 20010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#include <cutils/compiler.h> 21010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#include <utils/Log.h> 222dd4bdd715f586d4d30cf90cc6fc2bbfbce60fe0Glenn Kasten#include <media/nbaio/AudioBufferProviderSource.h> 23010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 24010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastennamespace android { 25010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 26010662326b9c43c703725f933e95e0897f8a6bddGlenn KastenAudioBufferProviderSource::AudioBufferProviderSource(AudioBufferProvider *provider, 27010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten NBAIO_Format format) : 28010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten NBAIO_Source(format), mProvider(provider), mConsumed(0) 29010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 30010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(provider != NULL); 31010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(format != Format_Invalid); 32010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 33010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 34010662326b9c43c703725f933e95e0897f8a6bddGlenn KastenAudioBufferProviderSource::~AudioBufferProviderSource() 35010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 36010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (mBuffer.raw != NULL) { 37010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mProvider->releaseBuffer(&mBuffer); 38010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 39010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 40010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 41010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastenssize_t AudioBufferProviderSource::availableToRead() 42010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 43010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(!mNegotiated)) { 44010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return NEGOTIATE; 45010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 46010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return mBuffer.raw != NULL ? mBuffer.frameCount - mConsumed : 0; 47010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 48010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 492c3b2da3049627264b7c6b449a1622f002210f03John Grossmanssize_t AudioBufferProviderSource::read(void *buffer, 502c3b2da3049627264b7c6b449a1622f002210f03John Grossman size_t count, 512c3b2da3049627264b7c6b449a1622f002210f03John Grossman int64_t readPTS) 52010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 53010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(!mNegotiated)) { 54010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return NEGOTIATE; 55010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 56010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(mBuffer.raw == NULL)) { 57010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mBuffer.frameCount = count; 582c3b2da3049627264b7c6b449a1622f002210f03John Grossman status_t status = mProvider->getNextBuffer(&mBuffer, readPTS); 59010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (status != OK) { 60010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return status == NOT_ENOUGH_DATA ? (ssize_t) WOULD_BLOCK : (ssize_t) status; 61010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 62010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(mBuffer.raw != NULL); 63010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // mConsumed is 0 either from constructor or after releaseBuffer() 64010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 65010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten size_t available = mBuffer.frameCount - mConsumed; 66010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(count > available)) { 67010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten count = available; 68010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 69010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // count could be zero, either because count was zero on entry or 70010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // available is zero, but both are unlikely so don't check for that 71010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten memcpy(buffer, (char *) mBuffer.raw + (mConsumed << mBitShift), count << mBitShift); 72010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY((mConsumed += count) >= mBuffer.frameCount)) { 73010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mProvider->releaseBuffer(&mBuffer); 74010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mBuffer.raw = NULL; 75010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mConsumed = 0; 76010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 77010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mFramesRead += count; 78010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // For better responsiveness with large values of count, 79010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // return a short count rather than continuing with next buffer. 80010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // This gives the caller a chance to interpolate other actions. 81010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return count; 82010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 83010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 842c3b2da3049627264b7c6b449a1622f002210f03John Grossmanssize_t AudioBufferProviderSource::readVia(readVia_t via, size_t total, void *user, 852c3b2da3049627264b7c6b449a1622f002210f03John Grossman int64_t readPTS, size_t block) 86010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 87010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(!mNegotiated)) { 88010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return NEGOTIATE; 89010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 90010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(block == 0)) { 91010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten block = ~0; 92010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 93010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten for (size_t accumulator = 0; ; ) { 94010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(accumulator <= total); 95010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten size_t count = total - accumulator; 96010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(count == 0)) { 97010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return accumulator; 98010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 99010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_LIKELY(count > block)) { 100010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten count = block; 101010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 102010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // 1 <= count <= block 103010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(mBuffer.raw == NULL)) { 104010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mBuffer.frameCount = count; 1052c3b2da3049627264b7c6b449a1622f002210f03John Grossman status_t status = mProvider->getNextBuffer(&mBuffer, readPTS); 106010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_LIKELY(status == OK)) { 107010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(mBuffer.raw != NULL && mBuffer.frameCount <= count); 108010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // mConsumed is 0 either from constructor or after releaseBuffer() 109010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten continue; 110010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 111010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // FIXME simplify logic - does the initial count and block checks again for no reason; 112010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // don't you just want to fall through to the size_t available line? 113010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_LIKELY(status == NOT_ENOUGH_DATA)) { 114010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten status = WOULD_BLOCK; 115010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 116010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return accumulator > 0 ? accumulator : (ssize_t) status; 117010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 118010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten size_t available = mBuffer.frameCount - mConsumed; 119010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(count > available)) { 120010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten count = available; 121010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 122010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_LIKELY(count > 0)) { 1232c3b2da3049627264b7c6b449a1622f002210f03John Grossman char* readTgt = (char *) mBuffer.raw + (mConsumed << mBitShift); 1242c3b2da3049627264b7c6b449a1622f002210f03John Grossman ssize_t ret = via(user, readTgt, count, readPTS); 125010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(ret <= 0)) { 126010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_LIKELY(accumulator > 0)) { 127010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return accumulator; 128010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 129010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return ret; 130010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 131010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT((size_t) ret <= count); 132010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mFramesRead += ret; 133010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten accumulator += ret; 134010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_LIKELY((mConsumed += ret) < mBuffer.frameCount)) { 135010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten continue; 136010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 137010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 138010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mProvider->releaseBuffer(&mBuffer); 139010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mBuffer.raw = NULL; 140010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mConsumed = 0; 141010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // don't get next buffer until we really need it 142010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 143010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 144010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 145010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} // namespace android 146