NuPlayerDriver.cpp revision 09e0c3646362d29c78bc26c8b23b7a753c412e6c
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)/* 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Copyright (C) 2010 The Android Open Source Project 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Licensed under the Apache License, Version 2.0 (the "License"); 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * you may not use this file except in compliance with the License. 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * You may obtain a copy of the License at 71320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci * 81320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci * http://www.apache.org/licenses/LICENSE-2.0 91320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci * 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * Unless required by applicable law or agreed to in writing, software 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * distributed under the License is distributed on an "AS IS" BASIS, 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * See the License for the specific language governing permissions and 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) * limitations under the License. 159ab5563a3196760eb381d102cbb2bc0f7abc6a50Ben Murdoch */ 160529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 171320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci//#define LOG_NDEBUG 0 181320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#define LOG_TAG "NuPlayerDriver" 19a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include <inttypes.h> 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <utils/Log.h> 21f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 221320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "NuPlayerDriver.h" 23a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 24a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "NuPlayer.h" 25a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "NuPlayerSource.h" 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 271320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include <media/stagefright/foundation/ADebug.h> 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <media/stagefright/foundation/ALooper.h> 29a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include <media/stagefright/MetaData.h> 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace android { 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NuPlayerDriver::NuPlayerDriver() 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : mState(STATE_IDLE), 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mIsAsyncPrepare(false), 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mAsyncResult(UNKNOWN_ERROR), 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mSetSurfaceInProgress(false), 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mDurationUs(-1), 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPositionUs(-1), 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mNotifyTimeRealUs(-1), 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPauseStartedTimeUs(-1), 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mNumFramesTotal(0), 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mNumFramesDropped(0), 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mLooper(new ALooper), 451320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mPlayerFlags(0), 461320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mAtEOS(false), 471320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mLooping(false), 481320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mStartupSeekTimeUs(-1) { 491320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mLooper->setName("NuPlayerDriver Looper"); 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mLooper->start( 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) false, /* runOnCallingThread */ 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) true, /* canCallJava */ 54f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) PRIORITY_AUDIO); 55f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 561320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mPlayer = new NuPlayer; 571320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mLooper->registerHandler(mPlayer); 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->setDriver(this); 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)NuPlayerDriver::~NuPlayerDriver() { 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mLooper->stop(); 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::initCheck() { 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::setUID(uid_t uid) { 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->setUID(uid); 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 73f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return OK; 74f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles)} 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 762385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdochstatus_t NuPlayerDriver::setDataSource( 77f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) const sp<IMediaHTTPService> &httpService, 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const char *url, 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const KeyedVector<String8, String8> *headers) { 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Mutex::Autolock autoLock(mLock); 8190dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ALOGV("setDataSource: url=%s", url); 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mState != STATE_IDLE) { 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 871320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci mState = STATE_SET_DATASOURCE_PENDING; 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 89f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) mPlayer->setDataSourceAsync(httpService, url, headers); 901320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 91f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) while (mState == STATE_SET_DATASOURCE_PENDING) { 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mCondition.wait(mLock); 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return mAsyncResult; 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::setDataSource(int fd, int64_t offset, int64_t length) { 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Mutex::Autolock autoLock(mLock); 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ALOGV("setDataSource: fd=%d", fd); 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mState != STATE_IDLE) { 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mState = STATE_SET_DATASOURCE_PENDING; 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->setDataSourceAsync(fd, offset, length); 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while (mState == STATE_SET_DATASOURCE_PENDING) { 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mCondition.wait(mLock); 112f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) } 113f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return mAsyncResult; 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1172385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdochstatus_t NuPlayerDriver::setDataSource(const sp<IStreamSource> &source) { 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Mutex::Autolock autoLock(mLock); 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ALOGV("setDataSource: stream source"); 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mState != STATE_IDLE) { 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mState = STATE_SET_DATASOURCE_PENDING; 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->setDataSourceAsync(source); 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while (mState == STATE_SET_DATASOURCE_PENDING) { 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mCondition.wait(mLock); 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1332385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch return mAsyncResult; 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::setVideoSurfaceTexture( 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const sp<IGraphicBufferProducer> &bufferProducer) { 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Mutex::Autolock autoLock(mLock); 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mSetSurfaceInProgress) { 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (mState) { 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_SET_DATASOURCE_PENDING: 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RESET_IN_PROGRESS: 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mSetSurfaceInProgress = true; 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1552385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch mPlayer->setVideoSurfaceTextureAsync(bufferProducer); 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while (mSetSurfaceInProgress) { 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mCondition.wait(mLock); 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1631320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::prepare() { 165f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) Mutex::Autolock autoLock(mLock); 166f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) return prepare_l(); 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::prepare_l() { 1702385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch switch (mState) { 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_UNPREPARED: 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mState = STATE_PREPARING; 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1742385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch // Make sure we're not posting any notifications, success or 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // failure information is only communicated through our result 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // code. 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mIsAsyncPrepare = false; 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->prepareAsync(); 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while (mState == STATE_PREPARING) { 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mCondition.wait(mLock); 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return (mState == STATE_PREPARED) ? OK : UNKNOWN_ERROR; 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_STOPPED: 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // this is really just paused. handle as seek to start 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mAtEOS = false; 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mState = STATE_STOPPED_AND_PREPARING; 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mIsAsyncPrepare = false; 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->seekToAsync(0); 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while (mState == STATE_STOPPED_AND_PREPARING) { 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mCondition.wait(mLock); 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return (mState == STATE_STOPPED_AND_PREPARED) ? OK : UNKNOWN_ERROR; 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 1962385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch} 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::prepareAsync() { 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Mutex::Autolock autoLock(mLock); 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (mState) { 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_UNPREPARED: 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mState = STATE_PREPARING; 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mIsAsyncPrepare = true; 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->prepareAsync(); 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_STOPPED: 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // this is really just paused. handle as seek to start 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mAtEOS = false; 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mState = STATE_STOPPED_AND_PREPARING; 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mIsAsyncPrepare = true; 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->seekToAsync(0); 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return OK; 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return INVALID_OPERATION; 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)status_t NuPlayerDriver::start() { 2202385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch Mutex::Autolock autoLock(mLock); 2211320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 222f8ee788a64d60abd8f2d742a5fdedde054ecd910Torne (Richard Coles) switch (mState) { 2230529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch case STATE_UNPREPARED: 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) status_t err = prepare_l(); 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2270529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch if (err != OK) { 2281320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci return err; 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CHECK_EQ(mState, STATE_PREPARED); 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // fall through 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_PREPARED: 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mAtEOS = false; 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->start(); 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mStartupSeekTimeUs >= 0) { 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mStartupSeekTimeUs == 0) { 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) notifySeekComplete_l(); 2448bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) } else { 2458bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) mPlayer->seekToAsync(mStartupSeekTimeUs); 246a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) } 2470529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch 2480529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch mStartupSeekTimeUs = -1; 2492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 2500529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch break; 2510529e5d033099cbfc42635f6f6183833b09dff6eBen Murdoch } 2522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case STATE_RUNNING: 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mAtEOS) { 2562385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch mPlayer->seekToAsync(0); 2575d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) mAtEOS = false; 2585d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) mPositionUs = -1; 2595d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) } 2605d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) break; 2615d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) } 2625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 2635d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) case STATE_PAUSED: 2645d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) case STATE_STOPPED_AND_PREPARED: 2655d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) { 2665d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) if (mAtEOS) { 2672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) mPlayer->seekToAsync(0); 2682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) mAtEOS = false; 2692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) mPlayer->resume(); 2702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) mPositionUs = -1; 2712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } else { 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mPlayer->resume(); 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (mNotifyTimeRealUs != -1) { 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Pause time must be set if here by setPauseStartedTimeIfNeeded(). 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) //CHECK(mPauseStartedTimeUs != -1); 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // if no seek occurs, adjust our notify time so that getCurrentPosition() 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is continuous if read immediately after calling start(). 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mNotifyTimeRealUs += ALooper::GetNowUs() - mPauseStartedTimeUs; 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 281 } 282 break; 283 } 284 285 default: 286 return INVALID_OPERATION; 287 } 288 289 mState = STATE_RUNNING; 290 mPauseStartedTimeUs = -1; 291 292 return OK; 293} 294 295status_t NuPlayerDriver::stop() { 296 Mutex::Autolock autoLock(mLock); 297 298 switch (mState) { 299 case STATE_RUNNING: 300 mPlayer->pause(); 301 // fall through 302 303 case STATE_PAUSED: 304 mState = STATE_STOPPED; 305 notifyListener_l(MEDIA_STOPPED); 306 break; 307 308 case STATE_PREPARED: 309 case STATE_STOPPED: 310 case STATE_STOPPED_AND_PREPARING: 311 case STATE_STOPPED_AND_PREPARED: 312 mState = STATE_STOPPED; 313 break; 314 315 default: 316 return INVALID_OPERATION; 317 } 318 setPauseStartedTimeIfNeeded(); 319 320 return OK; 321} 322 323status_t NuPlayerDriver::pause() { 324 Mutex::Autolock autoLock(mLock); 325 326 switch (mState) { 327 case STATE_PAUSED: 328 case STATE_PREPARED: 329 return OK; 330 331 case STATE_RUNNING: 332 setPauseStartedTimeIfNeeded(); 333 mState = STATE_PAUSED; 334 notifyListener_l(MEDIA_PAUSED); 335 mPlayer->pause(); 336 break; 337 338 default: 339 return INVALID_OPERATION; 340 } 341 342 return OK; 343} 344 345bool NuPlayerDriver::isPlaying() { 346 return mState == STATE_RUNNING && !mAtEOS; 347} 348 349status_t NuPlayerDriver::seekTo(int msec) { 350 Mutex::Autolock autoLock(mLock); 351 352 int64_t seekTimeUs = msec * 1000ll; 353 354 switch (mState) { 355 case STATE_PREPARED: 356 { 357 mStartupSeekTimeUs = seekTimeUs; 358 // pretend that the seek completed. It will actually happen when starting playback. 359 // TODO: actually perform the seek here, so the player is ready to go at the new 360 // location 361 notifySeekComplete_l(); 362 break; 363 } 364 365 case STATE_RUNNING: 366 case STATE_PAUSED: 367 { 368 mAtEOS = false; 369 // seeks can take a while, so we essentially paused 370 notifyListener_l(MEDIA_PAUSED); 371 mPlayer->seekToAsync(seekTimeUs); 372 break; 373 } 374 375 default: 376 return INVALID_OPERATION; 377 } 378 379 mPositionUs = seekTimeUs; 380 mNotifyTimeRealUs = -1; 381 return OK; 382} 383 384status_t NuPlayerDriver::getCurrentPosition(int *msec) { 385 Mutex::Autolock autoLock(mLock); 386 387 if (mPositionUs < 0) { 388 // mPositionUs is the media time. 389 // It is negative under these cases 390 // (1) == -1 after reset, or very first playback, no stream notification yet. 391 // (2) == -1 start after end of stream, no stream notification yet. 392 // (3) == large negative # after ~292,471 years of continuous playback. 393 394 //CHECK_EQ(mPositionUs, -1); 395 *msec = 0; 396 } else if (mNotifyTimeRealUs == -1) { 397 // A seek has occurred just occurred, no stream notification yet. 398 // mPositionUs (>= 0) is the new media position. 399 *msec = mPositionUs / 1000; 400 } else { 401 // mPosition must be valid (i.e. >= 0) by the first check above. 402 // We're either playing or have pause time set: mPauseStartedTimeUs is >= 0 403 //LOG_ALWAYS_FATAL_IF( 404 // !isPlaying() && mPauseStartedTimeUs < 0, 405 // "Player in non-playing mState(%d) and mPauseStartedTimeUs(%lld) < 0", 406 // mState, (long long)mPauseStartedTimeUs); 407 ALOG_ASSERT(mNotifyTimeRealUs >= 0); 408 int64_t nowUs = 409 (isPlaying() ? ALooper::GetNowUs() : mPauseStartedTimeUs); 410 *msec = (mPositionUs + nowUs - mNotifyTimeRealUs + 500ll) / 1000; 411 // It is possible for *msec to be negative if the media position is > 596 hours. 412 // but we turn on this checking in NDEBUG == 0 mode. 413 ALOG_ASSERT(*msec >= 0); 414 ALOGV("getCurrentPosition nowUs(%lld)", (long long)nowUs); 415 } 416 ALOGV("getCurrentPosition returning(%d) mPositionUs(%lld) mNotifyRealTimeUs(%lld)", 417 *msec, (long long)mPositionUs, (long long)mNotifyTimeRealUs); 418 return OK; 419} 420 421status_t NuPlayerDriver::getDuration(int *msec) { 422 Mutex::Autolock autoLock(mLock); 423 424 if (mDurationUs < 0) { 425 return UNKNOWN_ERROR; 426 } 427 428 *msec = (mDurationUs + 500ll) / 1000; 429 430 return OK; 431} 432 433status_t NuPlayerDriver::reset() { 434 Mutex::Autolock autoLock(mLock); 435 436 switch (mState) { 437 case STATE_IDLE: 438 return OK; 439 440 case STATE_SET_DATASOURCE_PENDING: 441 case STATE_RESET_IN_PROGRESS: 442 return INVALID_OPERATION; 443 444 case STATE_PREPARING: 445 { 446 CHECK(mIsAsyncPrepare); 447 448 notifyListener_l(MEDIA_PREPARED); 449 break; 450 } 451 452 default: 453 break; 454 } 455 456 if (mState != STATE_STOPPED) { 457 notifyListener_l(MEDIA_STOPPED); 458 } 459 460 mState = STATE_RESET_IN_PROGRESS; 461 mPlayer->resetAsync(); 462 463 while (mState == STATE_RESET_IN_PROGRESS) { 464 mCondition.wait(mLock); 465 } 466 467 mDurationUs = -1; 468 mPositionUs = -1; 469 mStartupSeekTimeUs = -1; 470 mLooping = false; 471 472 return OK; 473} 474 475status_t NuPlayerDriver::setLooping(int loop) { 476 mLooping = loop != 0; 477 return OK; 478} 479 480player_type NuPlayerDriver::playerType() { 481 return NU_PLAYER; 482} 483 484status_t NuPlayerDriver::invoke(const Parcel &request, Parcel *reply) { 485 if (reply == NULL) { 486 ALOGE("reply is a NULL pointer"); 487 return BAD_VALUE; 488 } 489 490 int32_t methodId; 491 status_t ret = request.readInt32(&methodId); 492 if (ret != OK) { 493 ALOGE("Failed to retrieve the requested method to invoke"); 494 return ret; 495 } 496 497 switch (methodId) { 498 case INVOKE_ID_SET_VIDEO_SCALING_MODE: 499 { 500 int mode = request.readInt32(); 501 return mPlayer->setVideoScalingMode(mode); 502 } 503 504 case INVOKE_ID_GET_TRACK_INFO: 505 { 506 return mPlayer->getTrackInfo(reply); 507 } 508 509 case INVOKE_ID_SELECT_TRACK: 510 { 511 int trackIndex = request.readInt32(); 512 return mPlayer->selectTrack(trackIndex, true /* select */); 513 } 514 515 case INVOKE_ID_UNSELECT_TRACK: 516 { 517 int trackIndex = request.readInt32(); 518 return mPlayer->selectTrack(trackIndex, false /* select */); 519 } 520 521 case INVOKE_ID_GET_SELECTED_TRACK: 522 { 523 int32_t type = request.readInt32(); 524 return mPlayer->getSelectedTrack(type, reply); 525 } 526 527 default: 528 { 529 return INVALID_OPERATION; 530 } 531 } 532} 533 534void NuPlayerDriver::setAudioSink(const sp<AudioSink> &audioSink) { 535 mPlayer->setAudioSink(audioSink); 536} 537 538status_t NuPlayerDriver::setParameter( 539 int /* key */, const Parcel & /* request */) { 540 return INVALID_OPERATION; 541} 542 543status_t NuPlayerDriver::getParameter(int /* key */, Parcel * /* reply */) { 544 return INVALID_OPERATION; 545} 546 547status_t NuPlayerDriver::getMetadata( 548 const media::Metadata::Filter& /* ids */, Parcel *records) { 549 Mutex::Autolock autoLock(mLock); 550 551 using media::Metadata; 552 553 Metadata meta(records); 554 555 meta.appendBool( 556 Metadata::kPauseAvailable, 557 mPlayerFlags & NuPlayer::Source::FLAG_CAN_PAUSE); 558 559 meta.appendBool( 560 Metadata::kSeekBackwardAvailable, 561 mPlayerFlags & NuPlayer::Source::FLAG_CAN_SEEK_BACKWARD); 562 563 meta.appendBool( 564 Metadata::kSeekForwardAvailable, 565 mPlayerFlags & NuPlayer::Source::FLAG_CAN_SEEK_FORWARD); 566 567 meta.appendBool( 568 Metadata::kSeekAvailable, 569 mPlayerFlags & NuPlayer::Source::FLAG_CAN_SEEK); 570 571 return OK; 572} 573 574void NuPlayerDriver::notifyResetComplete() { 575 Mutex::Autolock autoLock(mLock); 576 577 CHECK_EQ(mState, STATE_RESET_IN_PROGRESS); 578 mState = STATE_IDLE; 579 mCondition.broadcast(); 580} 581 582void NuPlayerDriver::notifySetSurfaceComplete() { 583 Mutex::Autolock autoLock(mLock); 584 585 CHECK(mSetSurfaceInProgress); 586 mSetSurfaceInProgress = false; 587 588 mCondition.broadcast(); 589} 590 591void NuPlayerDriver::notifyDuration(int64_t durationUs) { 592 Mutex::Autolock autoLock(mLock); 593 mDurationUs = durationUs; 594} 595 596void NuPlayerDriver::notifyPosition(int64_t positionUs) { 597 Mutex::Autolock autoLock(mLock); 598 if (isPlaying()) { 599 mPositionUs = positionUs; 600 mNotifyTimeRealUs = ALooper::GetNowUs(); 601 } 602} 603 604void NuPlayerDriver::notifySeekComplete() { 605 Mutex::Autolock autoLock(mLock); 606 notifySeekComplete_l(); 607} 608 609void NuPlayerDriver::notifySeekComplete_l() { 610 bool wasSeeking = true; 611 if (mState == STATE_STOPPED_AND_PREPARING) { 612 wasSeeking = false; 613 mState = STATE_STOPPED_AND_PREPARED; 614 mCondition.broadcast(); 615 if (!mIsAsyncPrepare) { 616 // if we are preparing synchronously, no need to notify listener 617 return; 618 } 619 } else if (mState == STATE_STOPPED) { 620 // no need to notify listener 621 return; 622 } 623 notifyListener_l(wasSeeking ? MEDIA_SEEK_COMPLETE : MEDIA_PREPARED); 624} 625 626void NuPlayerDriver::notifyFrameStats( 627 int64_t numFramesTotal, int64_t numFramesDropped) { 628 Mutex::Autolock autoLock(mLock); 629 mNumFramesTotal = numFramesTotal; 630 mNumFramesDropped = numFramesDropped; 631} 632 633status_t NuPlayerDriver::dump( 634 int fd, const Vector<String16> & /* args */) const { 635 Mutex::Autolock autoLock(mLock); 636 637 FILE *out = fdopen(dup(fd), "w"); 638 639 fprintf(out, " NuPlayer\n"); 640 fprintf(out, " numFramesTotal(%" PRId64 "), numFramesDropped(%" PRId64 "), " 641 "percentageDropped(%.2f)\n", 642 mNumFramesTotal, 643 mNumFramesDropped, 644 mNumFramesTotal == 0 645 ? 0.0 : (double)mNumFramesDropped / mNumFramesTotal); 646 647 fclose(out); 648 out = NULL; 649 650 return OK; 651} 652 653void NuPlayerDriver::notifyListener( 654 int msg, int ext1, int ext2, const Parcel *in) { 655 Mutex::Autolock autoLock(mLock); 656 notifyListener_l(msg, ext1, ext2, in); 657} 658 659void NuPlayerDriver::notifyListener_l( 660 int msg, int ext1, int ext2, const Parcel *in) { 661 switch (msg) { 662 case MEDIA_PLAYBACK_COMPLETE: 663 { 664 if (mState != STATE_RESET_IN_PROGRESS) { 665 if (mLooping) { 666 mPlayer->seekToAsync(0); 667 break; 668 } 669 670 mPlayer->pause(); 671 mState = STATE_PAUSED; 672 } 673 // fall through 674 } 675 676 case MEDIA_ERROR: 677 { 678 mAtEOS = true; 679 setPauseStartedTimeIfNeeded(); 680 break; 681 } 682 683 default: 684 break; 685 } 686 687 mLock.unlock(); 688 sendEvent(msg, ext1, ext2, in); 689 mLock.lock(); 690} 691 692void NuPlayerDriver::notifySetDataSourceCompleted(status_t err) { 693 Mutex::Autolock autoLock(mLock); 694 695 CHECK_EQ(mState, STATE_SET_DATASOURCE_PENDING); 696 697 mAsyncResult = err; 698 mState = (err == OK) ? STATE_UNPREPARED : STATE_IDLE; 699 mCondition.broadcast(); 700} 701 702void NuPlayerDriver::notifyPrepareCompleted(status_t err) { 703 Mutex::Autolock autoLock(mLock); 704 705 if (mState != STATE_PREPARING) { 706 // We were preparing asynchronously when the client called 707 // reset(), we sent a premature "prepared" notification and 708 // then initiated the reset. This notification is stale. 709 CHECK(mState == STATE_RESET_IN_PROGRESS || mState == STATE_IDLE); 710 return; 711 } 712 713 CHECK_EQ(mState, STATE_PREPARING); 714 715 mAsyncResult = err; 716 717 if (err == OK) { 718 // update state before notifying client, so that if client calls back into NuPlayerDriver 719 // in response, NuPlayerDriver has the right state 720 mState = STATE_PREPARED; 721 if (mIsAsyncPrepare) { 722 notifyListener_l(MEDIA_PREPARED); 723 } 724 } else { 725 mState = STATE_UNPREPARED; 726 if (mIsAsyncPrepare) { 727 notifyListener_l(MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, err); 728 } 729 } 730 731 mCondition.broadcast(); 732} 733 734void NuPlayerDriver::notifyFlagsChanged(uint32_t flags) { 735 Mutex::Autolock autoLock(mLock); 736 737 mPlayerFlags = flags; 738} 739 740void NuPlayerDriver::setPauseStartedTimeIfNeeded() { 741 if (mPauseStartedTimeUs == -1) { 742 mPauseStartedTimeUs = ALooper::GetNowUs(); 743 } 744} 745 746} // namespace android 747