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 27665ca3f1b0fc90cd5980a435d164354b2529c0b5Andreas Huber#include "mpeg2ts/ATSParser.h" 2826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 29eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 30fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivinamespace android { 31fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 32be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel TriviStreamSourceAppProxy::StreamSourceAppProxy( 337133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, 347133228a478e16458b659946f2180ecddd13fda7Glenn Kasten const sp<CallbackProtector> &callbackProtector, 35a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // sp<StreamPlayer> would cause StreamPlayer's destructor to run during it's own 36a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // construction. If you pass in a sp<> to 'this' inside a constructor, then first the 37a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // refcount is increased from 0 to 1, then decreased from 1 to 0, which causes the object's 38a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // destructor to run from inside it's own constructor. 39a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten StreamPlayer * /* const sp<StreamPlayer> & */ player) : 40a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet(false), 417133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAndroidBufferQueue(androidBufferQueue), 42bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mCallbackProtector(callbackProtector), 43bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mPlayer(player) 4426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi{ 45ecc4fe22e076c4e5c891d823b01db1a683ba6690Glenn Kasten SL_LOGV("StreamSourceAppProxy::StreamSourceAppProxy()"); 4626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 4726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 4826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel TriviStreamSourceAppProxy::~StreamSourceAppProxy() { 49513222822545c3e954176476b263df52a47f43a4Glenn Kasten SL_LOGV("StreamSourceAppProxy::~StreamSourceAppProxy()"); 50a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten disconnect(); 5126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 5226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 531c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Triviconst SLuint32 StreamSourceAppProxy::kItemProcessed[NB_BUFFEREVENT_ITEM_FIELDS] = { 541c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROID_ITEMKEY_BUFFERQUEUEEVENT, // item key 551c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi sizeof(SLuint32), // item size 561c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED // item data 571c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi}; 581c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi 5926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------- 6026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi// IStreamSource implementation 6126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setListener(const sp<IStreamListener> &listener) { 62a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(listener != NULL); 6370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 64a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(mListener == NULL); 6526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mListener = listener; 6626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 6726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 6826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setBuffers(const Vector<sp<IMemory> > &buffers) { 69a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mLock); 70a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(!mBuffersHasBeenSet); 7126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mBuffers = buffers; 72a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet = true; 7326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 7426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::onBufferAvailable(size_t index) { 7670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi //SL_LOGD("StreamSourceAppProxy::onBufferAvailable(%d)", index); 7726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 7970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 804a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi if (!mBuffersHasBeenSet) { 814a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi // no buffers available to push data to from the buffer queue, bail 824a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi return; 834a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi } 84a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten CHECK_LT(index, mBuffers.size()); 85a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#if 0 // enable if needed for debugging 86a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten sp<IMemory> mem = mBuffers.itemAt(index); 87a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten SLAint64 length = (SLAint64) mem->size(); 88a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#endif 8970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.push_back(index); 90e2e8fa36bd7448b59fbcdf141e0b6d21e5401d91Glenn Kasten //SL_LOGD("onBufferAvailable() now %d buffers available in queue", 91e2e8fa36bd7448b59fbcdf141e0b6d21e5401d91Glenn Kasten // mAvailableBuffers.size()); 9270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 9370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 9470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // a new shared mem buffer is available: let's try to fill immediately 9570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi pullFromBuffQueue(); 9670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 9770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 9870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedCmd_l(IStreamListener::Command cmd, const sp<AMessage> &msg) { 99be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 10070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mListener->issueCommand(cmd, false /* synchronous */, msg); 10126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi } 10226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 10326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 10470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedBuffer_l(size_t buffIndex, size_t buffLength) { 105be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 106be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi mListener->queueBuffer(buffIndex, buffLength); 107be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi } 108be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 109be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 110a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kastenvoid StreamSourceAppProxy::disconnect() { 111a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mLock); 112a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mListener.clear(); 113a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // Force binder to push the decremented reference count for sp<IStreamListener>. 114a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // mediaserver and client both have sp<> to the other. When you decrement an sp<> 115a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // reference count, binder doesn't push that to the other process immediately. 116a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten IPCThreadState::self()->flushCommands(); 117a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffers.clear(); 118a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet = false; 119a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mAvailableBuffers.clear(); 120a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten} 121a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten 12270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi//-------------------------------------------------- 123bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi// consumption from ABQ: pull from the ABQ, and push to shared memory (media server) 12470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::pullFromBuffQueue() { 12570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 126485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten if (android::CallbackProtector::enterCbIfOk(mCallbackProtector)) { 127485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 12870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t bufferId; 12970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi void* bufferLoc; 13070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t buffSize; 13170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 13270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi slAndroidBufferQueueCallback callback = NULL; 133677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten void* pBufferContext, *pBufferData, *callbackPContext = NULL; 13470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *oldFront = NULL; 135677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten uint32_t dataSize /* , dataUsed */; 13670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 13770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // retrieve data from the buffer queue 13870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_lock_exclusive(mAndroidBufferQueue); 13970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 1406bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // can this read operation cause us to call the buffer queue callback 1416bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // (either because there was a command with no data, or all the data has been consumed) 1426bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi bool queueCallbackCandidate = false; 1436bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 14470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (mAndroidBufferQueue->mState.count != 0) { 145a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten // SL_LOGD("nbBuffers in ABQ = %u, buffSize=%u",abq->mState.count, buffSize); 14670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi assert(mAndroidBufferQueue->mFront != mAndroidBufferQueue->mRear); 14770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 14870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront = mAndroidBufferQueue->mFront; 14970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *newFront = &oldFront[1]; 15070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 15170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume events when starting to read data from a buffer for the first time 15270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed == 0) { 153677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten // note this code assumes at most one event per buffer; see IAndroidBufferQueue_Enqueue 15470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_EOS) { 15570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::EOS); 1566bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // EOS has no associated data 1576bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 15870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCONTINUITY) { 15970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY); 16070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCON_NEWPTS) { 16170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 16270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi msg->setInt64(IStreamListener::kKeyResumeAtPTS, 16370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi (int64_t)oldFront->mItems.mTsCmdData.mPts); 16470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 165af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode 166af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi & ANDROID_MP2TSEVENT_FORMAT_CHANGE_FULL) { 1676f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 168665ca3f1b0fc90cd5980a435d164354b2529c0b5Andreas Huber msg->setInt32( 169665ca3f1b0fc90cd5980a435d164354b2529c0b5Andreas Huber IStreamListener::kKeyDiscontinuityMask, 170665ca3f1b0fc90cd5980a435d164354b2529c0b5Andreas Huber ATSParser::DISCONTINUITY_FORMATCHANGE); 171af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 172af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode 173af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi & ANDROID_MP2TSEVENT_FORMAT_CHANGE_VIDEO) { 174af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi sp<AMessage> msg = new AMessage(); 175af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi msg->setInt32( 176af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi IStreamListener::kKeyDiscontinuityMask, 177af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi ATSParser::DISCONTINUITY_VIDEO_FORMAT); 1786f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 17970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 180af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi // note that here we are intentionally only supporting 181af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi // ANDROID_MP2TSEVENT_FORMAT_CHANGE_VIDEO, see IAndroidBufferQueue.c 182af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi 183af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi // some commands may introduce a time discontinuity, reevaluate position if needed 184a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten if (oldFront->mItems.mTsCmdData.mTsCmdCode & (ANDROID_MP2TSEVENT_DISCONTINUITY | 185af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi ANDROID_MP2TSEVENT_DISCON_NEWPTS | ANDROID_MP2TSEVENT_FORMAT_CHANGE_FULL)) { 186a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten const sp<StreamPlayer> player(mPlayer.promote()); 187a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten if (player != NULL) { 188a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // FIXME see note at onSeek 189a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten player->seek(ANDROID_UNKNOWN_TIME); 190a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 191a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten } 19270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mItems.mTsCmdData.mTsCmdCode = ANDROID_MP2TSEVENT_NONE; 19370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 19470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 19570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 19670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we're going to change the shared mem buffer queue, so lock it 19770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 19870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 19970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferId = *mAvailableBuffers.begin(); 20070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi CHECK_LT(bufferId, mBuffers.size()); 20170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<IMemory> mem = mBuffers.itemAt(bufferId); 20270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferLoc = mem->pointer(); 20370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi buffSize = mem->size(); 20470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 20570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi char *pSrc = ((char*)oldFront->mDataBuffer) + oldFront->mDataSizeConsumed; 20670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed + buffSize < oldFront->mDataSize) { 20770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // more available than requested, copy as much as requested 20870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 20970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, buffSize); 21070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 21170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed += buffSize; 21270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify shared mem listener that new data is available 21370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, buffSize); 21470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 21570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { 21670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // requested as much available or more: consume the whole of the current 21770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // buffer and move to the next 21870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t consumed = oldFront->mDataSize - oldFront->mDataSizeConsumed; 219a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten //SL_LOGD("consuming rest of buffer: enqueueing=%u", consumed); 22070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed = oldFront->mDataSize; 22170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 22270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // move queue to next 22370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (newFront == &mAndroidBufferQueue-> 22470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mBufferArray[mAndroidBufferQueue->mNumBuffers + 1]) { 22570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // reached the end, circle back 22670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi newFront = mAndroidBufferQueue->mBufferArray; 22770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 22870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mFront = newFront; 22970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.count--; 23070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.index++; 23170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 23270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (consumed > 0) { 23370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 23470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, consumed); 23570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 23670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // here nothing to do because we are done with this buffer 23770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify StreamPlayer that new data is available 23870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, consumed); 23970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 24070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 24170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 24270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // data has been consumed, and the buffer queue state has been updated 24370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we will notify the client if applicable 2446bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 24570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2466bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 2476bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 2486bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (queueCallbackCandidate) { 2496bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (mAndroidBufferQueue->mCallbackEventsMask & 2506bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED) { 2516bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callback = mAndroidBufferQueue->mCallback; 2526bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // save callback data while under lock 2536bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callbackPContext = mAndroidBufferQueue->mContext; 2546bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferContext = (void *)oldFront->mBufferContext; 2556bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferData = (void *)oldFront->mDataBuffer; 2566bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi dataSize = oldFront->mDataSize; 2576bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // here a buffer is only dequeued when fully consumed 2586bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //dataUsed = oldFront->mDataSizeConsumed; 259bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi } 26070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2616bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //SL_LOGD("%d buffers available after reading from queue", mAvailableBuffers.size()); 2626bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 2636bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // there is still room in the shared memory, recheck later if we can pull 2646bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // data from the buffer queue and write it to shared memory 265a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten const sp<StreamPlayer> player(mPlayer.promote()); 266a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten if (player != NULL) { 267a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten player->queueRefilled(); 268a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 2696bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 27070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 27170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 27270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { // empty queue 27370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi SL_LOGD("ABQ empty, starving!"); 2746bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 27570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 27670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_unlock_exclusive(mAndroidBufferQueue); 27770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 278a07e6cd61b12a5c6ed78adaa88a08abd028f5a64Jean-Michel Trivi // notify client of buffer processed 27970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (NULL != callback) { 28057ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SLresult result = (*callback)(&mAndroidBufferQueue->mItf, callbackPContext, 281677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten pBufferContext, pBufferData, dataSize, 282677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten dataSize, /* dataUsed */ 2831c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi // no messages during playback other than marking the buffer as processed 284677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten (const SLAndroidBufferItem*)(&kItemProcessed) /* pItems */, 285677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten NB_BUFFEREVENT_ITEM_FIELDS *sizeof(SLuint32) /* itemsLength */ ); 28657ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten if (SL_RESULT_SUCCESS != result) { 28757ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten // Reserved for future use 28857ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SL_LOGW("Unsuccessful result %d returned from AndroidBufferQueueCallback", result); 28957ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten } 29070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 291485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 292485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten mCallbackProtector->exitCb(); 293485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten } // enterCbIfOk 29470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 29570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 296be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 29726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 298167a2af67dcc0d20e6e3e995a23a0567715e0ee1Glenn KastenStreamPlayer::StreamPlayer(const AudioPlayback_Parameters* params, bool hasVideo, 2997133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, const sp<CallbackProtector> &callbackProtector) : 30068d56b8ebaf60184a3aef988e3d2b09ed8b88c05Jean-Michel Trivi GenericMediaPlayer(params, hasVideo), 301d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mAppProxy(new StreamSourceAppProxy(androidBufferQueue, callbackProtector, this)), 302d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCompleted(false) 303fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi{ 304e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::StreamPlayer()"); 305fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 306fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 307fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel TriviStreamPlayer::~StreamPlayer() { 308e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::~StreamPlayer()"); 309a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mAppProxy->disconnect(); 310fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 311fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 312fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 31370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamPlayer::onMessageReceived(const sp<AMessage> &msg) { 31470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi switch (msg->what()) { 315bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi case kWhatPullFromAbq: 316bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi onPullFromAndroidBufferQueue(); 31770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 31870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 319d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten case kWhatStopForDestroy: 320d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten onStopForDestroy(); 321d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten break; 322d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 32370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi default: 32470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi GenericMediaPlayer::onMessageReceived(msg); 32570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 32670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 32770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 32870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 32970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 330d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::preDestroy() { 331d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten // FIXME NuPlayerDriver is currently not thread-safe, so stop() must be called by looper 33252e35b2c9f25450452ab422c46737a7fb5b67380Lajos Molnar (new AMessage(kWhatStopForDestroy, this))->post(); 333d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten { 334d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 335d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten while (!mStopForDestroyCompleted) { 336d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.wait(mStopForDestroyLock); 337d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 338d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 339a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // GenericMediaPlayer::preDestroy will repeat some of what we've done, but that's benign 340a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten GenericMediaPlayer::preDestroy(); 341d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 342d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 343d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 344d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::onStopForDestroy() { 345d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten if (mPlayer != 0) { 346d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mPlayer->stop(); 347a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // causes CHECK failure in Nuplayer 348a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten //mPlayer->setDataSource(NULL); 349241b9c06493479dc632a8851097c193b724a2b41Andreas Huber mPlayer->setVideoSurfaceTexture(NULL); 350a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPlayer->disconnect(); 351a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPlayer.clear(); 352a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten { 353a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // FIXME ugh make this a method 354a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mPreparedPlayerLock); 355a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPreparedPlayer.clear(); 356a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 357d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 3588ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten { 3598ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 3608ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten mStopForDestroyCompleted = true; 3618ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten } 362d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.signal(); 363d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 364d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 365d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 36670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi/** 367bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi * Asynchronously notify the player that the queue is ready to be pulled from. 36870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi */ 369bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::queueRefilled() { 370bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // async notification that the ABQ was refilled: the player should pull from the ABQ, and 371bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // and push to shared memory (to the media server) 37252e35b2c9f25450452ab422c46737a7fb5b67380Lajos Molnar (new AMessage(kWhatPullFromAbq, this))->post(); 373be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 374be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 375e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivi 376e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivivoid StreamPlayer::appClear_l() { 37737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // the user of StreamPlayer has cleared its AndroidBufferQueue: 37837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // there's no clear() for the shared memory queue, so this is a no-op 37926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 38026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 381cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 382cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi//-------------------------------------------------- 383cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi// Event handlers 384cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivivoid StreamPlayer::onPrepare() { 385e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::onPrepare()"); 38685edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten sp<IMediaPlayerService> mediaPlayerService(getMediaPlayerService()); 38785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mediaPlayerService != NULL) { 3883376429dfe306b9bfebf3a50941e2ccf44984495Glenn Kasten mPlayer = mediaPlayerService->create(mPlayerClient /*IMediaPlayerClient*/, 389e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlaybackParams.sessionId); 39085edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 39185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGE("media player service failed to create player by app proxy"); 392d2a31043966c76e4739bb325edcd5a475861a951Glenn Kasten } else if (mPlayer->setDataSource(static_cast<sp<IStreamSource>>(mAppProxy)) != 393d2a31043966c76e4739bb325edcd5a475861a951Glenn Kasten NO_ERROR) { 394e52e877354b1477d5cb34d24c70417820b013521Dave Burke SL_LOGE("setDataSource failed"); 395e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlayer.clear(); 39685edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 39785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 39885edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 39985edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten mStateFlags |= kFlagPreparedUnsuccessfully; 40085edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 40185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten GenericMediaPlayer::onPrepare(); 40285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGD("StreamPlayer::onPrepare() done"); 403cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi} 404cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 405cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 406b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivivoid StreamPlayer::onPlay() { 407b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi SL_LOGD("StreamPlayer::onPlay()"); 408b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // enqueue a message that will cause StreamAppProxy to consume from the queue (again if the 409b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // player had starved the shared memory) 410bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi queueRefilled(); 411b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 412b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi GenericMediaPlayer::onPlay(); 413b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi} 414b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 415b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 416bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::onPullFromAndroidBufferQueue() { 4177133228a478e16458b659946f2180ecddd13fda7Glenn Kasten SL_LOGD("StreamPlayer::onPullFromAndroidBufferQueue()"); 4187133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAppProxy->pullFromBuffQueue(); 41970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 420cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 421fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} // namespace android 422