android_StreamPlayer.cpp revision d1e9fd4cff80becfef5077090fc90328ba63999a
1fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi/* 2fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * Copyright (C) 2010 The Android Open Source Project 3fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * 4fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * Licensed under the Apache License, Version 2.0 (the "License"); 5fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * you may not use this file except in compliance with the License. 6fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * You may obtain a copy of the License at 7fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * 8fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * http://www.apache.org/licenses/LICENSE-2.0 9fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * 10fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * Unless required by applicable law or agreed to in writing, software 11fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * distributed under the License is distributed on an "AS IS" BASIS, 12fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * See the License for the specific language governing permissions and 14fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi * limitations under the License. 15fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi */ 16fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 17e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi//#define USE_LOG SLAndroidLogLevel_Verbose 18fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 19fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi#include "sles_allinclusive.h" 204ee246c55533bdab8ab5fa0f0581744fe58e7c91Jean-Michel Trivi#include "android_StreamPlayer.h" 214ee246c55533bdab8ab5fa0f0581744fe58e7c91Jean-Michel Trivi 2263c002ab68761be0eace98f28320d8eb2f3f7695Jean-Michel Trivi#include <media/IStreamSource.h> 2326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi#include <media/IMediaPlayerService.h> 244ee246c55533bdab8ab5fa0f0581744fe58e7c91Jean-Michel Trivi#include <media/stagefright/foundation/ADebug.h> 25fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 2626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 27eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 28fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivinamespace android { 29fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 30be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel TriviStreamSourceAppProxy::StreamSourceAppProxy( 317133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, 327133228a478e16458b659946f2180ecddd13fda7Glenn Kasten const sp<CallbackProtector> &callbackProtector, 33bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi const sp<StreamPlayer> &player) : 347133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAndroidBufferQueue(androidBufferQueue), 35bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mCallbackProtector(callbackProtector), 36bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mPlayer(player) 3726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi{ 38ecc4fe22e076c4e5c891d823b01db1a683ba6690Glenn Kasten SL_LOGV("StreamSourceAppProxy::StreamSourceAppProxy()"); 3926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 4026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 4126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel TriviStreamSourceAppProxy::~StreamSourceAppProxy() { 42e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamSourceAppProxy::~StreamSourceAppProxy()"); 43be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi mListener.clear(); 44be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi mBuffers.clear(); 4526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 4626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 471c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Triviconst SLuint32 StreamSourceAppProxy::kItemProcessed[NB_BUFFEREVENT_ITEM_FIELDS] = { 481c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROID_ITEMKEY_BUFFERQUEUEEVENT, // item key 491c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi sizeof(SLuint32), // item size 501c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED // item data 511c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi}; 521c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi 5326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------- 5426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi// IStreamSource implementation 5526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setListener(const sp<IStreamListener> &listener) { 5670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 5726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mListener = listener; 5826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 5926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 6026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setBuffers(const Vector<sp<IMemory> > &buffers) { 6126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mBuffers = buffers; 6226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 6326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 6426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::onBufferAvailable(size_t index) { 6570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi //SL_LOGD("StreamSourceAppProxy::onBufferAvailable(%d)", index); 6626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 6726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi CHECK_LT(index, mBuffers.size()); 6826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi sp<IMemory> mem = mBuffers.itemAt(index); 6926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi SLAint64 length = (SLAint64) mem->size(); 7026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 7270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 7370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.push_back(index); 7470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 75b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi //SL_LOGD("onBufferAvailable() now %d buffers available in queue", mAvailableBuffers.size()); 7670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 7770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // a new shared mem buffer is available: let's try to fill immediately 7870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi pullFromBuffQueue(); 7970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 8070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 8170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedCmd_l(IStreamListener::Command cmd, const sp<AMessage> &msg) { 82be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 8370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mListener->issueCommand(cmd, false /* synchronous */, msg); 8426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi } 8526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 8626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 8770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedBuffer_l(size_t buffIndex, size_t buffLength) { 88be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 89be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi mListener->queueBuffer(buffIndex, buffLength); 90be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi } 91be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 92be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 9370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi//-------------------------------------------------- 94bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi// consumption from ABQ: pull from the ABQ, and push to shared memory (media server) 9570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::pullFromBuffQueue() { 9670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 97485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten if (android::CallbackProtector::enterCbIfOk(mCallbackProtector)) { 98485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 9970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t bufferId; 10070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi void* bufferLoc; 10170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t buffSize; 10270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 10370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi slAndroidBufferQueueCallback callback = NULL; 104677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten void* pBufferContext, *pBufferData, *callbackPContext = NULL; 10570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *oldFront = NULL; 106677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten uint32_t dataSize /* , dataUsed */; 10770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 10870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // retrieve data from the buffer queue 10970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_lock_exclusive(mAndroidBufferQueue); 11070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 1116bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // can this read operation cause us to call the buffer queue callback 1126bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // (either because there was a command with no data, or all the data has been consumed) 1136bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi bool queueCallbackCandidate = false; 1146bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 11570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (mAndroidBufferQueue->mState.count != 0) { 116a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten // SL_LOGD("nbBuffers in ABQ = %u, buffSize=%u",abq->mState.count, buffSize); 11770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi assert(mAndroidBufferQueue->mFront != mAndroidBufferQueue->mRear); 11870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 11970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront = mAndroidBufferQueue->mFront; 12070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *newFront = &oldFront[1]; 12170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 12270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume events when starting to read data from a buffer for the first time 12370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed == 0) { 124677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten // note this code assumes at most one event per buffer; see IAndroidBufferQueue_Enqueue 12570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_EOS) { 12670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::EOS); 1276bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // EOS has no associated data 1286bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 12970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCONTINUITY) { 13070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY); 13170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCON_NEWPTS) { 13270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 13370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi msg->setInt64(IStreamListener::kKeyResumeAtPTS, 13470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi (int64_t)oldFront->mItems.mTsCmdData.mPts); 13570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 1366f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_FORMAT_CHANGE) { 1376f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 1386f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi // positive value for format change key makes the discontinuity "hard", see key def 1396f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi msg->setInt32(IStreamListener::kKeyFormatChange, (int32_t) 1); 1406f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 14170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 14270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mItems.mTsCmdData.mTsCmdCode = ANDROID_MP2TSEVENT_NONE; 14370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 14470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 14570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 14670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we're going to change the shared mem buffer queue, so lock it 14770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 14870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 14970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferId = *mAvailableBuffers.begin(); 15070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi CHECK_LT(bufferId, mBuffers.size()); 15170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<IMemory> mem = mBuffers.itemAt(bufferId); 15270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferLoc = mem->pointer(); 15370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi buffSize = mem->size(); 15470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 15570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi char *pSrc = ((char*)oldFront->mDataBuffer) + oldFront->mDataSizeConsumed; 15670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed + buffSize < oldFront->mDataSize) { 15770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // more available than requested, copy as much as requested 15870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 15970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, buffSize); 16070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 16170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed += buffSize; 16270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify shared mem listener that new data is available 16370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, buffSize); 16470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 16570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { 16670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // requested as much available or more: consume the whole of the current 16770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // buffer and move to the next 16870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t consumed = oldFront->mDataSize - oldFront->mDataSizeConsumed; 169a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten //SL_LOGD("consuming rest of buffer: enqueueing=%u", consumed); 17070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed = oldFront->mDataSize; 17170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 17270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // move queue to next 17370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (newFront == &mAndroidBufferQueue-> 17470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mBufferArray[mAndroidBufferQueue->mNumBuffers + 1]) { 17570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // reached the end, circle back 17670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi newFront = mAndroidBufferQueue->mBufferArray; 17770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 17870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mFront = newFront; 17970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.count--; 18070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.index++; 18170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 18270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (consumed > 0) { 18370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 18470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, consumed); 18570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 18670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // here nothing to do because we are done with this buffer 18770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify StreamPlayer that new data is available 18870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, consumed); 18970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 19070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 19170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 19270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // data has been consumed, and the buffer queue state has been updated 19370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we will notify the client if applicable 1946bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 19570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 1966bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 1976bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 1986bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (queueCallbackCandidate) { 1996bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (mAndroidBufferQueue->mCallbackEventsMask & 2006bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED) { 2016bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callback = mAndroidBufferQueue->mCallback; 2026bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // save callback data while under lock 2036bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callbackPContext = mAndroidBufferQueue->mContext; 2046bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferContext = (void *)oldFront->mBufferContext; 2056bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferData = (void *)oldFront->mDataBuffer; 2066bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi dataSize = oldFront->mDataSize; 2076bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // here a buffer is only dequeued when fully consumed 2086bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //dataUsed = oldFront->mDataSizeConsumed; 209bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi } 21070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2116bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //SL_LOGD("%d buffers available after reading from queue", mAvailableBuffers.size()); 2126bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 2136bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // there is still room in the shared memory, recheck later if we can pull 2146bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // data from the buffer queue and write it to shared memory 2156bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi mPlayer->queueRefilled(); 2166bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 21770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 21870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 21970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { // empty queue 22070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi SL_LOGD("ABQ empty, starving!"); 2216bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 22270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 22370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_unlock_exclusive(mAndroidBufferQueue); 22470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 225a07e6cd61b12a5c6ed78adaa88a08abd028f5a64Jean-Michel Trivi // notify client of buffer processed 22670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (NULL != callback) { 22757ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SLresult result = (*callback)(&mAndroidBufferQueue->mItf, callbackPContext, 228677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten pBufferContext, pBufferData, dataSize, 229677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten dataSize, /* dataUsed */ 2301c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi // no messages during playback other than marking the buffer as processed 231677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten (const SLAndroidBufferItem*)(&kItemProcessed) /* pItems */, 232677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten NB_BUFFEREVENT_ITEM_FIELDS *sizeof(SLuint32) /* itemsLength */ ); 23357ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten if (SL_RESULT_SUCCESS != result) { 23457ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten // Reserved for future use 23557ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SL_LOGW("Unsuccessful result %d returned from AndroidBufferQueueCallback", result); 23657ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten } 23770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 238485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 239485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten mCallbackProtector->exitCb(); 240485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten } // enterCbIfOk 24170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 24270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 243be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 24426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 2457133228a478e16458b659946f2180ecddd13fda7Glenn KastenStreamPlayer::StreamPlayer(AudioPlayback_Parameters* params, bool hasVideo, 2467133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, const sp<CallbackProtector> &callbackProtector) : 24768d56b8ebaf60184a3aef988e3d2b09ed8b88c05Jean-Michel Trivi GenericMediaPlayer(params, hasVideo), 248d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mAppProxy(new StreamSourceAppProxy(androidBufferQueue, callbackProtector, this)), 249d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCompleted(false) 250fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi{ 251e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::StreamPlayer()"); 252fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 25326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mPlaybackParams = *params; 25426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 255fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 256fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 257fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel TriviStreamPlayer::~StreamPlayer() { 258e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::~StreamPlayer()"); 259fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 260fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 261fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 26270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamPlayer::onMessageReceived(const sp<AMessage> &msg) { 26370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi switch (msg->what()) { 264bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi case kWhatPullFromAbq: 265bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi onPullFromAndroidBufferQueue(); 26670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 26770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 268d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten case kWhatStopForDestroy: 269d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten onStopForDestroy(); 270d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten break; 271d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 27270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi default: 27370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi GenericMediaPlayer::onMessageReceived(msg); 27470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 27570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 27670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 27770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 27870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 279d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::preDestroy() { 280d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten // FIXME NuPlayerDriver is currently not thread-safe, so stop() must be called by looper 281d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten (new AMessage(kWhatStopForDestroy, id()))->post(); 282d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten { 283d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 284d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten while (!mStopForDestroyCompleted) { 285d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.wait(mStopForDestroyLock); 286d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 287d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 288d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten // skipping past GenericMediaPlayer::preDestroy 289d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten GenericPlayer::preDestroy(); 290d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 291d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 292d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 293d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::onStopForDestroy() { 294d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten if (mPlayer != 0) { 295d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mPlayer->stop(); 296d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 297d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCompleted = true; 298d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.signal(); 299d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 300d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 301d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 3027133228a478e16458b659946f2180ecddd13fda7Glenn Kastenvoid StreamPlayer::registerQueueCallback(IAndroidBufferQueue *androidBufferQueue) { 303e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::registerQueueCallback"); 304be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 305be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 30670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 30770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi/** 308bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi * Asynchronously notify the player that the queue is ready to be pulled from. 30970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi */ 310bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::queueRefilled() { 311bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // async notification that the ABQ was refilled: the player should pull from the ABQ, and 312bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // and push to shared memory (to the media server) 313bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi (new AMessage(kWhatPullFromAbq, id()))->post(); 314be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 315be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 316e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivi 317e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivivoid StreamPlayer::appClear_l() { 31837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // the user of StreamPlayer has cleared its AndroidBufferQueue: 31937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // there's no clear() for the shared memory queue, so this is a no-op 32026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 32126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 322cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 323cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi//-------------------------------------------------- 324cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi// Event handlers 325cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivivoid StreamPlayer::onPrepare() { 326e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::onPrepare()"); 32785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten sp<IMediaPlayerService> mediaPlayerService(getMediaPlayerService()); 32885edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mediaPlayerService != NULL) { 32985edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten mPlayer = mediaPlayerService->create(getpid(), mPlayerClient /*IMediaPlayerClient*/, 330e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlaybackParams.sessionId); 33185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 33285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGE("media player service failed to create player by app proxy"); 333e52e877354b1477d5cb34d24c70417820b013521Dave Burke } else if (mPlayer->setDataSource(mAppProxy /*IStreamSource*/) != NO_ERROR) { 334e52e877354b1477d5cb34d24c70417820b013521Dave Burke SL_LOGE("setDataSource failed"); 335e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlayer.clear(); 33685edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 33785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 33885edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 33985edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten mStateFlags |= kFlagPreparedUnsuccessfully; 34085edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 34185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten GenericMediaPlayer::onPrepare(); 34285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGD("StreamPlayer::onPrepare() done"); 343cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi} 344cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 345cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 346b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivivoid StreamPlayer::onPlay() { 347b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi SL_LOGD("StreamPlayer::onPlay()"); 348b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // enqueue a message that will cause StreamAppProxy to consume from the queue (again if the 349b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // player had starved the shared memory) 350bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi queueRefilled(); 351b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 352b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi GenericMediaPlayer::onPlay(); 353b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi} 354b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 355b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 356bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::onPullFromAndroidBufferQueue() { 3577133228a478e16458b659946f2180ecddd13fda7Glenn Kasten SL_LOGD("StreamPlayer::onPullFromAndroidBufferQueue()"); 3587133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAppProxy->pullFromBuffQueue(); 35970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 360cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 361fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} // namespace android 362