android_StreamPlayer.cpp revision 513222822545c3e954176476b263df52a47f43a4
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> 25a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#include <binder/IPCThreadState.h> 26fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 2726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 28eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 29fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivinamespace android { 30fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 31be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel TriviStreamSourceAppProxy::StreamSourceAppProxy( 327133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, 337133228a478e16458b659946f2180ecddd13fda7Glenn Kasten const sp<CallbackProtector> &callbackProtector, 34a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // sp<StreamPlayer> would cause StreamPlayer's destructor to run during it's own 35a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // construction. If you pass in a sp<> to 'this' inside a constructor, then first the 36a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // refcount is increased from 0 to 1, then decreased from 1 to 0, which causes the object's 37a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // destructor to run from inside it's own constructor. 38a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten StreamPlayer * /* const sp<StreamPlayer> & */ player) : 39a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet(false), 407133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAndroidBufferQueue(androidBufferQueue), 41bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mCallbackProtector(callbackProtector), 42bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mPlayer(player) 4326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi{ 44ecc4fe22e076c4e5c891d823b01db1a683ba6690Glenn Kasten SL_LOGV("StreamSourceAppProxy::StreamSourceAppProxy()"); 4526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 4626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 4726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel TriviStreamSourceAppProxy::~StreamSourceAppProxy() { 48513222822545c3e954176476b263df52a47f43a4Glenn Kasten SL_LOGV("StreamSourceAppProxy::~StreamSourceAppProxy()"); 49a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten disconnect(); 5026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 5126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 521c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Triviconst SLuint32 StreamSourceAppProxy::kItemProcessed[NB_BUFFEREVENT_ITEM_FIELDS] = { 531c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROID_ITEMKEY_BUFFERQUEUEEVENT, // item key 541c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi sizeof(SLuint32), // item size 551c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED // item data 561c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi}; 571c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi 5826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------- 5926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi// IStreamSource implementation 6026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setListener(const sp<IStreamListener> &listener) { 61a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(listener != NULL); 6270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 63a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(mListener == NULL); 6426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mListener = listener; 6526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 6626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 6726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setBuffers(const Vector<sp<IMemory> > &buffers) { 68a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mLock); 69a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(!mBuffersHasBeenSet); 7026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mBuffers = buffers; 71a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet = true; 7226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 7326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::onBufferAvailable(size_t index) { 7570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi //SL_LOGD("StreamSourceAppProxy::onBufferAvailable(%d)", index); 7626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 7870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 79a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // assert not needed because if not set, size() will be zero and the CHECK_LT will also fail 80a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // assert(mBuffersHasBeenSet); 81a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten CHECK_LT(index, mBuffers.size()); 82a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#if 0 // enable if needed for debugging 83a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten sp<IMemory> mem = mBuffers.itemAt(index); 84a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten SLAint64 length = (SLAint64) mem->size(); 85a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#endif 8670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.push_back(index); 87a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten //SL_LOGD("onBufferAvailable() now %d buffers available in queue", mAvailableBuffers.size()); 8870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 8970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 9070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // a new shared mem buffer is available: let's try to fill immediately 9170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi pullFromBuffQueue(); 9270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 9370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 9470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedCmd_l(IStreamListener::Command cmd, const sp<AMessage> &msg) { 95be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 9670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mListener->issueCommand(cmd, false /* synchronous */, msg); 9726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi } 9826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 9926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 10070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedBuffer_l(size_t buffIndex, size_t buffLength) { 101be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 102be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi mListener->queueBuffer(buffIndex, buffLength); 103be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi } 104be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 105be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 106a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kastenvoid StreamSourceAppProxy::disconnect() { 107a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mLock); 108a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mListener.clear(); 109a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // Force binder to push the decremented reference count for sp<IStreamListener>. 110a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // mediaserver and client both have sp<> to the other. When you decrement an sp<> 111a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // reference count, binder doesn't push that to the other process immediately. 112a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten IPCThreadState::self()->flushCommands(); 113a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffers.clear(); 114a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet = false; 115a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mAvailableBuffers.clear(); 116a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten} 117a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten 11870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi//-------------------------------------------------- 119bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi// consumption from ABQ: pull from the ABQ, and push to shared memory (media server) 12070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::pullFromBuffQueue() { 12170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 122485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten if (android::CallbackProtector::enterCbIfOk(mCallbackProtector)) { 123485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 12470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t bufferId; 12570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi void* bufferLoc; 12670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t buffSize; 12770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 12870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi slAndroidBufferQueueCallback callback = NULL; 129677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten void* pBufferContext, *pBufferData, *callbackPContext = NULL; 13070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *oldFront = NULL; 131677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten uint32_t dataSize /* , dataUsed */; 13270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 13370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // retrieve data from the buffer queue 13470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_lock_exclusive(mAndroidBufferQueue); 13570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 1366bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // can this read operation cause us to call the buffer queue callback 1376bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // (either because there was a command with no data, or all the data has been consumed) 1386bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi bool queueCallbackCandidate = false; 1396bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 14070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (mAndroidBufferQueue->mState.count != 0) { 141a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten // SL_LOGD("nbBuffers in ABQ = %u, buffSize=%u",abq->mState.count, buffSize); 14270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi assert(mAndroidBufferQueue->mFront != mAndroidBufferQueue->mRear); 14370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 14470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront = mAndroidBufferQueue->mFront; 14570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *newFront = &oldFront[1]; 14670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 14770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume events when starting to read data from a buffer for the first time 14870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed == 0) { 149677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten // note this code assumes at most one event per buffer; see IAndroidBufferQueue_Enqueue 15070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_EOS) { 15170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::EOS); 1526bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // EOS has no associated data 1536bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 15470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCONTINUITY) { 15570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY); 15670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCON_NEWPTS) { 15770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 15870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi msg->setInt64(IStreamListener::kKeyResumeAtPTS, 15970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi (int64_t)oldFront->mItems.mTsCmdData.mPts); 16070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 1616f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_FORMAT_CHANGE) { 1626f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 1636f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi // positive value for format change key makes the discontinuity "hard", see key def 1646f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi msg->setInt32(IStreamListener::kKeyFormatChange, (int32_t) 1); 1656f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 16670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 167a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten if (oldFront->mItems.mTsCmdData.mTsCmdCode & (ANDROID_MP2TSEVENT_DISCONTINUITY | 168a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten ANDROID_MP2TSEVENT_DISCON_NEWPTS | ANDROID_MP2TSEVENT_FORMAT_CHANGE)) { 169a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten const sp<StreamPlayer> player(mPlayer.promote()); 170a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten if (player != NULL) { 171a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // FIXME see note at onSeek 172a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten player->seek(ANDROID_UNKNOWN_TIME); 173a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 174a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten } 17570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mItems.mTsCmdData.mTsCmdCode = ANDROID_MP2TSEVENT_NONE; 17670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 17770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 17870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 17970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we're going to change the shared mem buffer queue, so lock it 18070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 18170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 18270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferId = *mAvailableBuffers.begin(); 18370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi CHECK_LT(bufferId, mBuffers.size()); 18470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<IMemory> mem = mBuffers.itemAt(bufferId); 18570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferLoc = mem->pointer(); 18670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi buffSize = mem->size(); 18770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 18870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi char *pSrc = ((char*)oldFront->mDataBuffer) + oldFront->mDataSizeConsumed; 18970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed + buffSize < oldFront->mDataSize) { 19070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // more available than requested, copy as much as requested 19170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 19270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, buffSize); 19370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 19470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed += buffSize; 19570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify shared mem listener that new data is available 19670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, buffSize); 19770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 19870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { 19970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // requested as much available or more: consume the whole of the current 20070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // buffer and move to the next 20170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t consumed = oldFront->mDataSize - oldFront->mDataSizeConsumed; 202a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten //SL_LOGD("consuming rest of buffer: enqueueing=%u", consumed); 20370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed = oldFront->mDataSize; 20470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 20570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // move queue to next 20670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (newFront == &mAndroidBufferQueue-> 20770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mBufferArray[mAndroidBufferQueue->mNumBuffers + 1]) { 20870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // reached the end, circle back 20970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi newFront = mAndroidBufferQueue->mBufferArray; 21070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 21170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mFront = newFront; 21270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.count--; 21370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.index++; 21470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 21570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (consumed > 0) { 21670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 21770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, consumed); 21870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 21970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // here nothing to do because we are done with this buffer 22070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify StreamPlayer that new data is available 22170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, consumed); 22270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 22370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 22470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 22570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // data has been consumed, and the buffer queue state has been updated 22670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we will notify the client if applicable 2276bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 22870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2296bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 2306bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 2316bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (queueCallbackCandidate) { 2326bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (mAndroidBufferQueue->mCallbackEventsMask & 2336bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED) { 2346bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callback = mAndroidBufferQueue->mCallback; 2356bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // save callback data while under lock 2366bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callbackPContext = mAndroidBufferQueue->mContext; 2376bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferContext = (void *)oldFront->mBufferContext; 2386bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferData = (void *)oldFront->mDataBuffer; 2396bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi dataSize = oldFront->mDataSize; 2406bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // here a buffer is only dequeued when fully consumed 2416bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //dataUsed = oldFront->mDataSizeConsumed; 242bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi } 24370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2446bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //SL_LOGD("%d buffers available after reading from queue", mAvailableBuffers.size()); 2456bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 2466bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // there is still room in the shared memory, recheck later if we can pull 2476bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // data from the buffer queue and write it to shared memory 248a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten const sp<StreamPlayer> player(mPlayer.promote()); 249a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten if (player != NULL) { 250a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten player->queueRefilled(); 251a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 2526bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 25370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 25470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 25570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { // empty queue 25670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi SL_LOGD("ABQ empty, starving!"); 2576bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 25870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 25970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_unlock_exclusive(mAndroidBufferQueue); 26070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 261a07e6cd61b12a5c6ed78adaa88a08abd028f5a64Jean-Michel Trivi // notify client of buffer processed 26270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (NULL != callback) { 26357ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SLresult result = (*callback)(&mAndroidBufferQueue->mItf, callbackPContext, 264677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten pBufferContext, pBufferData, dataSize, 265677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten dataSize, /* dataUsed */ 2661c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi // no messages during playback other than marking the buffer as processed 267677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten (const SLAndroidBufferItem*)(&kItemProcessed) /* pItems */, 268677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten NB_BUFFEREVENT_ITEM_FIELDS *sizeof(SLuint32) /* itemsLength */ ); 26957ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten if (SL_RESULT_SUCCESS != result) { 27057ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten // Reserved for future use 27157ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SL_LOGW("Unsuccessful result %d returned from AndroidBufferQueueCallback", result); 27257ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten } 27370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 274485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 275485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten mCallbackProtector->exitCb(); 276485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten } // enterCbIfOk 27770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 27870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 279be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 28026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 2817133228a478e16458b659946f2180ecddd13fda7Glenn KastenStreamPlayer::StreamPlayer(AudioPlayback_Parameters* params, bool hasVideo, 2827133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, const sp<CallbackProtector> &callbackProtector) : 28368d56b8ebaf60184a3aef988e3d2b09ed8b88c05Jean-Michel Trivi GenericMediaPlayer(params, hasVideo), 284d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mAppProxy(new StreamSourceAppProxy(androidBufferQueue, callbackProtector, this)), 285d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCompleted(false) 286fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi{ 287e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::StreamPlayer()"); 288fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 28926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mPlaybackParams = *params; 29026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 291fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 292fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 293fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel TriviStreamPlayer::~StreamPlayer() { 294e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::~StreamPlayer()"); 295a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mAppProxy->disconnect(); 296fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 297fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 298fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 29970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamPlayer::onMessageReceived(const sp<AMessage> &msg) { 30070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi switch (msg->what()) { 301bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi case kWhatPullFromAbq: 302bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi onPullFromAndroidBufferQueue(); 30370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 30470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 305d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten case kWhatStopForDestroy: 306d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten onStopForDestroy(); 307d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten break; 308d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 30970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi default: 31070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi GenericMediaPlayer::onMessageReceived(msg); 31170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 31270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 31370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 31470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 31570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 316d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::preDestroy() { 317d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten // FIXME NuPlayerDriver is currently not thread-safe, so stop() must be called by looper 318d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten (new AMessage(kWhatStopForDestroy, id()))->post(); 319d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten { 320d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 321d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten while (!mStopForDestroyCompleted) { 322d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.wait(mStopForDestroyLock); 323d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 324d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 325a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // GenericMediaPlayer::preDestroy will repeat some of what we've done, but that's benign 326a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten GenericMediaPlayer::preDestroy(); 327d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 328d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 329d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 330d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::onStopForDestroy() { 331d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten if (mPlayer != 0) { 332d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mPlayer->stop(); 333a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // causes CHECK failure in Nuplayer 334a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten //mPlayer->setDataSource(NULL); 335241b9c06493479dc632a8851097c193b724a2b41Andreas Huber mPlayer->setVideoSurfaceTexture(NULL); 336a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPlayer->disconnect(); 337a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPlayer.clear(); 338a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten { 339a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // FIXME ugh make this a method 340a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mPreparedPlayerLock); 341a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPreparedPlayer.clear(); 342a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 343d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 3448ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten { 3458ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 3468ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten mStopForDestroyCompleted = true; 3478ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten } 348d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.signal(); 349d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 350d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 351d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 35270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi/** 353bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi * Asynchronously notify the player that the queue is ready to be pulled from. 35470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi */ 355bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::queueRefilled() { 356bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // async notification that the ABQ was refilled: the player should pull from the ABQ, and 357bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // and push to shared memory (to the media server) 358bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi (new AMessage(kWhatPullFromAbq, id()))->post(); 359be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 360be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 361e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivi 362e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivivoid StreamPlayer::appClear_l() { 36337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // the user of StreamPlayer has cleared its AndroidBufferQueue: 36437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // there's no clear() for the shared memory queue, so this is a no-op 36526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 36626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 367cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 368cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi//-------------------------------------------------- 369cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi// Event handlers 370cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivivoid StreamPlayer::onPrepare() { 371e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::onPrepare()"); 37285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten sp<IMediaPlayerService> mediaPlayerService(getMediaPlayerService()); 37385edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mediaPlayerService != NULL) { 37485edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten mPlayer = mediaPlayerService->create(getpid(), mPlayerClient /*IMediaPlayerClient*/, 375e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlaybackParams.sessionId); 37685edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 37785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGE("media player service failed to create player by app proxy"); 378e52e877354b1477d5cb34d24c70417820b013521Dave Burke } else if (mPlayer->setDataSource(mAppProxy /*IStreamSource*/) != NO_ERROR) { 379e52e877354b1477d5cb34d24c70417820b013521Dave Burke SL_LOGE("setDataSource failed"); 380e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlayer.clear(); 38185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 38285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 38385edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 38485edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten mStateFlags |= kFlagPreparedUnsuccessfully; 38585edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 38685edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten GenericMediaPlayer::onPrepare(); 38785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGD("StreamPlayer::onPrepare() done"); 388cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi} 389cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 390cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 391b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivivoid StreamPlayer::onPlay() { 392b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi SL_LOGD("StreamPlayer::onPlay()"); 393b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // enqueue a message that will cause StreamAppProxy to consume from the queue (again if the 394b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // player had starved the shared memory) 395bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi queueRefilled(); 396b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 397b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi GenericMediaPlayer::onPlay(); 398b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi} 399b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 400b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 401bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::onPullFromAndroidBufferQueue() { 4027133228a478e16458b659946f2180ecddd13fda7Glenn Kasten SL_LOGD("StreamPlayer::onPullFromAndroidBufferQueue()"); 4037133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAppProxy->pullFromBuffQueue(); 40470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 405cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 406fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} // namespace android 407