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> 25d66a1acc332b1dacf8e13e932e904a686fcd9ac6Dongwon Kang#include <media/stagefright/foundation/MediaKeys.h> 26a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#include <binder/IPCThreadState.h> 27fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 2818ddf4c7a41e6c9752fb2dc39c52f41916723255Pawin Vongmasa#include <ATSParser.h> 2926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 30eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 31fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivinamespace android { 32fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 33be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel TriviStreamSourceAppProxy::StreamSourceAppProxy( 347133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, 357133228a478e16458b659946f2180ecddd13fda7Glenn Kasten const sp<CallbackProtector> &callbackProtector, 36a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // sp<StreamPlayer> would cause StreamPlayer's destructor to run during it's own 37a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // construction. If you pass in a sp<> to 'this' inside a constructor, then first the 38a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // refcount is increased from 0 to 1, then decreased from 1 to 0, which causes the object's 39a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // destructor to run from inside it's own constructor. 40a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten StreamPlayer * /* const sp<StreamPlayer> & */ player) : 41a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet(false), 427133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAndroidBufferQueue(androidBufferQueue), 43bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mCallbackProtector(callbackProtector), 44bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi mPlayer(player) 4526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi{ 46ecc4fe22e076c4e5c891d823b01db1a683ba6690Glenn Kasten SL_LOGV("StreamSourceAppProxy::StreamSourceAppProxy()"); 4726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 4826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 4926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel TriviStreamSourceAppProxy::~StreamSourceAppProxy() { 50513222822545c3e954176476b263df52a47f43a4Glenn Kasten SL_LOGV("StreamSourceAppProxy::~StreamSourceAppProxy()"); 51a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten disconnect(); 5226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 5326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 541c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Triviconst SLuint32 StreamSourceAppProxy::kItemProcessed[NB_BUFFEREVENT_ITEM_FIELDS] = { 551c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROID_ITEMKEY_BUFFERQUEUEEVENT, // item key 561c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi sizeof(SLuint32), // item size 571c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED // item data 581c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi}; 591c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi 6026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------- 6126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi// IStreamSource implementation 6226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setListener(const sp<IStreamListener> &listener) { 63a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(listener != NULL); 6470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 65a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(mListener == NULL); 6626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mListener = listener; 6726043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 6826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 6926043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::setBuffers(const Vector<sp<IMemory> > &buffers) { 70a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mLock); 71a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten assert(!mBuffersHasBeenSet); 7226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi mBuffers = buffers; 73a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet = true; 7426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 7526043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7626043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivivoid StreamSourceAppProxy::onBufferAvailable(size_t index) { 7770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi //SL_LOGD("StreamSourceAppProxy::onBufferAvailable(%d)", index); 7826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 7970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 8070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 814a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi if (!mBuffersHasBeenSet) { 824a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi // no buffers available to push data to from the buffer queue, bail 834a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi return; 844a4c728965b10df683d37b4b7ac27211e02006adJean-Michel Trivi } 85a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten CHECK_LT(index, mBuffers.size()); 86a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#if 0 // enable if needed for debugging 87a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten sp<IMemory> mem = mBuffers.itemAt(index); 88a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten SLAint64 length = (SLAint64) mem->size(); 89a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten#endif 9070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.push_back(index); 91e2e8fa36bd7448b59fbcdf141e0b6d21e5401d91Glenn Kasten //SL_LOGD("onBufferAvailable() now %d buffers available in queue", 92e2e8fa36bd7448b59fbcdf141e0b6d21e5401d91Glenn Kasten // mAvailableBuffers.size()); 9370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 9470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 9570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // a new shared mem buffer is available: let's try to fill immediately 9670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi pullFromBuffQueue(); 9770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 9870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 9970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedCmd_l(IStreamListener::Command cmd, const sp<AMessage> &msg) { 100be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 10170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mListener->issueCommand(cmd, false /* synchronous */, msg); 10226043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi } 10326043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 10426043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 10570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::receivedBuffer_l(size_t buffIndex, size_t buffLength) { 106be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi if (mListener != 0) { 107be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi mListener->queueBuffer(buffIndex, buffLength); 108be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi } 109be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 110be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 111a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kastenvoid StreamSourceAppProxy::disconnect() { 112a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mLock); 113a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mListener.clear(); 114a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // Force binder to push the decremented reference count for sp<IStreamListener>. 115a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // mediaserver and client both have sp<> to the other. When you decrement an sp<> 116a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // reference count, binder doesn't push that to the other process immediately. 117a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten IPCThreadState::self()->flushCommands(); 118a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffers.clear(); 119a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mBuffersHasBeenSet = false; 120a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mAvailableBuffers.clear(); 121a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten} 122a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten 12370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi//-------------------------------------------------- 124bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi// consumption from ABQ: pull from the ABQ, and push to shared memory (media server) 12570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamSourceAppProxy::pullFromBuffQueue() { 12670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 127485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten if (android::CallbackProtector::enterCbIfOk(mCallbackProtector)) { 128485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 12970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t bufferId; 13070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi void* bufferLoc; 13170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t buffSize; 13270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 13370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi slAndroidBufferQueueCallback callback = NULL; 134677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten void* pBufferContext, *pBufferData, *callbackPContext = NULL; 13570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *oldFront = NULL; 136677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten uint32_t dataSize /* , dataUsed */; 13770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 13870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // retrieve data from the buffer queue 13970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_lock_exclusive(mAndroidBufferQueue); 14070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 1416bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // can this read operation cause us to call the buffer queue callback 1426bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // (either because there was a command with no data, or all the data has been consumed) 1436bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi bool queueCallbackCandidate = false; 1446bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 14570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (mAndroidBufferQueue->mState.count != 0) { 146a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten // SL_LOGD("nbBuffers in ABQ = %u, buffSize=%u",abq->mState.count, buffSize); 14770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi assert(mAndroidBufferQueue->mFront != mAndroidBufferQueue->mRear); 14870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 14970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront = mAndroidBufferQueue->mFront; 15070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi AdvancedBufferHeader *newFront = &oldFront[1]; 15170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 15270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume events when starting to read data from a buffer for the first time 15370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed == 0) { 154677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten // note this code assumes at most one event per buffer; see IAndroidBufferQueue_Enqueue 15570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_EOS) { 15670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::EOS); 1576bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // EOS has no associated data 1586bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 15970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCONTINUITY) { 16070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY); 16170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode & ANDROID_MP2TSEVENT_DISCON_NEWPTS) { 16270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 163d66a1acc332b1dacf8e13e932e904a686fcd9ac6Dongwon Kang msg->setInt64(kATSParserKeyResumeAtPTS, 16470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi (int64_t)oldFront->mItems.mTsCmdData.mPts); 16570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 166af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode 167af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi & ANDROID_MP2TSEVENT_FORMAT_CHANGE_FULL) { 1686f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi sp<AMessage> msg = new AMessage(); 169665ca3f1b0fc90cd5980a435d164354b2529c0b5Andreas Huber msg->setInt32( 170d66a1acc332b1dacf8e13e932e904a686fcd9ac6Dongwon Kang kIStreamListenerKeyDiscontinuityMask, 171665ca3f1b0fc90cd5980a435d164354b2529c0b5Andreas Huber ATSParser::DISCONTINUITY_FORMATCHANGE); 172af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 173af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi } else if (oldFront->mItems.mTsCmdData.mTsCmdCode 174af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi & ANDROID_MP2TSEVENT_FORMAT_CHANGE_VIDEO) { 175af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi sp<AMessage> msg = new AMessage(); 176af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi msg->setInt32( 177d66a1acc332b1dacf8e13e932e904a686fcd9ac6Dongwon Kang kIStreamListenerKeyDiscontinuityMask, 178af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi ATSParser::DISCONTINUITY_VIDEO_FORMAT); 1796f0f5640d190b0187c356eb53bd96d9f9e49da60Jean-Michel Trivi receivedCmd_l(IStreamListener::DISCONTINUITY, msg /*msg*/); 18070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 181af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi // note that here we are intentionally only supporting 182af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi // ANDROID_MP2TSEVENT_FORMAT_CHANGE_VIDEO, see IAndroidBufferQueue.c 183af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi 184af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi // some commands may introduce a time discontinuity, reevaluate position if needed 185a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten if (oldFront->mItems.mTsCmdData.mTsCmdCode & (ANDROID_MP2TSEVENT_DISCONTINUITY | 186af9b87de97356722370d11d2c5797d75cb43969eJean-Michel Trivi ANDROID_MP2TSEVENT_DISCON_NEWPTS | ANDROID_MP2TSEVENT_FORMAT_CHANGE_FULL)) { 187a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten const sp<StreamPlayer> player(mPlayer.promote()); 188a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten if (player != NULL) { 189a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // FIXME see note at onSeek 190a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten player->seek(ANDROID_UNKNOWN_TIME); 191a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 192a9f22e6f5f53e90daa779e38b22f88e4faa35c95Glenn Kasten } 19370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mItems.mTsCmdData.mTsCmdCode = ANDROID_MP2TSEVENT_NONE; 19470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 19570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 19670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi { 19770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we're going to change the shared mem buffer queue, so lock it 19870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi Mutex::Autolock _l(mLock); 19970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 20070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferId = *mAvailableBuffers.begin(); 20170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi CHECK_LT(bufferId, mBuffers.size()); 20270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi sp<IMemory> mem = mBuffers.itemAt(bufferId); 20370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi bufferLoc = mem->pointer(); 20470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi buffSize = mem->size(); 20570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 20670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi char *pSrc = ((char*)oldFront->mDataBuffer) + oldFront->mDataSizeConsumed; 20770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (oldFront->mDataSizeConsumed + buffSize < oldFront->mDataSize) { 20870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // more available than requested, copy as much as requested 20970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 21070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, buffSize); 21170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 21270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed += buffSize; 21370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify shared mem listener that new data is available 21470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, buffSize); 21570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 21670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { 21770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // requested as much available or more: consume the whole of the current 21870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // buffer and move to the next 21970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi size_t consumed = oldFront->mDataSize - oldFront->mDataSizeConsumed; 220a8179ea15c4ff78db589d742b135649f0eda7ef2Glenn Kasten //SL_LOGD("consuming rest of buffer: enqueueing=%u", consumed); 22170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi oldFront->mDataSizeConsumed = oldFront->mDataSize; 22270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 22370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // move queue to next 22470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (newFront == &mAndroidBufferQueue-> 22570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mBufferArray[mAndroidBufferQueue->mNumBuffers + 1]) { 22670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // reached the end, circle back 22770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi newFront = mAndroidBufferQueue->mBufferArray; 22870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 22970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mFront = newFront; 23070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.count--; 23170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAndroidBufferQueue->mState.index++; 23270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 23370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (consumed > 0) { 23470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // consume data: 1/ copy to given destination 23570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi memcpy(bufferLoc, pSrc, consumed); 23670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 2/ keep track of how much has been consumed 23770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // here nothing to do because we are done with this buffer 23870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // 3/ notify StreamPlayer that new data is available 23970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi receivedBuffer_l(bufferId, consumed); 24070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi mAvailableBuffers.erase(mAvailableBuffers.begin()); 24170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 24270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 24370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // data has been consumed, and the buffer queue state has been updated 24470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi // we will notify the client if applicable 2456bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi queueCallbackCandidate = true; 24670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2476bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 2486bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi 2496bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (queueCallbackCandidate) { 2506bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (mAndroidBufferQueue->mCallbackEventsMask & 2516bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi SL_ANDROIDBUFFERQUEUEEVENT_PROCESSED) { 2526bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callback = mAndroidBufferQueue->mCallback; 2536bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // save callback data while under lock 2546bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi callbackPContext = mAndroidBufferQueue->mContext; 2556bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferContext = (void *)oldFront->mBufferContext; 2566bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi pBufferData = (void *)oldFront->mDataBuffer; 2576bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi dataSize = oldFront->mDataSize; 2586bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // here a buffer is only dequeued when fully consumed 2596bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //dataUsed = oldFront->mDataSizeConsumed; 260bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi } 26170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 2626bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi //SL_LOGD("%d buffers available after reading from queue", mAvailableBuffers.size()); 2636bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi if (!mAvailableBuffers.empty()) { 2646bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // there is still room in the shared memory, recheck later if we can pull 2656bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi // data from the buffer queue and write it to shared memory 266a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten const sp<StreamPlayer> player(mPlayer.promote()); 267a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten if (player != NULL) { 268a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten player->queueRefilled(); 269a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 2706bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 27170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 27270c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 27370c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } else { // empty queue 27470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi SL_LOGD("ABQ empty, starving!"); 2756bc8af4e67051af7c86c311cb9c50e294e547500Jean-Michel Trivi } 27670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 27770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi interface_unlock_exclusive(mAndroidBufferQueue); 27870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 279a07e6cd61b12a5c6ed78adaa88a08abd028f5a64Jean-Michel Trivi // notify client of buffer processed 28070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi if (NULL != callback) { 28157ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SLresult result = (*callback)(&mAndroidBufferQueue->mItf, callbackPContext, 282677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten pBufferContext, pBufferData, dataSize, 283677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten dataSize, /* dataUsed */ 2841c853a41d9d9886e60618a7c878ce3912f46bf3cJean-Michel Trivi // no messages during playback other than marking the buffer as processed 285677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten (const SLAndroidBufferItem*)(&kItemProcessed) /* pItems */, 286677c76347d9aaca4cf3746b3dbfc8a741281066bGlenn Kasten NB_BUFFEREVENT_ITEM_FIELDS *sizeof(SLuint32) /* itemsLength */ ); 28757ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten if (SL_RESULT_SUCCESS != result) { 28857ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten // Reserved for future use 28957ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten SL_LOGW("Unsuccessful result %d returned from AndroidBufferQueueCallback", result); 29057ec2b5fbd0c7c08f068e1f7b9d7644b0932617bGlenn Kasten } 29170c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 292485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten 293485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten mCallbackProtector->exitCb(); 294485a038f9f0f898227b8ab4218e94c5d56b6ed0bGlenn Kasten } // enterCbIfOk 29570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 29670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 297be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 29826043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi//-------------------------------------------------------------------------------------------------- 299167a2af67dcc0d20e6e3e995a23a0567715e0ee1Glenn KastenStreamPlayer::StreamPlayer(const AudioPlayback_Parameters* params, bool hasVideo, 3007133228a478e16458b659946f2180ecddd13fda7Glenn Kasten IAndroidBufferQueue *androidBufferQueue, const sp<CallbackProtector> &callbackProtector) : 30168d56b8ebaf60184a3aef988e3d2b09ed8b88c05Jean-Michel Trivi GenericMediaPlayer(params, hasVideo), 302d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mAppProxy(new StreamSourceAppProxy(androidBufferQueue, callbackProtector, this)), 303d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCompleted(false) 304fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi{ 305e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::StreamPlayer()"); 306fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 307fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 308fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel TriviStreamPlayer::~StreamPlayer() { 309e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::~StreamPlayer()"); 310a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mAppProxy->disconnect(); 311fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} 312fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 313fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi 31470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivivoid StreamPlayer::onMessageReceived(const sp<AMessage> &msg) { 31570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi switch (msg->what()) { 316bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi case kWhatPullFromAbq: 317bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi onPullFromAndroidBufferQueue(); 31870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 31970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 320d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten case kWhatStopForDestroy: 321d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten onStopForDestroy(); 322d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten break; 323d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 32470c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi default: 32570c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi GenericMediaPlayer::onMessageReceived(msg); 32670c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi break; 32770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi } 32870c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 32970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 33070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi 331d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::preDestroy() { 332d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten // FIXME NuPlayerDriver is currently not thread-safe, so stop() must be called by looper 33352e35b2c9f25450452ab422c46737a7fb5b67380Lajos Molnar (new AMessage(kWhatStopForDestroy, this))->post(); 334d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten { 335d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 336d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten while (!mStopForDestroyCompleted) { 337d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.wait(mStopForDestroyLock); 338d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 339d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 340a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // GenericMediaPlayer::preDestroy will repeat some of what we've done, but that's benign 341a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten GenericMediaPlayer::preDestroy(); 342d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 343d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 344d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 345d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kastenvoid StreamPlayer::onStopForDestroy() { 346d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten if (mPlayer != 0) { 347d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mPlayer->stop(); 348a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // causes CHECK failure in Nuplayer 349a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten //mPlayer->setDataSource(NULL); 350241b9c06493479dc632a8851097c193b724a2b41Andreas Huber mPlayer->setVideoSurfaceTexture(NULL); 351a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPlayer->disconnect(); 352a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPlayer.clear(); 353a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten { 354a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten // FIXME ugh make this a method 355a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten Mutex::Autolock _l(mPreparedPlayerLock); 356a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten mPreparedPlayer.clear(); 357a0fa47f72f47fffb80ab2ae791739ce73de1e8f4Glenn Kasten } 358d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten } 3598ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten { 3608ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten Mutex::Autolock _l(mStopForDestroyLock); 3618ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten mStopForDestroyCompleted = true; 3628ab6c02fa1384397d24eb8c15029577b17ab7c71Glenn Kasten } 363d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten mStopForDestroyCondition.signal(); 364d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten} 365d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 366d1e9fd4cff80becfef5077090fc90328ba63999aGlenn Kasten 36770c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi/** 368bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi * Asynchronously notify the player that the queue is ready to be pulled from. 36970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi */ 370bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::queueRefilled() { 371bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // async notification that the ABQ was refilled: the player should pull from the ABQ, and 372bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi // and push to shared memory (to the media server) 37352e35b2c9f25450452ab422c46737a7fb5b67380Lajos Molnar (new AMessage(kWhatPullFromAbq, this))->post(); 374be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi} 375be59fc5cfd9354d70d4b0e28bb2bca24a6ca6f22Jean-Michel Trivi 376e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivi 377e7bfcdc183454ec959ff51342f0973cabba219b2Jean-Michel Trivivoid StreamPlayer::appClear_l() { 37837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // the user of StreamPlayer has cleared its AndroidBufferQueue: 37937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // there's no clear() for the shared memory queue, so this is a no-op 38026043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi} 38126043f06b7d6cb2f93a2f2e7846a4e59da722206Jean-Michel Trivi 382cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 383cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi//-------------------------------------------------- 384cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi// Event handlers 385cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivivoid StreamPlayer::onPrepare() { 386e9236d046fdb5cac0696c42e03443a2439188146Jean-Michel Trivi SL_LOGD("StreamPlayer::onPrepare()"); 38785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten sp<IMediaPlayerService> mediaPlayerService(getMediaPlayerService()); 38885edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mediaPlayerService != NULL) { 3893376429dfe306b9bfebf3a50941e2ccf44984495Glenn Kasten mPlayer = mediaPlayerService->create(mPlayerClient /*IMediaPlayerClient*/, 390e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlaybackParams.sessionId); 39185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 39285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGE("media player service failed to create player by app proxy"); 393d2a31043966c76e4739bb325edcd5a475861a951Glenn Kasten } else if (mPlayer->setDataSource(static_cast<sp<IStreamSource>>(mAppProxy)) != 394d2a31043966c76e4739bb325edcd5a475861a951Glenn Kasten NO_ERROR) { 395e52e877354b1477d5cb34d24c70417820b013521Dave Burke SL_LOGE("setDataSource failed"); 396e52e877354b1477d5cb34d24c70417820b013521Dave Burke mPlayer.clear(); 39785edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 39885edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 39985edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten if (mPlayer == NULL) { 40085edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten mStateFlags |= kFlagPreparedUnsuccessfully; 40185edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten } 40285edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten GenericMediaPlayer::onPrepare(); 40385edd878a30caa535b0267d8d6e61b4ccc0d5fd0Glenn Kasten SL_LOGD("StreamPlayer::onPrepare() done"); 404cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi} 405cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 406cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 407b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivivoid StreamPlayer::onPlay() { 408b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi SL_LOGD("StreamPlayer::onPlay()"); 409b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // enqueue a message that will cause StreamAppProxy to consume from the queue (again if the 410b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi // player had starved the shared memory) 411bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivi queueRefilled(); 412b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 413b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi GenericMediaPlayer::onPlay(); 414b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi} 415b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 416b712aebe63a6c50cc01f4493282fc77578242976Jean-Michel Trivi 417bc0e642e6c1a51b3ae3a02d490d94b03e718e6b5Jean-Michel Trivivoid StreamPlayer::onPullFromAndroidBufferQueue() { 4187133228a478e16458b659946f2180ecddd13fda7Glenn Kasten SL_LOGD("StreamPlayer::onPullFromAndroidBufferQueue()"); 4197133228a478e16458b659946f2180ecddd13fda7Glenn Kasten mAppProxy->pullFromBuffQueue(); 42070c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi} 421cb417262919560a715628f4317dc8a4de386f750Jean-Michel Trivi 422fe6f6b9ed3683119721618e1aeaa8c7d6baee188Jean-Michel Trivi} // namespace android 423