AwesomePlayer.cpp revision 14acc736e336cbd6026df781d4f411e908831815
1bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber/* 2bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * Copyright (C) 2009 The Android Open Source Project 3bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * 4bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * Licensed under the Apache License, Version 2.0 (the "License"); 5bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * you may not use this file except in compliance with the License. 6bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * You may obtain a copy of the License at 7bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * 8bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * http://www.apache.org/licenses/LICENSE-2.0 9bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * 10bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * Unless required by applicable law or agreed to in writing, software 11bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * distributed under the License is distributed on an "AS IS" BASIS, 12bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * See the License for the specific language governing permissions and 14bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber * limitations under the License. 15bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber */ 16bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 17bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber//#define LOG_NDEBUG 0 18bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#define LOG_TAG "AwesomePlayer" 19bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <utils/Log.h> 20bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 21988e3f0b2c74095deae580157c57935a98573052Andreas Huber#include <dlfcn.h> 22988e3f0b2c74095deae580157c57935a98573052Andreas Huber 23cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber#include "include/ARTSPController.h" 24bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include "include/AwesomePlayer.h" 25733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber#include "include/SoftwareRenderer.h" 260a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber#include "include/NuCachedSource2.h" 270a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber#include "include/ThrottledSource.h" 28bff07d0b22a5ee2d9f044f6cb5e4be1532017ab0Andreas Huber#include "include/MPEG2TSExtractor.h" 29bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 3039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#include "ARTPSession.h" 3139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#include "APacketSource.h" 3239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#include "ASessionDescription.h" 3339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#include "UDPPusher.h" 3439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 354844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber#include <binder/IPCThreadState.h> 36e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber#include <binder/MemoryDealer.h> 37e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber#include <media/IStreamSource.h> 38e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber#include <media/stagefright/foundation/hexdump.h> 39e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber#include <media/stagefright/foundation/ADebug.h> 40bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/AudioPlayer.h> 41bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/DataSource.h> 42bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/FileSource.h> 43bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/MediaBuffer.h> 44717826ececd8d39596f62418677721d70776add1Andreas Huber#include <media/stagefright/MediaDefs.h> 45bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/MediaExtractor.h> 46bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/MediaSource.h> 47bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/MetaData.h> 48bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber#include <media/stagefright/OMXCodec.h> 49717826ececd8d39596f62418677721d70776add1Andreas Huber 505daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber#include <surfaceflinger/Surface.h> 513cf613507f1e2f7bd932d921a6e222e426fd3be4Mathias Agopian 52cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber#include <media/stagefright/foundation/ALooper.h> 5314acc736e336cbd6026df781d4f411e908831815Andreas Huber#include <media/stagefright/foundation/AMessage.h> 54a44153c1a57202fb538659eb50706e60454d6273Andreas Huber#include "include/LiveSession.h" 55e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber 56e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber#define USE_SURFACE_ALLOC 1 57e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber 58bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubernamespace android { 59bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 608650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huberstatic int64_t kLowWaterMarkUs = 2000000ll; // 2secs 618650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huberstatic int64_t kHighWaterMarkUs = 10000000ll; // 10secs 628650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber 63bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstruct AwesomeEvent : public TimedEventQueue::Event { 64c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber AwesomeEvent( 65c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber AwesomePlayer *player, 66c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber void (AwesomePlayer::*method)()) 67bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber : mPlayer(player), 68c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mMethod(method) { 69bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 70bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 71bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberprotected: 72bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber virtual ~AwesomeEvent() {} 73bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 74bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber virtual void fire(TimedEventQueue *queue, int64_t /* now_us */) { 75c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber (mPlayer->*mMethod)(); 76bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 77bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 78bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberprivate: 79bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber AwesomePlayer *mPlayer; 80c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber void (AwesomePlayer::*mMethod)(); 81bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 82bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber AwesomeEvent(const AwesomeEvent &); 83bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber AwesomeEvent &operator=(const AwesomeEvent &); 84bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber}; 85bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 86733b7729ea462fae9c6899456444e28fef1c757cAndreas Huberstruct AwesomeLocalRenderer : public AwesomeRenderer { 87733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber AwesomeLocalRenderer( 88f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber const sp<Surface> &surface, const sp<MetaData> &meta) 89f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber : mTarget(new SoftwareRenderer(surface, meta)) { 90733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber } 91733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber 92733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber virtual void render(MediaBuffer *buffer) { 93fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber render((const uint8_t *)buffer->data() + buffer->range_offset(), 94fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber buffer->range_length()); 95fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber } 96fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber 97fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber void render(const void *data, size_t size) { 98fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber mTarget->render(data, size, NULL); 99733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber } 100733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber 101733b7729ea462fae9c6899456444e28fef1c757cAndreas Huberprotected: 102733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber virtual ~AwesomeLocalRenderer() { 103733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber delete mTarget; 104733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber mTarget = NULL; 105733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber } 106733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber 107733b7729ea462fae9c6899456444e28fef1c757cAndreas Huberprivate: 1080a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber SoftwareRenderer *mTarget; 109988e3f0b2c74095deae580157c57935a98573052Andreas Huber 110733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber AwesomeLocalRenderer(const AwesomeLocalRenderer &); 111733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber AwesomeLocalRenderer &operator=(const AwesomeLocalRenderer &);; 112733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber}; 113733b7729ea462fae9c6899456444e28fef1c757cAndreas Huber 1146a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennisstruct AwesomeNativeWindowRenderer : public AwesomeRenderer { 115ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber AwesomeNativeWindowRenderer( 116ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber const sp<ANativeWindow> &nativeWindow, 117ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber int32_t rotationDegrees) 1186a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis : mNativeWindow(nativeWindow) { 119ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber applyRotation(rotationDegrees); 1206a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis } 1216a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis 1226a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis virtual void render(MediaBuffer *buffer) { 1236a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis status_t err = mNativeWindow->queueBuffer( 1246a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis mNativeWindow.get(), buffer->graphicBuffer().get()); 1256a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis if (err != 0) { 1266a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis LOGE("queueBuffer failed with error %s (%d)", strerror(-err), 1276a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis -err); 1286a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis return; 1296a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis } 1306a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis 1316a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis sp<MetaData> metaData = buffer->meta_data(); 1326a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis metaData->setInt32(kKeyRendered, 1); 1336a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis } 1346a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis 1356a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennisprotected: 1366a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis virtual ~AwesomeNativeWindowRenderer() {} 1376a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis 1386a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennisprivate: 1396a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis sp<ANativeWindow> mNativeWindow; 1406a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis 141ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber void applyRotation(int32_t rotationDegrees) { 142ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber uint32_t transform; 143ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber switch (rotationDegrees) { 144ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber case 0: transform = 0; break; 145ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber case 90: transform = HAL_TRANSFORM_ROT_90; break; 146ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber case 180: transform = HAL_TRANSFORM_ROT_180; break; 147ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber case 270: transform = HAL_TRANSFORM_ROT_270; break; 148ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber default: transform = 0; break; 149ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } 150ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber 151ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber if (transform) { 152ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber CHECK_EQ(0, native_window_set_buffers_transform( 153ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber mNativeWindow.get(), transform)); 154ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } 155ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } 156ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber 1576a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis AwesomeNativeWindowRenderer(const AwesomeNativeWindowRenderer &); 1586a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis AwesomeNativeWindowRenderer &operator=( 1596a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis const AwesomeNativeWindowRenderer &); 1606a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis}; 1616a9da9fc558263548ebfbae2cbf177eb7454a41bJamie Gennis 162e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber//////////////////////////////////////////////////////////////////////////////// 163e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 164e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberstruct QueueDataSource; 165e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 166e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberstruct QueueListener : public BnStreamListener { 167e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber QueueListener(QueueDataSource *owner) 168e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber : mOwner(owner) { 169e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 170e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 171e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber void clearOwner(); 172e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 173e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber virtual void queueBuffer(size_t index, size_t size); 17414acc736e336cbd6026df781d4f411e908831815Andreas Huber 17514acc736e336cbd6026df781d4f411e908831815Andreas Huber virtual void issueCommand( 17614acc736e336cbd6026df781d4f411e908831815Andreas Huber Command cmd, bool synchronous, const sp<AMessage> &msg); 177e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 178e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberprivate: 179e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex mLock; 180e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 181e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber QueueDataSource *mOwner; 182e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 183e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber DISALLOW_EVIL_CONSTRUCTORS(QueueListener); 184e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber}; 185e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 186e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberstruct QueueDataSource : public DataSource { 187e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber QueueDataSource(const sp<IStreamSource> &source); 188e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 189e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber virtual status_t initCheck() const; 190e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 191e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber virtual ssize_t readAt(off64_t offset, void *data, size_t size); 192e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 193e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber virtual void queueBuffer(size_t index, size_t size); 19414acc736e336cbd6026df781d4f411e908831815Andreas Huber 19514acc736e336cbd6026df781d4f411e908831815Andreas Huber virtual void issueCommand( 19614acc736e336cbd6026df781d4f411e908831815Andreas Huber IStreamListener::Command cmd, 19714acc736e336cbd6026df781d4f411e908831815Andreas Huber bool synchronous, 19814acc736e336cbd6026df781d4f411e908831815Andreas Huber const sp<AMessage> &msg); 199e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 200e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberprotected: 201e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber virtual ~QueueDataSource(); 202e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 203e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberprivate: 204e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber enum { 205e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber kNumBuffers = 16 206e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber }; 207e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 20814acc736e336cbd6026df781d4f411e908831815Andreas Huber struct QueueEntry { 20914acc736e336cbd6026df781d4f411e908831815Andreas Huber bool mIsCommand; 21014acc736e336cbd6026df781d4f411e908831815Andreas Huber 21114acc736e336cbd6026df781d4f411e908831815Andreas Huber IStreamListener::Command mCommand; 21214acc736e336cbd6026df781d4f411e908831815Andreas Huber sp<AMessage> mCommandMessage; 21314acc736e336cbd6026df781d4f411e908831815Andreas Huber 214e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber size_t mIndex; 215e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber size_t mOffset; 216e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber size_t mSize; 217e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber }; 218e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 219e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex mLock; 220e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Condition mCondition; 221e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 222e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber sp<IStreamSource> mSource; 223e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber sp<QueueListener> mListener; 224e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber sp<MemoryDealer> mDealer; 225e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Vector<sp<IMemory> > mBuffers; 226e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 22714acc736e336cbd6026df781d4f411e908831815Andreas Huber List<QueueEntry> mQueue; 228e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 229e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber off64_t mPosition; 230e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber bool mEOS; 231e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 232e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber DISALLOW_EVIL_CONSTRUCTORS(QueueDataSource); 233e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber}; 234e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 235e2b1028852120bcfded33b8f06f66b780437fe92Andreas HuberQueueDataSource::QueueDataSource(const sp<IStreamSource> &source) 236e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber : mSource(source), 237e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mPosition(0), 238e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mEOS(false) { 239e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mListener = new QueueListener(this); 240e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mSource->setListener(mListener); 241e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 24214acc736e336cbd6026df781d4f411e908831815Andreas Huber static const size_t kBufferSize = (8192 / 188) * 188; 243e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 244e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mDealer = new MemoryDealer(kNumBuffers * kBufferSize); 245e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber for (size_t i = 0; i < kNumBuffers; ++i) { 246e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber sp<IMemory> mem = mDealer->allocate(kBufferSize); 247e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber CHECK(mem != NULL); 248e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 249e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mBuffers.push(mem); 250e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 251e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mSource->setBuffers(mBuffers); 252e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 253e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber for (size_t i = 0; i < kNumBuffers; ++i) { 254e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mSource->onBufferAvailable(i); 255e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 256e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 257e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 258e2b1028852120bcfded33b8f06f66b780437fe92Andreas HuberQueueDataSource::~QueueDataSource() { 259e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 260e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 261e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mListener->clearOwner(); 262e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 263e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 264e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberstatus_t QueueDataSource::initCheck() const { 265e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber return OK; 266e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 267e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 268e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberssize_t QueueDataSource::readAt(off64_t offset, void *data, size_t size) { 269e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber if (offset != mPosition) { 270e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber return -EPIPE; 271e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 272e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 273e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 274e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 27514acc736e336cbd6026df781d4f411e908831815Andreas Huber if (mEOS) { 27614acc736e336cbd6026df781d4f411e908831815Andreas Huber return ERROR_END_OF_STREAM; 27714acc736e336cbd6026df781d4f411e908831815Andreas Huber } 27814acc736e336cbd6026df781d4f411e908831815Andreas Huber 279e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber size_t sizeDone = 0; 280e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 281e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber while (sizeDone < size) { 28214acc736e336cbd6026df781d4f411e908831815Andreas Huber while (mQueue.empty()) { 283e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mCondition.wait(mLock); 284e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 285e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 28614acc736e336cbd6026df781d4f411e908831815Andreas Huber QueueEntry &entry = *mQueue.begin(); 28714acc736e336cbd6026df781d4f411e908831815Andreas Huber 28814acc736e336cbd6026df781d4f411e908831815Andreas Huber if (entry.mIsCommand) { 28914acc736e336cbd6026df781d4f411e908831815Andreas Huber switch (entry.mCommand) { 29014acc736e336cbd6026df781d4f411e908831815Andreas Huber case IStreamListener::EOS: 29114acc736e336cbd6026df781d4f411e908831815Andreas Huber { 29214acc736e336cbd6026df781d4f411e908831815Andreas Huber mEOS = true; 29314acc736e336cbd6026df781d4f411e908831815Andreas Huber 29414acc736e336cbd6026df781d4f411e908831815Andreas Huber if (sizeDone > 0) { 29514acc736e336cbd6026df781d4f411e908831815Andreas Huber offset += sizeDone; 29614acc736e336cbd6026df781d4f411e908831815Andreas Huber return sizeDone; 29714acc736e336cbd6026df781d4f411e908831815Andreas Huber } else { 29814acc736e336cbd6026df781d4f411e908831815Andreas Huber return ERROR_END_OF_STREAM; 29914acc736e336cbd6026df781d4f411e908831815Andreas Huber } 30014acc736e336cbd6026df781d4f411e908831815Andreas Huber break; 30114acc736e336cbd6026df781d4f411e908831815Andreas Huber } 30214acc736e336cbd6026df781d4f411e908831815Andreas Huber 30314acc736e336cbd6026df781d4f411e908831815Andreas Huber case IStreamListener::DISCONTINUITY: 30414acc736e336cbd6026df781d4f411e908831815Andreas Huber { 30514acc736e336cbd6026df781d4f411e908831815Andreas Huber CHECK_EQ(size, 188u); 30614acc736e336cbd6026df781d4f411e908831815Andreas Huber CHECK_EQ(sizeDone, 0u); 30714acc736e336cbd6026df781d4f411e908831815Andreas Huber 30814acc736e336cbd6026df781d4f411e908831815Andreas Huber memset(data, 0, size); 30914acc736e336cbd6026df781d4f411e908831815Andreas Huber sizeDone = size; 31014acc736e336cbd6026df781d4f411e908831815Andreas Huber break; 31114acc736e336cbd6026df781d4f411e908831815Andreas Huber } 31214acc736e336cbd6026df781d4f411e908831815Andreas Huber 31314acc736e336cbd6026df781d4f411e908831815Andreas Huber default: 31414acc736e336cbd6026df781d4f411e908831815Andreas Huber break; 315e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 316e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 31714acc736e336cbd6026df781d4f411e908831815Andreas Huber mQueue.erase(mQueue.begin()); 31814acc736e336cbd6026df781d4f411e908831815Andreas Huber continue; 31914acc736e336cbd6026df781d4f411e908831815Andreas Huber } 320e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 321e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber size_t copy = size - sizeDone; 32214acc736e336cbd6026df781d4f411e908831815Andreas Huber if (copy > entry.mSize) { 32314acc736e336cbd6026df781d4f411e908831815Andreas Huber copy = entry.mSize; 324e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 325e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 326e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber memcpy((uint8_t *)data + sizeDone, 32714acc736e336cbd6026df781d4f411e908831815Andreas Huber (const uint8_t *)mBuffers.itemAt(entry.mIndex)->pointer() 32814acc736e336cbd6026df781d4f411e908831815Andreas Huber + entry.mOffset, 329e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber copy); 330e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 33114acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mSize -= copy; 33214acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mOffset += copy; 333e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber sizeDone += copy; 334e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 33514acc736e336cbd6026df781d4f411e908831815Andreas Huber if (entry.mSize == 0) { 33614acc736e336cbd6026df781d4f411e908831815Andreas Huber mSource->onBufferAvailable(entry.mIndex); 33714acc736e336cbd6026df781d4f411e908831815Andreas Huber mQueue.erase(mQueue.begin()); 338e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 339e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 340e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 341e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mPosition += sizeDone; 342e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 343e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber return sizeDone; 344e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 345e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 346e2b1028852120bcfded33b8f06f66b780437fe92Andreas Hubervoid QueueDataSource::queueBuffer(size_t index, size_t size) { 347e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 348e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 349e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber CHECK_LT(index, mBuffers.size()); 350e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber CHECK_LE(size, mBuffers.itemAt(index)->size()); 351e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 35214acc736e336cbd6026df781d4f411e908831815Andreas Huber QueueEntry entry; 35314acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mIsCommand = false; 35414acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mIndex = index; 35514acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mSize = size; 35614acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mOffset = 0; 357e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 35814acc736e336cbd6026df781d4f411e908831815Andreas Huber mQueue.push_back(entry); 359e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mCondition.signal(); 360e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 361e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 36214acc736e336cbd6026df781d4f411e908831815Andreas Hubervoid QueueDataSource::issueCommand( 36314acc736e336cbd6026df781d4f411e908831815Andreas Huber IStreamListener::Command cmd, 36414acc736e336cbd6026df781d4f411e908831815Andreas Huber bool synchronous, 36514acc736e336cbd6026df781d4f411e908831815Andreas Huber const sp<AMessage> &msg) { 366e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 367e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 36814acc736e336cbd6026df781d4f411e908831815Andreas Huber CHECK(!synchronous); 36914acc736e336cbd6026df781d4f411e908831815Andreas Huber 37014acc736e336cbd6026df781d4f411e908831815Andreas Huber QueueEntry entry; 37114acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mIsCommand = true; 37214acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mCommand = cmd; 37314acc736e336cbd6026df781d4f411e908831815Andreas Huber entry.mCommandMessage = msg; 37414acc736e336cbd6026df781d4f411e908831815Andreas Huber mQueue.push_back(entry); 37514acc736e336cbd6026df781d4f411e908831815Andreas Huber 37614acc736e336cbd6026df781d4f411e908831815Andreas Huber mCondition.signal(); 377e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 378e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 379e2b1028852120bcfded33b8f06f66b780437fe92Andreas Hubervoid QueueListener::clearOwner() { 380e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 381e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mOwner = NULL; 382e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 383e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 384e2b1028852120bcfded33b8f06f66b780437fe92Andreas Hubervoid QueueListener::queueBuffer(size_t index, size_t size) { 385e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 386e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber if (mOwner == NULL) { 387e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber return; 388e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 389e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber mOwner->queueBuffer(index, size); 390e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 391e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 39214acc736e336cbd6026df781d4f411e908831815Andreas Hubervoid QueueListener::issueCommand( 39314acc736e336cbd6026df781d4f411e908831815Andreas Huber Command cmd, bool synchronous, const sp<AMessage> &msg) { 394e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 395e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber if (mOwner == NULL) { 396e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber return; 397e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber } 39814acc736e336cbd6026df781d4f411e908831815Andreas Huber mOwner->issueCommand(cmd, synchronous, msg); 399e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 400e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 401e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber//////////////////////////////////////////////////////////////////////////////// 402e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 403bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas HuberAwesomePlayer::AwesomePlayer() 4042e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber : mQueueStarted(false), 4052e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber mTimeSource(NULL), 406fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber mVideoRendererIsPreview(false), 407bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mAudioPlayer(NULL), 408bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mFlags(0), 409acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber mExtractorFlags(0), 4107b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber mVideoBuffer(NULL), 411dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDecryptHandle(NULL) { 412e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber CHECK_EQ(mClient.connect(), (status_t)OK); 413bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 414bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber DataSource::RegisterDefaultSniffers(); 415bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 416c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mVideoEvent = new AwesomeEvent(this, &AwesomePlayer::onVideoEvent); 417bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoEventPending = false; 418c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mStreamDoneEvent = new AwesomeEvent(this, &AwesomePlayer::onStreamDone); 419bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mStreamDoneEventPending = false; 420c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mBufferingEvent = new AwesomeEvent(this, &AwesomePlayer::onBufferingUpdate); 42166b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber mBufferingEventPending = false; 422c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 423c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mCheckAudioStatusEvent = new AwesomeEvent( 424c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber this, &AwesomePlayer::onCheckAudioStatus); 425c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 4261862a33b246249630b654182afb5914da3480d4cAndreas Huber mAudioStatusEventPending = false; 427bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 428bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber reset(); 429bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 430bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 431bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas HuberAwesomePlayer::~AwesomePlayer() { 4322e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber if (mQueueStarted) { 4332e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber mQueue.stop(); 4342e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber } 435bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 436bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber reset(); 437bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 438bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mClient.disconnect(); 439bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 440bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 44166b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Hubervoid AwesomePlayer::cancelPlayerEvents(bool keepBufferingGoing) { 442bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mQueue.cancelEvent(mVideoEvent->eventID()); 443bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoEventPending = false; 444bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mQueue.cancelEvent(mStreamDoneEvent->eventID()); 445bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mStreamDoneEventPending = false; 4461862a33b246249630b654182afb5914da3480d4cAndreas Huber mQueue.cancelEvent(mCheckAudioStatusEvent->eventID()); 4471862a33b246249630b654182afb5914da3480d4cAndreas Huber mAudioStatusEventPending = false; 44866b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 44966b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber if (!keepBufferingGoing) { 45066b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber mQueue.cancelEvent(mBufferingEvent->eventID()); 45166b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber mBufferingEventPending = false; 45266b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber } 453bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 454bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 4550726045216f576e97672ebeefc265d39c4ebaaa5Andreas Hubervoid AwesomePlayer::setListener(const wp<MediaPlayerBase> &listener) { 456bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 457bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mListener = listener; 458bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 459bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 4605561ccf4a8db88a2e44eac1b3ed13b4ff53a7f20Andreas Huberstatus_t AwesomePlayer::setDataSource( 4615561ccf4a8db88a2e44eac1b3ed13b4ff53a7f20Andreas Huber const char *uri, const KeyedVector<String8, String8> *headers) { 462bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 4637b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber return setDataSource_l(uri, headers); 4647b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber} 465bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 4667b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huberstatus_t AwesomePlayer::setDataSource_l( 4677b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber const char *uri, const KeyedVector<String8, String8> *headers) { 468bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber reset_l(); 469bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 470bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mUri = uri; 47166b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 472e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber if (!strncmp("http://", uri, 7)) { 473e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber // Hack to support http live. 474e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber 475e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber size_t len = strlen(uri); 476decd96988e495133e4a1728f612d4c9fdb4d218eAndreas Huber if (!strcasecmp(&uri[len - 5], ".m3u8") 477decd96988e495133e4a1728f612d4c9fdb4d218eAndreas Huber || strstr(&uri[7], "m3u8") != NULL) { 478e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber mUri = "httplive://"; 479e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber mUri.append(&uri[7]); 480e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber } 481e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber } 482e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber 483bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (headers) { 484bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mUriHeaders = *headers; 48566b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber } 48666b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 487bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber // The actual work will be done during preparation in the call to 488bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber // ::finishSetDataSource_l to avoid blocking the calling thread in 489bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber // setDataSource for any significant time. 49066b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 491bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return OK; 492bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 493bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 494bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::setDataSource( 495bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber int fd, int64_t offset, int64_t length) { 496bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 497bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 498bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber reset_l(); 499bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 5007b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber sp<DataSource> dataSource = new FileSource(fd, offset, length); 501bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 5027b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber status_t err = dataSource->initCheck(); 503bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 504bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (err != OK) { 505bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return err; 506bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 507bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 5087b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber mFileSource = dataSource; 5097b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 5107b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber return setDataSource_l(dataSource); 5117b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber} 5127b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 513e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huberstatus_t AwesomePlayer::setDataSource(const sp<IStreamSource> &source) { 514e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber Mutex::Autolock autoLock(mLock); 515e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 516e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber reset_l(); 517e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 518e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber sp<DataSource> dataSource = new QueueDataSource(source); 51914acc736e336cbd6026df781d4f411e908831815Andreas Huber sp<MediaExtractor> extractor = new MPEG2TSExtractor(dataSource); 520e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 521e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber return setDataSource_l(extractor); 522e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber} 523e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber 5247b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huberstatus_t AwesomePlayer::setDataSource_l( 5257b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber const sp<DataSource> &dataSource) { 5267b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber sp<MediaExtractor> extractor = MediaExtractor::Create(dataSource); 527bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 528bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (extractor == NULL) { 529bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return UNKNOWN_ERROR; 530bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 531bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 532dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang dataSource->getDrmInfo(&mDecryptHandle, &mDrmManagerClient); 53355426ce7eded04c9993149edd86f861cfccb4d19Gloria Wang if (mDecryptHandle != NULL 53455426ce7eded04c9993149edd86f861cfccb4d19Gloria Wang && RightsStatus::RIGHTS_VALID != mDecryptHandle->status) { 53555426ce7eded04c9993149edd86f861cfccb4d19Gloria Wang notifyListener_l(MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, ERROR_NO_LICENSE); 536dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang } 537dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang 538bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return setDataSource_l(extractor); 539bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 540bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 541bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::setDataSource_l(const sp<MediaExtractor> &extractor) { 5427fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber // Attempt to approximate overall stream bitrate by summing all 5437fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber // tracks' individual bitrates, if not all of them advertise bitrate, 5447fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber // we have to fail. 5457fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 5467fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber int64_t totalBitRate = 0; 5477fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 5487fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber for (size_t i = 0; i < extractor->countTracks(); ++i) { 5497fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber sp<MetaData> meta = extractor->getTrackMetaData(i); 5507fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 5517fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber int32_t bitrate; 5527fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber if (!meta->findInt32(kKeyBitRate, &bitrate)) { 5537fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber totalBitRate = -1; 5547fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber break; 5557fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber } 5567fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 5577fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber totalBitRate += bitrate; 5587fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber } 5597fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 5607fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber mBitrate = totalBitRate; 5617fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 5627fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber LOGV("mBitrate = %lld bits/sec", mBitrate); 5637fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 564bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber bool haveAudio = false; 565bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber bool haveVideo = false; 566bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber for (size_t i = 0; i < extractor->countTracks(); ++i) { 567bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber sp<MetaData> meta = extractor->getTrackMetaData(i); 568bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 569bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber const char *mime; 570bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber CHECK(meta->findCString(kKeyMIMEType, &mime)); 571bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 572bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (!haveVideo && !strncasecmp(mime, "video/", 6)) { 57388d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber setVideoSource(extractor->getTrack(i)); 57488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber haveVideo = true; 575bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } else if (!haveAudio && !strncasecmp(mime, "audio/", 6)) { 57688d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber setAudioSource(extractor->getTrack(i)); 57788d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber haveAudio = true; 5788ae49d87b98d57d6758b0c51b95e28a6581a79f1Andreas Huber 5796954535ba64374e4e941cd83019a7af53edfb098Andreas Huber if (!strcasecmp(mime, MEDIA_MIMETYPE_AUDIO_VORBIS)) { 5806954535ba64374e4e941cd83019a7af53edfb098Andreas Huber // Only do this for vorbis audio, none of the other audio 5816954535ba64374e4e941cd83019a7af53edfb098Andreas Huber // formats even support this ringtone specific hack and 5826954535ba64374e4e941cd83019a7af53edfb098Andreas Huber // retrieving the metadata on some extractors may turn out 5836954535ba64374e4e941cd83019a7af53edfb098Andreas Huber // to be very expensive. 5846954535ba64374e4e941cd83019a7af53edfb098Andreas Huber sp<MetaData> fileMeta = extractor->getMetaData(); 5856954535ba64374e4e941cd83019a7af53edfb098Andreas Huber int32_t loop; 5866954535ba64374e4e941cd83019a7af53edfb098Andreas Huber if (fileMeta != NULL 5876954535ba64374e4e941cd83019a7af53edfb098Andreas Huber && fileMeta->findInt32(kKeyAutoLoop, &loop) && loop != 0) { 5886954535ba64374e4e941cd83019a7af53edfb098Andreas Huber mFlags |= AUTO_LOOPING; 5896954535ba64374e4e941cd83019a7af53edfb098Andreas Huber } 5908ae49d87b98d57d6758b0c51b95e28a6581a79f1Andreas Huber } 591bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 592bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 593bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (haveAudio && haveVideo) { 594bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber break; 595bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 596bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 597bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 598acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber if (!haveAudio && !haveVideo) { 599acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber return UNKNOWN_ERROR; 600acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber } 601acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber 602acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber mExtractorFlags = extractor->flags(); 603acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber 604acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber return OK; 605bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 606bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 607bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::reset() { 608bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 609bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber reset_l(); 610bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 611bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 612bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::reset_l() { 613dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang if (mDecryptHandle != NULL) { 614dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 615dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang Playback::STOP, 0); 616b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang mDrmManagerClient->closeDecryptSession(mDecryptHandle); 617dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDecryptHandle = NULL; 618dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDrmManagerClient = NULL; 619dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang } 620dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang 621e94bd14078d327ef2f800e69907efce641a13272Andreas Huber if (mFlags & PREPARING) { 622e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mFlags |= PREPARE_CANCELLED; 623e94bd14078d327ef2f800e69907efce641a13272Andreas Huber if (mConnectingDataSource != NULL) { 624e94bd14078d327ef2f800e69907efce641a13272Andreas Huber LOGI("interrupting the connection process"); 625e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mConnectingDataSource->disconnect(); 626e94bd14078d327ef2f800e69907efce641a13272Andreas Huber } 6276a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber 6286a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber if (mFlags & PREPARING_CONNECTED) { 6296a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber // We are basically done preparing, we're just buffering 6306a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber // enough data to start playback, we can safely interrupt that. 6316a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber finishAsyncPrepare_l(); 6326a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber } 633e94bd14078d327ef2f800e69907efce641a13272Andreas Huber } 634e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 635bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber while (mFlags & PREPARING) { 636bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mPreparedCondition.wait(mLock); 637bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 638bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 639bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber cancelPlayerEvents(); 640bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 6410a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mCachedSource.clear(); 64288d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mAudioTrack.clear(); 64388d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mVideoTrack.clear(); 64488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber 6457b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // Shutdown audio first, so that the respone to the reset request 6467b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // appears to happen instantaneously as far as the user is concerned 6477b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // If we did this later, audio would continue playing while we 6487b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // shutdown the video-related resources and the player appear to 6497b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // not be as responsive to a reset request. 650e94bd14078d327ef2f800e69907efce641a13272Andreas Huber if (mAudioPlayer == NULL && mAudioSource != NULL) { 651e94bd14078d327ef2f800e69907efce641a13272Andreas Huber // If we had an audio player, it would have effectively 652e94bd14078d327ef2f800e69907efce641a13272Andreas Huber // taken possession of the audio source and stopped it when 653e94bd14078d327ef2f800e69907efce641a13272Andreas Huber // _it_ is stopped. Otherwise this is still our responsibility. 654e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mAudioSource->stop(); 655e94bd14078d327ef2f800e69907efce641a13272Andreas Huber } 6567b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber mAudioSource.clear(); 6577b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 6587b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber mTimeSource = NULL; 6597b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 6607b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber delete mAudioPlayer; 6617b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber mAudioPlayer = NULL; 6627b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 663b9280d5c2313c41eb490f58198c4e59118e0e3e6Andreas Huber mVideoRenderer.clear(); 664b9280d5c2313c41eb490f58198c4e59118e0e3e6Andreas Huber 665bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mVideoBuffer) { 666bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer->release(); 667bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer = NULL; 668bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 669bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 670cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber if (mRTSPController != NULL) { 671cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber mRTSPController->disconnect(); 672cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber mRTSPController.clear(); 673cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber } 674cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber 675a44153c1a57202fb538659eb50706e60454d6273Andreas Huber if (mLiveSession != NULL) { 676a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLiveSession->disconnect(); 677a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLiveSession.clear(); 678a44153c1a57202fb538659eb50706e60454d6273Andreas Huber } 679a44153c1a57202fb538659eb50706e60454d6273Andreas Huber 68039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTPPusher.clear(); 68139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTCPPusher.clear(); 68239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTPSession.clear(); 683cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber 684bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mVideoSource != NULL) { 685bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoSource->stop(); 68669f5f4c021ee55055df39718244c036faf2d3382Andreas Huber 68769f5f4c021ee55055df39718244c036faf2d3382Andreas Huber // The following hack is necessary to ensure that the OMX 68869f5f4c021ee55055df39718244c036faf2d3382Andreas Huber // component is completely released by the time we may try 68969f5f4c021ee55055df39718244c036faf2d3382Andreas Huber // to instantiate it again. 69069f5f4c021ee55055df39718244c036faf2d3382Andreas Huber wp<MediaSource> tmp = mVideoSource; 691bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoSource.clear(); 69269f5f4c021ee55055df39718244c036faf2d3382Andreas Huber while (tmp.promote() != NULL) { 69369f5f4c021ee55055df39718244c036faf2d3382Andreas Huber usleep(1000); 69469f5f4c021ee55055df39718244c036faf2d3382Andreas Huber } 69569f5f4c021ee55055df39718244c036faf2d3382Andreas Huber IPCThreadState::self()->flushCommands(); 696bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 697bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 698bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mDurationUs = -1; 699bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags = 0; 700acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber mExtractorFlags = 0; 701bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mTimeSourceDeltaUs = 0; 702bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoTimeUs = 0; 703bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 704bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mSeeking = false; 7051321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber mSeekNotificationSent = false; 706bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mSeekTimeUs = 0; 70766b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 708bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mUri.setTo(""); 709bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mUriHeaders.clear(); 7107b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 7117b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber mFileSource.clear(); 7127b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber 7137fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber mBitrate = -1; 714bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 715bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 716c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Hubervoid AwesomePlayer::notifyListener_l(int msg, int ext1, int ext2) { 7170726045216f576e97672ebeefc265d39c4ebaaa5Andreas Huber if (mListener != NULL) { 7180726045216f576e97672ebeefc265d39c4ebaaa5Andreas Huber sp<MediaPlayerBase> listener = mListener.promote(); 7190726045216f576e97672ebeefc265d39c4ebaaa5Andreas Huber 7200726045216f576e97672ebeefc265d39c4ebaaa5Andreas Huber if (listener != NULL) { 721c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber listener->sendEvent(msg, ext1, ext2); 72266b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber } 72366b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber } 72466b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber} 72566b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 7267fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huberbool AwesomePlayer::getBitrate(int64_t *bitrate) { 727c7fc37a3dab9bd1f96713649f351b5990e6316ffJames Dong off64_t size; 7287fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber if (mDurationUs >= 0 && mCachedSource != NULL 7297fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber && mCachedSource->getSize(&size) == OK) { 7307fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber *bitrate = size * 8000000ll / mDurationUs; // in bits/sec 7317fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber return true; 7327fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber } 7337fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 7347fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber if (mBitrate >= 0) { 7357fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber *bitrate = mBitrate; 7367fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber return true; 7377fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber } 7387fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 7397fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber *bitrate = 0; 7407fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 7417fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber return false; 7427fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber} 7437fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber 7448650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber// Returns true iff cached duration is available/applicable. 7458650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huberbool AwesomePlayer::getCachedDuration_l(int64_t *durationUs, bool *eos) { 7467fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber int64_t bitrate; 7478650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber 7488650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mRTSPController != NULL) { 7498650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber *durationUs = mRTSPController->getQueueDurationUs(eos); 7508650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return true; 7517fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber } else if (mCachedSource != NULL && getBitrate(&bitrate)) { 7528650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber size_t cachedDataRemaining = mCachedSource->approxDataRemaining(eos); 7538650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber *durationUs = cachedDataRemaining * 8000000ll / bitrate; 7548650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return true; 7558650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 7568650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber 7578650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return false; 7588650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber} 7598650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber 76034ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Hubervoid AwesomePlayer::ensureCacheIsFetching_l() { 76134ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber if (mCachedSource != NULL) { 76234ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber mCachedSource->resumeFetchingIfNecessary(); 76334ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber } 76434ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber} 76534ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber 76666b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Hubervoid AwesomePlayer::onBufferingUpdate() { 76766b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber Mutex::Autolock autoLock(mLock); 768d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber if (!mBufferingEventPending) { 769d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber return; 770d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber } 77166b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber mBufferingEventPending = false; 77266b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 7738650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mCachedSource != NULL) { 774c9e894872c298b25fe9d74e68aa1e7287a541ac3Andreas Huber bool eos; 7758650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber size_t cachedDataRemaining = mCachedSource->approxDataRemaining(&eos); 776c9e894872c298b25fe9d74e68aa1e7287a541ac3Andreas Huber 7778650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (eos) { 7788650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber notifyListener_l(MEDIA_BUFFERING_UPDATE, 100); 77983977eb230d829cfe520f55d7977037a904ce548Andreas Huber if (mFlags & PREPARING) { 78083977eb230d829cfe520f55d7977037a904ce548Andreas Huber LOGV("cache has reached EOS, prepare is done."); 78183977eb230d829cfe520f55d7977037a904ce548Andreas Huber finishAsyncPrepare_l(); 78283977eb230d829cfe520f55d7977037a904ce548Andreas Huber } 7838650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else { 7847fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber int64_t bitrate; 7857fbdb0903dfbf70b314a74e64e28fb880cdb9247Andreas Huber if (getBitrate(&bitrate)) { 7868650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber size_t cachedSize = mCachedSource->cachedSize(); 7878650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber int64_t cachedDurationUs = cachedSize * 8000000ll / bitrate; 788c9e894872c298b25fe9d74e68aa1e7287a541ac3Andreas Huber 7898650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber int percentage = 100.0 * (double)cachedDurationUs / mDurationUs; 7908650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (percentage > 100) { 7918650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber percentage = 100; 7928650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 793c9e894872c298b25fe9d74e68aa1e7287a541ac3Andreas Huber 7948650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber notifyListener_l(MEDIA_BUFFERING_UPDATE, percentage); 7958650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else { 7968650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber // We don't know the bitrate of the stream, use absolute size 7978650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber // limits to maintain the cache. 7988650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber 799bff07d0b22a5ee2d9f044f6cb5e4be1532017ab0Andreas Huber const size_t kLowWaterMarkBytes = 40000; 800bff07d0b22a5ee2d9f044f6cb5e4be1532017ab0Andreas Huber const size_t kHighWaterMarkBytes = 200000; 8018650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber 8028650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if ((mFlags & PLAYING) && !eos 8038650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber && (cachedDataRemaining < kLowWaterMarkBytes)) { 8048650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGI("cache is running low (< %d) , pausing.", 8058650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber kLowWaterMarkBytes); 8068650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber mFlags |= CACHE_UNDERRUN; 8078650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber pause_l(); 80834ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber ensureCacheIsFetching_l(); 8098650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber notifyListener_l(MEDIA_INFO, MEDIA_INFO_BUFFERING_START); 8108650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else if (eos || cachedDataRemaining > kHighWaterMarkBytes) { 8118650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mFlags & CACHE_UNDERRUN) { 8128650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGI("cache has filled up (> %d), resuming.", 8138650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber kHighWaterMarkBytes); 8148650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber mFlags &= ~CACHE_UNDERRUN; 8158650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber play_l(); 8168650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber notifyListener_l(MEDIA_INFO, MEDIA_INFO_BUFFERING_END); 8178650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else if (mFlags & PREPARING) { 8188650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGV("cache has filled up (> %d), prepare is done", 8198650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber kHighWaterMarkBytes); 8208650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber finishAsyncPrepare_l(); 8218650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 8228650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 8238650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 8248650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 8252415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber } 8262415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber 8278650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber int64_t cachedDurationUs; 8282a4b49bd3863024884a694b454e2e452752e6ea0Andreas Huber bool eos; 8298650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (getCachedDuration_l(&cachedDurationUs, &eos)) { 83034ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber LOGV("cachedDurationUs = %.2f secs, eos=%d", 83134ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber cachedDurationUs / 1E6, eos); 83234ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber 8338650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if ((mFlags & PLAYING) && !eos 8348650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber && (cachedDurationUs < kLowWaterMarkUs)) { 8358650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGI("cache is running low (%.2f secs) , pausing.", 8368650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber cachedDurationUs / 1E6); 8378650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber mFlags |= CACHE_UNDERRUN; 8388650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber pause_l(); 83934ef0f32c8fc0186236a27e07405328cc1f7c56dAndreas Huber ensureCacheIsFetching_l(); 8408650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber notifyListener_l(MEDIA_INFO, MEDIA_INFO_BUFFERING_START); 8418650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else if (eos || cachedDurationUs > kHighWaterMarkUs) { 8428650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mFlags & CACHE_UNDERRUN) { 8438650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGI("cache has filled up (%.2f secs), resuming.", 8448650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber cachedDurationUs / 1E6); 8458650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber mFlags &= ~CACHE_UNDERRUN; 8468650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber play_l(); 8478650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber notifyListener_l(MEDIA_INFO, MEDIA_INFO_BUFFERING_END); 8488650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else if (mFlags & PREPARING) { 8498650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGV("cache has filled up (%.2f secs), prepare is done", 8508650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber cachedDurationUs / 1E6); 8518650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber finishAsyncPrepare_l(); 8522a4b49bd3863024884a694b454e2e452752e6ea0Andreas Huber } 8532a4b49bd3863024884a694b454e2e452752e6ea0Andreas Huber } 8540a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber } 8550a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 8560a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber postBufferingEvent_l(); 8570726045216f576e97672ebeefc265d39c4ebaaa5Andreas Huber} 8580726045216f576e97672ebeefc265d39c4ebaaa5Andreas Huber 8592a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Hubervoid AwesomePlayer::partial_reset_l() { 8602a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // Only reset the video renderer and shut down the video decoder. 8612a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // Then instantiate a new video decoder and resume video playback. 8622a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 8632a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber mVideoRenderer.clear(); 8642a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 8652a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber if (mVideoBuffer) { 8662a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber mVideoBuffer->release(); 8672a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber mVideoBuffer = NULL; 8682a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber } 8692a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 8702a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber { 8712a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber mVideoSource->stop(); 8722a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 8732a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // The following hack is necessary to ensure that the OMX 8742a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // component is completely released by the time we may try 8752a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // to instantiate it again. 8762a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber wp<MediaSource> tmp = mVideoSource; 8772a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber mVideoSource.clear(); 8782a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber while (tmp.promote() != NULL) { 8792a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber usleep(1000); 8802a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber } 8812a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber IPCThreadState::self()->flushCommands(); 8822a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber } 8832a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 884e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber CHECK_EQ((status_t)OK, 885e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber initVideoDecoder(OMXCodec::kIgnoreCodecSpecificData)); 8862a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber} 8872a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 888bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::onStreamDone() { 889bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber // Posted whenever any stream finishes playing. 890bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 891bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 892d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber if (!mStreamDoneEventPending) { 893d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber return; 894d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber } 895bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mStreamDoneEventPending = false; 896bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 8972a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber if (mStreamDoneStatus == INFO_DISCONTINUITY) { 8982a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // This special status is returned because an http live stream's 8992a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // video stream switched to a different bandwidth at this point 9002a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // and future data may have been encoded using different parameters. 9012a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // This requires us to shutdown the video decoder and reinstantiate 9022a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber // a fresh one. 9032a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 9042a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber LOGV("INFO_DISCONTINUITY"); 9052a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 9062a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber CHECK(mVideoSource != NULL); 9072a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber 9082a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber partial_reset_l(); 9092a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber postVideoEvent_l(); 9102a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber return; 9112a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huber } else if (mStreamDoneStatus != ERROR_END_OF_STREAM) { 9125d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber LOGV("MEDIA_ERROR %d", mStreamDoneStatus); 9135d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 9145d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber notifyListener_l( 9155d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, mStreamDoneStatus); 9165d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 917b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber pause_l(true /* at eos */); 9185d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 9195d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mFlags |= AT_EOS; 9205d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber return; 9215d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber } 9225d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 9235d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber const bool allDone = 9245d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber (mVideoSource == NULL || (mFlags & VIDEO_AT_EOS)) 9255d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber && (mAudioSource == NULL || (mFlags & AUDIO_AT_EOS)); 9265d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 9275d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber if (!allDone) { 9285d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber return; 9295d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber } 9305d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 9318ae49d87b98d57d6758b0c51b95e28a6581a79f1Andreas Huber if (mFlags & (LOOPING | AUTO_LOOPING)) { 932bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber seekTo_l(0); 933bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 934a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber if (mVideoSource != NULL) { 935bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber postVideoEvent_l(); 936bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 937bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } else { 9385d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber LOGV("MEDIA_PLAYBACK_COMPLETE"); 9395d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber notifyListener_l(MEDIA_PLAYBACK_COMPLETE); 940bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 941b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber pause_l(true /* at eos */); 9422e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber 9432e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber mFlags |= AT_EOS; 944bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 945bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 946bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 947bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::play() { 948bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 9490a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 9500a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mFlags &= ~CACHE_UNDERRUN; 9510a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 9527b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber return play_l(); 9537b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber} 954bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 9557b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huberstatus_t AwesomePlayer::play_l() { 956bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mFlags & PLAYING) { 957bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 958bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 959bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 960bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (!(mFlags & PREPARED)) { 961bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber status_t err = prepare_l(); 962bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 963bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (err != OK) { 964bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return err; 965bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 966bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 967bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 968bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags |= PLAYING; 969bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags |= FIRST_FRAME; 970bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 971fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber bool deferredAudioSeek = false; 972fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber 973c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang if (mDecryptHandle != NULL) { 974c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang int64_t position; 975c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang getPosition(&position); 976c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 977c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang Playback::START, position / 1000); 978c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang } 979c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang 980bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mAudioSource != NULL) { 981bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mAudioPlayer == NULL) { 982bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mAudioSink != NULL) { 983ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber mAudioPlayer = new AudioPlayer(mAudioSink, this); 984bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mAudioPlayer->setSource(mAudioSource); 985e7e3b785a0e7819db4c895a4f60e9a4dd755880cAndreas Huber 986e7e3b785a0e7819db4c895a4f60e9a4dd755880cAndreas Huber // We've already started the MediaSource in order to enable 987e7e3b785a0e7819db4c895a4f60e9a4dd755880cAndreas Huber // the prefetcher to read its data. 988e7e3b785a0e7819db4c895a4f60e9a4dd755880cAndreas Huber status_t err = mAudioPlayer->start( 989e7e3b785a0e7819db4c895a4f60e9a4dd755880cAndreas Huber true /* sourceAlreadyStarted */); 99088c030e0e0152791ff74f90249f55fce01371198Andreas Huber 99188c030e0e0152791ff74f90249f55fce01371198Andreas Huber if (err != OK) { 99288c030e0e0152791ff74f90249f55fce01371198Andreas Huber delete mAudioPlayer; 99388c030e0e0152791ff74f90249f55fce01371198Andreas Huber mAudioPlayer = NULL; 99488c030e0e0152791ff74f90249f55fce01371198Andreas Huber 99588c030e0e0152791ff74f90249f55fce01371198Andreas Huber mFlags &= ~(PLAYING | FIRST_FRAME); 99688c030e0e0152791ff74f90249f55fce01371198Andreas Huber 997c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang if (mDecryptHandle != NULL) { 998c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 999c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang Playback::STOP, 0); 1000c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang } 1001c130b5bf563d049bd391ccd96985ac278ef8ff8dGloria Wang 100288c030e0e0152791ff74f90249f55fce01371198Andreas Huber return err; 100388c030e0e0152791ff74f90249f55fce01371198Andreas Huber } 1004bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1005bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mTimeSource = mAudioPlayer; 1006bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1007fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber deferredAudioSeek = true; 10081862a33b246249630b654182afb5914da3480d4cAndreas Huber 10091862a33b246249630b654182afb5914da3480d4cAndreas Huber mWatchForAudioSeekComplete = false; 10101862a33b246249630b654182afb5914da3480d4cAndreas Huber mWatchForAudioEOS = true; 1011bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1012bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } else { 1013bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mAudioPlayer->resume(); 1014bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1015bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1016bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1017bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mTimeSource == NULL && mAudioPlayer == NULL) { 10185d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mTimeSource = &mSystemTimeSource; 1019bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1020bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1021bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mVideoSource != NULL) { 1022a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber // Kick off video playback 1023a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber postVideoEvent_l(); 1024bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1025bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1026fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber if (deferredAudioSeek) { 1027fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber // If there was a seek request while we were paused 1028fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber // and we're just starting up again, honor the request now. 1029fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber seekAudioIfNecessary_l(); 1030fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber } 1031fd4a8e09a54469bbccea6248f84319a1eb78765eAndreas Huber 10322e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber if (mFlags & AT_EOS) { 10332e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber // Legacy behaviour, if a stream finishes playing and then 10342e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber // is started again, we play from the start... 10352e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber seekTo_l(0); 10362e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber } 10372e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber 1038bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1039bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1040bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 10415daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Hubervoid AwesomePlayer::notifyVideoSize_l() { 10425daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber sp<MetaData> meta = mVideoSource->getFormat(); 10435daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber 1044f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber int32_t cropLeft, cropTop, cropRight, cropBottom; 1045f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber if (!meta->findRect( 1046f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber kKeyCropRect, &cropLeft, &cropTop, &cropRight, &cropBottom)) { 1047f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber int32_t width, height; 1048f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber CHECK(meta->findInt32(kKeyWidth, &width)); 1049f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber CHECK(meta->findInt32(kKeyHeight, &height)); 1050f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber 1051f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber cropLeft = cropTop = 0; 1052f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber cropRight = width - 1; 1053f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber cropBottom = height - 1; 1054f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber 1055f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber LOGV("got dimensions only %d x %d", width, height); 1056f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber } else { 1057f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber LOGV("got crop rect %d, %d, %d, %d", 1058f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber cropLeft, cropTop, cropRight, cropBottom); 1059f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber } 1060f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber 1061f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber int32_t usableWidth = cropRight - cropLeft + 1; 1062f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber int32_t usableHeight = cropBottom - cropTop + 1; 10635daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber 1064ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber int32_t rotationDegrees; 1065ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber if (!mVideoTrack->getFormat()->findInt32( 1066ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber kKeyRotation, &rotationDegrees)) { 1067ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber rotationDegrees = 0; 1068ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } 1069ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber 1070ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber if (rotationDegrees == 90 || rotationDegrees == 270) { 1071ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber notifyListener_l( 1072f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber MEDIA_SET_VIDEO_SIZE, usableHeight, usableWidth); 1073ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } else { 1074ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber notifyListener_l( 1075f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber MEDIA_SET_VIDEO_SIZE, usableWidth, usableHeight); 1076ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } 10775daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber} 10785daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber 1079bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::initRenderer_l() { 10800a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber if (mSurface == NULL) { 10810a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber return; 10820a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber } 1083bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 10840a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber sp<MetaData> meta = mVideoSource->getFormat(); 1085bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 10860a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber int32_t format; 10870a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber const char *component; 10880a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber int32_t decodedWidth, decodedHeight; 10890a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber CHECK(meta->findInt32(kKeyColorFormat, &format)); 10900a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber CHECK(meta->findCString(kKeyDecoderComponent, &component)); 10910a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber CHECK(meta->findInt32(kKeyWidth, &decodedWidth)); 10920a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber CHECK(meta->findInt32(kKeyHeight, &decodedHeight)); 10934844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber 1094ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber int32_t rotationDegrees; 1095ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber if (!mVideoTrack->getFormat()->findInt32( 1096ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber kKeyRotation, &rotationDegrees)) { 1097ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber rotationDegrees = 0; 1098ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber } 1099ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber 11000a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber mVideoRenderer.clear(); 11014844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber 11020a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // Must ensure that mVideoRenderer's destructor is actually executed 11030a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // before creating a new one. 11040a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber IPCThreadState::self()->flushCommands(); 11050a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber 11060a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber if (USE_SURFACE_ALLOC && strncmp(component, "OMX.", 4) == 0) { 11070a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // Hardware decoders avoid the CPU color conversion by decoding 11080a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // directly to ANativeBuffers, so we must use a renderer that 11090a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // just pushes those buffers to the ANativeWindow. 1110ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber mVideoRenderer = 1111ba529e486dde15fe75ea1b48570f9d60a4cf3c48Andreas Huber new AwesomeNativeWindowRenderer(mSurface, rotationDegrees); 11120a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber } else { 11130a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // Other decoders are instantiated locally and as a consequence 11140a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // allocate their buffers in local address space. This renderer 11150a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // then performs a color conversion and copy to get the data 11160a5ca668c6f7d45706e9aec4a1dfec0aacc6d233Andreas Huber // into the ANativeBuffer. 1117f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber mVideoRenderer = new AwesomeLocalRenderer(mSurface, meta); 1118bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1119bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1120bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1121bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::pause() { 1122bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 11230a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 11240a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mFlags &= ~CACHE_UNDERRUN; 11250a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 1126bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return pause_l(); 1127bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1128bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1129b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huberstatus_t AwesomePlayer::pause_l(bool at_eos) { 1130bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (!(mFlags & PLAYING)) { 1131bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1132bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1133bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 113466b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber cancelPlayerEvents(true /* keepBufferingGoing */); 1135bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1136bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mAudioPlayer != NULL) { 1137b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber if (at_eos) { 1138b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber // If we played the audio stream to completion we 1139b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber // want to make sure that all samples remaining in the audio 1140b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber // track's queue are played out. 1141b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber mAudioPlayer->pause(true /* playPendingSamples */); 1142b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber } else { 1143b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber mAudioPlayer->pause(); 1144b2e3954c94717e43b3dc9b880564f166cfbbc0a2Andreas Huber } 1145bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1146bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1147bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags &= ~PLAYING; 1148bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1149dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang if (mDecryptHandle != NULL) { 1150dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 1151dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang Playback::PAUSE, 0); 1152dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang } 1153dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang 1154bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1155bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1156bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1157bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberbool AwesomePlayer::isPlaying() const { 11580a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber return (mFlags & PLAYING) || (mFlags & CACHE_UNDERRUN); 1159bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1160bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 11615daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Hubervoid AwesomePlayer::setSurface(const sp<Surface> &surface) { 11625daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber Mutex::Autolock autoLock(mLock); 11635daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber 11645daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber mSurface = surface; 11655daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber} 11665daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber 1167bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::setAudioSink( 1168bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber const sp<MediaPlayerBase::AudioSink> &audioSink) { 1169bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 1170bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1171bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mAudioSink = audioSink; 1172bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1173bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1174bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::setLooping(bool shouldLoop) { 1175bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 1176bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1177bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags = mFlags & ~LOOPING; 1178bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1179bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (shouldLoop) { 1180bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags |= LOOPING; 1181bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1182bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1183bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1184bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1185bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1186bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::getDuration(int64_t *durationUs) { 11872415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber Mutex::Autolock autoLock(mMiscStateLock); 1188bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1189bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mDurationUs < 0) { 1190bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return UNKNOWN_ERROR; 1191bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1192bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1193bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber *durationUs = mDurationUs; 1194bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1195bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1196bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1197bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1198bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::getPosition(int64_t *positionUs) { 11998d342970108926c4ea355c90d26a2a353ec0fd47Andreas Huber if (mRTSPController != NULL) { 12008d342970108926c4ea355c90d26a2a353ec0fd47Andreas Huber *positionUs = mRTSPController->getNormalPlayTimeUs(); 12018d342970108926c4ea355c90d26a2a353ec0fd47Andreas Huber } 12028d342970108926c4ea355c90d26a2a353ec0fd47Andreas Huber else if (mSeeking) { 1203dac4ee72bac87388a1495e098f39d73168c8078fAndreas Huber *positionUs = mSeekTimeUs; 1204dac4ee72bac87388a1495e098f39d73168c8078fAndreas Huber } else if (mVideoSource != NULL) { 12052415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber Mutex::Autolock autoLock(mMiscStateLock); 1206bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber *positionUs = mVideoTimeUs; 1207bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } else if (mAudioPlayer != NULL) { 1208bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber *positionUs = mAudioPlayer->getMediaTimeUs(); 1209bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } else { 1210bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber *positionUs = 0; 1211bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1212bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1213bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1214bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1215bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1216bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::seekTo(int64_t timeUs) { 121770f521de2675ce6eedf4b22beed94ea1289b0f38Andreas Huber if (mExtractorFlags & MediaExtractor::CAN_SEEK) { 1218acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber Mutex::Autolock autoLock(mLock); 1219acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber return seekTo_l(timeUs); 1220acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber } 1221acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber 1222acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber return OK; 1223bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1224bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 12250dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber// static 12260dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Hubervoid AwesomePlayer::OnRTSPSeekDoneWrapper(void *cookie) { 12270dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber static_cast<AwesomePlayer *>(cookie)->onRTSPSeekDone(); 12280dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber} 12290dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber 12300dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Hubervoid AwesomePlayer::onRTSPSeekDone() { 12310dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber notifyListener_l(MEDIA_SEEK_COMPLETE); 12320dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber mSeekNotificationSent = true; 12330dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber} 12340dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber 1235bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huberstatus_t AwesomePlayer::seekTo_l(int64_t timeUs) { 1236cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber if (mRTSPController != NULL) { 12370dcd837af4169bdb6fb2a0c384722dc4f57433c6Andreas Huber mRTSPController->seekAsync(timeUs, OnRTSPSeekDoneWrapper, this); 1238cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber return OK; 1239cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber } 1240cce326fe43411855aca2f719e505b051bc4b61b3Andreas Huber 12410a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber if (mFlags & CACHE_UNDERRUN) { 12420a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mFlags &= ~CACHE_UNDERRUN; 12430a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber play_l(); 12440a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber } 12450a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 1246bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mSeeking = true; 12471321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber mSeekNotificationSent = false; 1248bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mSeekTimeUs = timeUs; 12495d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mFlags &= ~(AT_EOS | AUDIO_AT_EOS | VIDEO_AT_EOS); 1250bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1251bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber seekAudioIfNecessary_l(); 1252bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 12531321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber if (!(mFlags & PLAYING)) { 12541321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber LOGV("seeking while paused, sending SEEK_COMPLETE notification" 12551321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber " immediately."); 12561321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber 12571321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber notifyListener_l(MEDIA_SEEK_COMPLETE); 12581321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber mSeekNotificationSent = true; 12591321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber } 12601321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber 1261bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return OK; 1262bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1263bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1264bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::seekAudioIfNecessary_l() { 1265a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber if (mSeeking && mVideoSource == NULL && mAudioPlayer != NULL) { 1266bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mAudioPlayer->seekTo(mSeekTimeUs); 1267bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 12681862a33b246249630b654182afb5914da3480d4cAndreas Huber mWatchForAudioSeekComplete = true; 12691862a33b246249630b654182afb5914da3480d4cAndreas Huber mWatchForAudioEOS = true; 12701321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber mSeekNotificationSent = false; 1271dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang 1272dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang if (mDecryptHandle != NULL) { 1273dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 1274dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang Playback::PAUSE, 0); 1275dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 1276dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang Playback::START, mSeekTimeUs / 1000); 1277dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang } 1278bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1279bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1280bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 128188d8a83de12592635248aa1a3bd6b9ea46108501Andreas Hubervoid AwesomePlayer::setAudioSource(sp<MediaSource> source) { 128288d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber CHECK(source != NULL); 1283bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 128488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mAudioTrack = source; 128588d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber} 128688d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber 128788d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huberstatus_t AwesomePlayer::initAudioDecoder() { 128888d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber sp<MetaData> meta = mAudioTrack->getFormat(); 1289717826ececd8d39596f62418677721d70776add1Andreas Huber 1290717826ececd8d39596f62418677721d70776add1Andreas Huber const char *mime; 1291717826ececd8d39596f62418677721d70776add1Andreas Huber CHECK(meta->findCString(kKeyMIMEType, &mime)); 1292717826ececd8d39596f62418677721d70776add1Andreas Huber 1293717826ececd8d39596f62418677721d70776add1Andreas Huber if (!strcasecmp(mime, MEDIA_MIMETYPE_AUDIO_RAW)) { 129488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mAudioSource = mAudioTrack; 1295717826ececd8d39596f62418677721d70776add1Andreas Huber } else { 1296717826ececd8d39596f62418677721d70776add1Andreas Huber mAudioSource = OMXCodec::Create( 129788d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mClient.interface(), mAudioTrack->getFormat(), 1298717826ececd8d39596f62418677721d70776add1Andreas Huber false, // createEncoder 129988d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mAudioTrack); 1300717826ececd8d39596f62418677721d70776add1Andreas Huber } 1301bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1302bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mAudioSource != NULL) { 1303bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber int64_t durationUs; 130488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber if (mAudioTrack->getFormat()->findInt64(kKeyDuration, &durationUs)) { 13052415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber Mutex::Autolock autoLock(mMiscStateLock); 1306bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mDurationUs < 0 || durationUs > mDurationUs) { 1307bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mDurationUs = durationUs; 1308bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1309bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1310bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1311a945bfd91aa291fba4d9201ffcb38fce40eab7feAndreas Huber status_t err = mAudioSource->start(); 1312a945bfd91aa291fba4d9201ffcb38fce40eab7feAndreas Huber 1313a945bfd91aa291fba4d9201ffcb38fce40eab7feAndreas Huber if (err != OK) { 1314a945bfd91aa291fba4d9201ffcb38fce40eab7feAndreas Huber mAudioSource.clear(); 1315a945bfd91aa291fba4d9201ffcb38fce40eab7feAndreas Huber return err; 1316a945bfd91aa291fba4d9201ffcb38fce40eab7feAndreas Huber } 131781f82c32459029bf0744e28c73f95a7f18cab5acAndreas Huber } else if (!strcasecmp(mime, MEDIA_MIMETYPE_AUDIO_QCELP)) { 131881f82c32459029bf0744e28c73f95a7f18cab5acAndreas Huber // For legacy reasons we're simply going to ignore the absence 131981f82c32459029bf0744e28c73f95a7f18cab5acAndreas Huber // of an audio decoder for QCELP instead of aborting playback 132081f82c32459029bf0744e28c73f95a7f18cab5acAndreas Huber // altogether. 132181f82c32459029bf0744e28c73f95a7f18cab5acAndreas Huber return OK; 132281f82c32459029bf0744e28c73f95a7f18cab5acAndreas Huber } 1323e7e3b785a0e7819db4c895a4f60e9a4dd755880cAndreas Huber 1324bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return mAudioSource != NULL ? OK : UNKNOWN_ERROR; 1325bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1326bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 132788d8a83de12592635248aa1a3bd6b9ea46108501Andreas Hubervoid AwesomePlayer::setVideoSource(sp<MediaSource> source) { 132888d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber CHECK(source != NULL); 1329bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 133088d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mVideoTrack = source; 133188d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber} 133288d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber 13332a4d22d79e927f2245537921e10fc5fda1c47a29Andreas Huberstatus_t AwesomePlayer::initVideoDecoder(uint32_t flags) { 1334bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoSource = OMXCodec::Create( 133588d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mClient.interface(), mVideoTrack->getFormat(), 1336bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber false, // createEncoder 133739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mVideoTrack, 1338e332a9181cf6a3155ed1a0fd2afc212ccb1f2753Andreas Huber NULL, flags, USE_SURFACE_ALLOC ? mSurface : NULL); 1339bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1340bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mVideoSource != NULL) { 1341bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber int64_t durationUs; 134288d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber if (mVideoTrack->getFormat()->findInt64(kKeyDuration, &durationUs)) { 13432415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber Mutex::Autolock autoLock(mMiscStateLock); 1344bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mDurationUs < 0 || durationUs > mDurationUs) { 1345bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mDurationUs = durationUs; 1346bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1347bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1348bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1349139a5d5bd33c9fc7708d0a79f11ee928f7796e6bAndreas Huber status_t err = mVideoSource->start(); 1350139a5d5bd33c9fc7708d0a79f11ee928f7796e6bAndreas Huber 1351139a5d5bd33c9fc7708d0a79f11ee928f7796e6bAndreas Huber if (err != OK) { 1352139a5d5bd33c9fc7708d0a79f11ee928f7796e6bAndreas Huber mVideoSource.clear(); 1353139a5d5bd33c9fc7708d0a79f11ee928f7796e6bAndreas Huber return err; 1354139a5d5bd33c9fc7708d0a79f11ee928f7796e6bAndreas Huber } 1355bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1356bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1357bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return mVideoSource != NULL ? OK : UNKNOWN_ERROR; 1358bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1359bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 13604769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Hubervoid AwesomePlayer::finishSeekIfNecessary(int64_t videoTimeUs) { 13614769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber if (!mSeeking) { 13624769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber return; 13634769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber } 13644769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber 13654769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber if (mAudioPlayer != NULL) { 1366f83dd80384f70da1f6d36d60e831439ff7739ad7Jamie Gennis LOGV("seeking audio to %lld us (%.2f secs).", videoTimeUs, videoTimeUs / 1E6); 13674769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber 13684769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // If we don't have a video time, seek audio to the originally 13694769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // requested seek time instead. 13704769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber 13714769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mAudioPlayer->seekTo(videoTimeUs < 0 ? mSeekTimeUs : videoTimeUs); 13724769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mAudioPlayer->resume(); 13734769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mWatchForAudioSeekComplete = true; 13744769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mWatchForAudioEOS = true; 13754769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber } else if (!mSeekNotificationSent) { 13764769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // If we're playing video only, report seek complete now, 13774769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // otherwise audio player will notify us later. 13784769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber notifyListener_l(MEDIA_SEEK_COMPLETE); 13794769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber } 13804769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber 13814769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mFlags |= FIRST_FRAME; 13824769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mSeeking = false; 13834769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber mSeekNotificationSent = false; 1384a89082944308805b0def7de87c67e370e74b8789Gloria Wang 1385a89082944308805b0def7de87c67e370e74b8789Gloria Wang if (mDecryptHandle != NULL) { 1386a89082944308805b0def7de87c67e370e74b8789Gloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 1387a89082944308805b0def7de87c67e370e74b8789Gloria Wang Playback::PAUSE, 0); 1388a89082944308805b0def7de87c67e370e74b8789Gloria Wang mDrmManagerClient->setPlaybackStatus(mDecryptHandle, 1389a89082944308805b0def7de87c67e370e74b8789Gloria Wang Playback::START, videoTimeUs / 1000); 1390a89082944308805b0def7de87c67e370e74b8789Gloria Wang } 13914769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber} 13924769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber 1393c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Hubervoid AwesomePlayer::onVideoEvent() { 1394bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber Mutex::Autolock autoLock(mLock); 13957b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber if (!mVideoEventPending) { 13967b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // The event has been cancelled in reset_l() but had already 13977b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber // been scheduled for execution at that time. 13987b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber return; 13997b3396acc702451be9bafb19d7fe26d55d43a316Andreas Huber } 1400bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoEventPending = false; 1401bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1402bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mSeeking) { 1403bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mVideoBuffer) { 1404bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer->release(); 1405bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer = NULL; 1406bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 14070a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 14080a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber if (mCachedSource != NULL && mAudioSource != NULL) { 14090a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // We're going to seek the video source first, followed by 14100a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // the audio source. 14110a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // In order to avoid jumps in the DataSource offset caused by 14120a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // the audio codec prefetching data from the old locations 14130a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // while the video codec is already reading data from the new 14140a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // locations, we'll "pause" the audio source, causing it to 14150a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber // stop reading input data until a subsequent seek. 14160a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 14170a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber if (mAudioPlayer != NULL) { 14180a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mAudioPlayer->pause(); 14190a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber } 14200a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mAudioSource->pause(); 14210a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber } 1422bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1423bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1424bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (!mVideoBuffer) { 1425bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber MediaSource::ReadOptions options; 1426bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mSeeking) { 1427bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber LOGV("seeking to %lld us (%.2f secs)", mSeekTimeUs, mSeekTimeUs / 1E6); 1428bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1429abd1f4f870925d6776dbe4b930b759a1ab6595caAndreas Huber options.setSeekTo( 1430abd1f4f870925d6776dbe4b930b759a1ab6595caAndreas Huber mSeekTimeUs, MediaSource::ReadOptions::SEEK_CLOSEST_SYNC); 1431bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1432bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber for (;;) { 1433bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber status_t err = mVideoSource->read(&mVideoBuffer, &options); 1434c1689e49ac867de33f2e81289449878ac2e536a0Andreas Huber options.clearSeekTo(); 1435bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1436bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (err != OK) { 1437e2b1028852120bcfded33b8f06f66b780437fe92Andreas Huber CHECK(mVideoBuffer == NULL); 1438bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1439bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (err == INFO_FORMAT_CHANGED) { 1440bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber LOGV("VideoSource signalled format change."); 1441bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 14425daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber notifyVideoSize_l(); 14435daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber 1444a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber if (mVideoRenderer != NULL) { 1445fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber mVideoRendererIsPreview = false; 1446a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber initRenderer_l(); 1447a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber } 1448bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber continue; 1449bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1450bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 14514769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // So video playback is complete, but we may still have 14524769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // a seek request pending that needs to be applied 14534769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber // to the audio track. 14544769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber if (mSeeking) { 14554769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber LOGV("video stream ended while seeking!"); 14564769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber } 14574769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber finishSeekIfNecessary(-1); 14584769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber 14595d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mFlags |= VIDEO_AT_EOS; 14605295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Huber postStreamDoneEvent_l(err); 1461bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return; 1462bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1463bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 14644844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber if (mVideoBuffer->range_length() == 0) { 146508411b75d4c30ce26180639f158e2f33d190eee8Andreas Huber // Some decoders, notably the PV AVC software decoder 146608411b75d4c30ce26180639f158e2f33d190eee8Andreas Huber // return spurious empty buffers that we just want to ignore. 146708411b75d4c30ce26180639f158e2f33d190eee8Andreas Huber 14684844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber mVideoBuffer->release(); 14694844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber mVideoBuffer = NULL; 14704844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber continue; 14714844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber } 14724844ac54e8b5997c3b03872dbafe8ebed4787517Andreas Huber 1473bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber break; 1474bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1475bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1476bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1477bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber int64_t timeUs; 1478bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber CHECK(mVideoBuffer->meta_data()->findInt64(kKeyTime, &timeUs)); 1479bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 14802415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber { 14812415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber Mutex::Autolock autoLock(mMiscStateLock); 14822415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber mVideoTimeUs = timeUs; 14832415ecb5bb4e1459024f6d6c8ae2d6e3dc4fbdc7Andreas Huber } 1484bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 148502a1db7dc1de2f2df306ec10bab992bc8bbaaca8Andreas Huber bool wasSeeking = mSeeking; 14864769cc92740e3ab58e9263d42553c12bbf79e3beAndreas Huber finishSeekIfNecessary(timeUs); 1487bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 14885d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber TimeSource *ts = (mFlags & AUDIO_AT_EOS) ? &mSystemTimeSource : mTimeSource; 14895d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber 1490bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mFlags & FIRST_FRAME) { 1491bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mFlags &= ~FIRST_FRAME; 1492bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 14935d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mTimeSourceDeltaUs = ts->getRealTimeUs() - timeUs; 1494bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1495bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1496bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber int64_t realTimeUs, mediaTimeUs; 14975d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber if (!(mFlags & AUDIO_AT_EOS) && mAudioPlayer != NULL 1498bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber && mAudioPlayer->getMediaTimeMapping(&realTimeUs, &mediaTimeUs)) { 1499bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mTimeSourceDeltaUs = realTimeUs - mediaTimeUs; 1500bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1501bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 15025d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber int64_t nowUs = ts->getRealTimeUs() - mTimeSourceDeltaUs; 1503bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1504bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber int64_t latenessUs = nowUs - timeUs; 1505bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 150602a1db7dc1de2f2df306ec10bab992bc8bbaaca8Andreas Huber if (wasSeeking) { 150702a1db7dc1de2f2df306ec10bab992bc8bbaaca8Andreas Huber // Let's display the first frame after seeking right away. 150802a1db7dc1de2f2df306ec10bab992bc8bbaaca8Andreas Huber latenessUs = 0; 150902a1db7dc1de2f2df306ec10bab992bc8bbaaca8Andreas Huber } 151002a1db7dc1de2f2df306ec10bab992bc8bbaaca8Andreas Huber 1511f8ca90452ff3e252f20de38f1c3eee524c808c3eAndreas Huber if (mRTPSession != NULL) { 1512f8ca90452ff3e252f20de38f1c3eee524c808c3eAndreas Huber // We'll completely ignore timestamps for gtalk videochat 1513f8ca90452ff3e252f20de38f1c3eee524c808c3eAndreas Huber // and we'll play incoming video as fast as we get it. 1514f8ca90452ff3e252f20de38f1c3eee524c808c3eAndreas Huber latenessUs = 0; 1515f8ca90452ff3e252f20de38f1c3eee524c808c3eAndreas Huber } 1516f8ca90452ff3e252f20de38f1c3eee524c808c3eAndreas Huber 1517650773d00356129ffd661cdaef3fb3095c343707Andreas Huber if (latenessUs > 40000) { 1518650773d00356129ffd661cdaef3fb3095c343707Andreas Huber // We're more than 40ms late. 1519ec9dd59902c8beea4ba6a842f3a843d46150d949Andreas Huber LOGV("we're late by %lld us (%.2f secs)", latenessUs, latenessUs / 1E6); 1520bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1521bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer->release(); 1522bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer = NULL; 1523bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1524bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber postVideoEvent_l(); 1525bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return; 1526bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1527bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1528bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (latenessUs < -10000) { 1529bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber // We're more than 10ms early. 1530bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1531bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber postVideoEvent_l(10000); 1532bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return; 1533bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1534bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1535fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber if (mVideoRendererIsPreview || mVideoRenderer == NULL) { 1536fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber mVideoRendererIsPreview = false; 1537fa090f541bb84a546af2ec834e91a032ff10e66eAndreas Huber 1538a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber initRenderer_l(); 1539a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber } 1540a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber 1541a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber if (mVideoRenderer != NULL) { 1542a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber mVideoRenderer->render(mVideoBuffer); 1543a657f8deaf21acbe5faba7be1df9c6681d44d471Andreas Huber } 1544bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1545f5ab57c2d5e02af7483c94eddb177e4f5c9e9892Andreas Huber mVideoBuffer->release(); 1546bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoBuffer = NULL; 1547bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1548bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber postVideoEvent_l(); 1549bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1550bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1551bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Hubervoid AwesomePlayer::postVideoEvent_l(int64_t delayUs) { 1552bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mVideoEventPending) { 1553bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return; 1554bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1555bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 1556bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mVideoEventPending = true; 1557bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mQueue.postEventWithDelay(mVideoEvent, delayUs < 0 ? 10000 : delayUs); 1558bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1559bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 15605295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Hubervoid AwesomePlayer::postStreamDoneEvent_l(status_t status) { 1561bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber if (mStreamDoneEventPending) { 1562bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber return; 1563bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber } 1564bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mStreamDoneEventPending = true; 15655295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Huber 15665295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Huber mStreamDoneStatus = status; 1567bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber mQueue.postEvent(mStreamDoneEvent); 1568bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} 1569bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber 157066b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Hubervoid AwesomePlayer::postBufferingEvent_l() { 157166b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber if (mBufferingEventPending) { 157266b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber return; 157366b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber } 157466b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber mBufferingEventPending = true; 157566b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber mQueue.postEventWithDelay(mBufferingEvent, 1000000ll); 157666b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber} 157766b0a35c9a4136a84c3f73b1b25fcb5220138b95Andreas Huber 15781862a33b246249630b654182afb5914da3480d4cAndreas Hubervoid AwesomePlayer::postCheckAudioStatusEvent_l() { 15791862a33b246249630b654182afb5914da3480d4cAndreas Huber if (mAudioStatusEventPending) { 15801862a33b246249630b654182afb5914da3480d4cAndreas Huber return; 15811862a33b246249630b654182afb5914da3480d4cAndreas Huber } 15821862a33b246249630b654182afb5914da3480d4cAndreas Huber mAudioStatusEventPending = true; 1583ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber mQueue.postEvent(mCheckAudioStatusEvent); 15841862a33b246249630b654182afb5914da3480d4cAndreas Huber} 15851862a33b246249630b654182afb5914da3480d4cAndreas Huber 15861862a33b246249630b654182afb5914da3480d4cAndreas Hubervoid AwesomePlayer::onCheckAudioStatus() { 15871862a33b246249630b654182afb5914da3480d4cAndreas Huber Mutex::Autolock autoLock(mLock); 1588d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber if (!mAudioStatusEventPending) { 1589d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber // Event was dispatched and while we were blocking on the mutex, 1590d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber // has already been cancelled. 1591d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber return; 1592d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber } 1593d29345dfa29cdcc650f3705e43950ef2500f6728Andreas Huber 15941862a33b246249630b654182afb5914da3480d4cAndreas Huber mAudioStatusEventPending = false; 15951862a33b246249630b654182afb5914da3480d4cAndreas Huber 15961862a33b246249630b654182afb5914da3480d4cAndreas Huber if (mWatchForAudioSeekComplete && !mAudioPlayer->isSeeking()) { 15971862a33b246249630b654182afb5914da3480d4cAndreas Huber mWatchForAudioSeekComplete = false; 15981321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber 15991321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber if (!mSeekNotificationSent) { 16001321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber notifyListener_l(MEDIA_SEEK_COMPLETE); 16011321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber mSeekNotificationSent = true; 16021321fdd94d354431b930735e9f38f32ecd189a2dAndreas Huber } 1603dac4ee72bac87388a1495e098f39d73168c8078fAndreas Huber 1604dac4ee72bac87388a1495e098f39d73168c8078fAndreas Huber mSeeking = false; 16051862a33b246249630b654182afb5914da3480d4cAndreas Huber } 16061862a33b246249630b654182afb5914da3480d4cAndreas Huber 16075295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Huber status_t finalStatus; 16085295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Huber if (mWatchForAudioEOS && mAudioPlayer->reachedEOS(&finalStatus)) { 16091862a33b246249630b654182afb5914da3480d4cAndreas Huber mWatchForAudioEOS = false; 16105d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mFlags |= AUDIO_AT_EOS; 16115d2de4da54504836e4b772b3010ac28c19f667f0Andreas Huber mFlags |= FIRST_FRAME; 16125295c0c55d41a2906ea7f65a3f22e6278cb17d4bAndreas Huber postStreamDoneEvent_l(finalStatus); 16131862a33b246249630b654182afb5914da3480d4cAndreas Huber } 16141862a33b246249630b654182afb5914da3480d4cAndreas Huber} 16151862a33b246249630b654182afb5914da3480d4cAndreas Huber 1616c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huberstatus_t AwesomePlayer::prepare() { 1617c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber Mutex::Autolock autoLock(mLock); 1618bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return prepare_l(); 1619bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber} 1620c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1621bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huberstatus_t AwesomePlayer::prepare_l() { 1622bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (mFlags & PREPARED) { 1623bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return OK; 1624bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1625bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1626bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (mFlags & PREPARING) { 1627bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return UNKNOWN_ERROR; 1628bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1629bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1630bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mIsAsyncPrepare = false; 1631c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber status_t err = prepareAsync_l(); 1632c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1633c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber if (err != OK) { 1634c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber return err; 1635c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber } 1636c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1637bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber while (mFlags & PREPARING) { 1638c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mPreparedCondition.wait(mLock); 1639c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber } 1640c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1641bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return mPrepareResult; 1642c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber} 1643c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1644c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huberstatus_t AwesomePlayer::prepareAsync() { 1645c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber Mutex::Autolock autoLock(mLock); 1646bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1647bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (mFlags & PREPARING) { 1648bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return UNKNOWN_ERROR; // async prepare already pending 1649bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1650bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1651bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mIsAsyncPrepare = true; 1652c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber return prepareAsync_l(); 1653c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber} 1654c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1655c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huberstatus_t AwesomePlayer::prepareAsync_l() { 1656bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (mFlags & PREPARING) { 1657bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return UNKNOWN_ERROR; // async prepare already pending 1658c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber } 1659c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 16602e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber if (!mQueueStarted) { 16612e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber mQueue.start(); 16622e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber mQueueStarted = true; 16632e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber } 16642e8ffaf95bd35358ecd14ddf00cddaf3abefe0a9Andreas Huber 1665bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mFlags |= PREPARING; 1666c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mAsyncPrepareEvent = new AwesomeEvent( 1667c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber this, &AwesomePlayer::onPrepareAsyncEvent); 1668c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1669c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mQueue.postEvent(mAsyncPrepareEvent); 1670c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1671c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber return OK; 1672c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber} 1673c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1674bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huberstatus_t AwesomePlayer::finishSetDataSource_l() { 1675e94bd14078d327ef2f800e69907efce641a13272Andreas Huber sp<DataSource> dataSource; 1676e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 1677e94bd14078d327ef2f800e69907efce641a13272Andreas Huber if (!strncasecmp("http://", mUri.string(), 7)) { 16780a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mConnectingDataSource = new NuHTTPDataSource; 1679e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 1680e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mLock.unlock(); 168179f77ef3b0a37660ba8c5bcb2dfbfda3860f2135Andreas Huber status_t err = mConnectingDataSource->connect(mUri, &mUriHeaders); 1682e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mLock.lock(); 1683e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 1684e94bd14078d327ef2f800e69907efce641a13272Andreas Huber if (err != OK) { 1685e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mConnectingDataSource.clear(); 1686e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 1687e94bd14078d327ef2f800e69907efce641a13272Andreas Huber LOGI("mConnectingDataSource->connect() returned %d", err); 1688e94bd14078d327ef2f800e69907efce641a13272Andreas Huber return err; 1689e94bd14078d327ef2f800e69907efce641a13272Andreas Huber } 1690e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 16910a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber#if 0 16920a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mCachedSource = new NuCachedSource2( 16930a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber new ThrottledSource( 16940a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mConnectingDataSource, 50 * 1024 /* bytes/sec */)); 16950a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber#else 16960a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber mCachedSource = new NuCachedSource2(mConnectingDataSource); 16970a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber#endif 1698e94bd14078d327ef2f800e69907efce641a13272Andreas Huber mConnectingDataSource.clear(); 16990a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 17000a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber dataSource = mCachedSource; 1701e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber } else if (!strncasecmp(mUri.string(), "httplive://", 11)) { 1702e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber String8 uri("http://"); 1703e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber uri.append(mUri.string() + 11); 1704e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber 1705a44153c1a57202fb538659eb50706e60454d6273Andreas Huber if (mLooper == NULL) { 1706a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLooper = new ALooper; 1707a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLooper->setName("httplive"); 1708a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLooper->start(); 1709a44153c1a57202fb538659eb50706e60454d6273Andreas Huber } 1710e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber 1711a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLiveSession = new LiveSession; 1712a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLooper->registerHandler(mLiveSession); 1713a44153c1a57202fb538659eb50706e60454d6273Andreas Huber 1714a44153c1a57202fb538659eb50706e60454d6273Andreas Huber mLiveSession->connect(uri.string()); 1715a44153c1a57202fb538659eb50706e60454d6273Andreas Huber dataSource = mLiveSession->getDataSource(); 1716e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber 1717e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber sp<MediaExtractor> extractor = 1718e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber MediaExtractor::Create(dataSource, MEDIA_MIMETYPE_CONTAINER_MPEG2TS); 17190a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber 1720bff07d0b22a5ee2d9f044f6cb5e4be1532017ab0Andreas Huber static_cast<MPEG2TSExtractor *>(extractor.get()) 1721a44153c1a57202fb538659eb50706e60454d6273Andreas Huber ->setLiveSession(mLiveSession); 1722bff07d0b22a5ee2d9f044f6cb5e4be1532017ab0Andreas Huber 17230a5baa9b411fe086013d2a5e9126ed63fbad046cAndreas Huber return setDataSource_l(extractor); 17241aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd } else if (!strncmp("rtsp://gtalk/", mUri.string(), 13)) { 172539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber if (mLooper == NULL) { 172639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mLooper = new ALooper; 1727a814c1fdc2acf0ed2ee3b175110f6039be7c4873Andreas Huber mLooper->setName("gtalk rtp"); 1728ff53123821a3ec2e71fdb1a971ea2cbae3119826Andreas Huber mLooper->start( 1729ff53123821a3ec2e71fdb1a971ea2cbae3119826Andreas Huber false /* runOnCallingThread */, 1730ff53123821a3ec2e71fdb1a971ea2cbae3119826Andreas Huber false /* canCallJava */, 1731ff53123821a3ec2e71fdb1a971ea2cbae3119826Andreas Huber PRIORITY_HIGHEST); 173239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber } 173339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 17341aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd const char *startOfCodecString = &mUri.string()[13]; 17351aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd const char *startOfSlash1 = strchr(startOfCodecString, '/'); 17361aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd if (startOfSlash1 == NULL) { 17371aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd return BAD_VALUE; 17381aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd } 17391aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd const char *startOfWidthString = &startOfSlash1[1]; 17401aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd const char *startOfSlash2 = strchr(startOfWidthString, '/'); 17411aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd if (startOfSlash2 == NULL) { 17421aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd return BAD_VALUE; 17431aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd } 17441aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd const char *startOfHeightString = &startOfSlash2[1]; 17451aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd 17461aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd String8 codecString(startOfCodecString, startOfSlash1 - startOfCodecString); 17471aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd String8 widthString(startOfWidthString, startOfSlash2 - startOfWidthString); 17481aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd String8 heightString(startOfHeightString); 17491aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd 175039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#if 0 175139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTPPusher = new UDPPusher("/data/misc/rtpout.bin", 5434); 175239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mLooper->registerHandler(mRTPPusher); 175339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 175439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTCPPusher = new UDPPusher("/data/misc/rtcpout.bin", 5435); 175539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mLooper->registerHandler(mRTCPPusher); 175639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#endif 175739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 175839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTPSession = new ARTPSession; 175939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mLooper->registerHandler(mRTPSession); 176039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 176139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#if 0 176239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber // My AMR SDP 176339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber static const char *raw = 176439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "v=0\r\n" 176539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "o=- 64 233572944 IN IP4 127.0.0.0\r\n" 176639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "s=QuickTime\r\n" 176739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "t=0 0\r\n" 176839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "a=range:npt=0-315\r\n" 176939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "a=isma-compliance:2,2.0,2\r\n" 177039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "m=audio 5434 RTP/AVP 97\r\n" 177139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "c=IN IP4 127.0.0.1\r\n" 177239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "b=AS:30\r\n" 177339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "a=rtpmap:97 AMR/8000/1\r\n" 177439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "a=fmtp:97 octet-align\r\n"; 177539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#elif 1 17761aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd String8 sdp; 17771aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd sdp.appendFormat( 177839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "v=0\r\n" 177939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "o=- 64 233572944 IN IP4 127.0.0.0\r\n" 178039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "s=QuickTime\r\n" 178139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "t=0 0\r\n" 178239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "a=range:npt=0-315\r\n" 178339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "a=isma-compliance:2,2.0,2\r\n" 178439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "m=video 5434 RTP/AVP 97\r\n" 178539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "c=IN IP4 127.0.0.1\r\n" 178639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber "b=AS:30\r\n" 17871aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd "a=rtpmap:97 %s/90000\r\n" 17881aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd "a=cliprect:0,0,%s,%s\r\n" 17891aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd "a=framesize:97 %s-%s\r\n", 17901aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd 17911aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd codecString.string(), 17921aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd heightString.string(), widthString.string(), 17931aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd widthString.string(), heightString.string() 17941aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd ); 17951aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd const char *raw = sdp.string(); 17961aa4fed23595d45b0ad0af86c9e839196172abe5Mike Dodd 179739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#endif 179839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 179939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber sp<ASessionDescription> desc = new ASessionDescription; 180039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber CHECK(desc->setTo(raw, strlen(raw))); 180139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 180239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber CHECK_EQ(mRTPSession->setup(desc), (status_t)OK); 180339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 180439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber if (mRTPPusher != NULL) { 180539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTPPusher->start(); 180639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber } 180739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 180839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber if (mRTCPPusher != NULL) { 180939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mRTCPPusher->start(); 181039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber } 181139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 181239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber CHECK_EQ(mRTPSession->countTracks(), 1u); 181339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber sp<MediaSource> source = mRTPSession->trackAt(0); 181439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 181539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#if 0 181639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber bool eos; 181739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber while (((APacketSource *)source.get()) 181839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber ->getQueuedDuration(&eos) < 5000000ll && !eos) { 181939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber usleep(100000ll); 182039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber } 182139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber#endif 182239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 182339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber const char *mime; 182439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber CHECK(source->getFormat()->findCString(kKeyMIMEType, &mime)); 182539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 182639ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber if (!strncasecmp("video/", mime, 6)) { 182739ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber setVideoSource(source); 182839ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber } else { 182939ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber CHECK(!strncasecmp("audio/", mime, 6)); 183039ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber setAudioSource(source); 183139ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber } 183239ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 183339ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber mExtractorFlags = MediaExtractor::CAN_PAUSE; 183439ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber 183539ddf8e0f18766f7ba1e3246b774aa6ebd93eea8Andreas Huber return OK; 1836cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber } else if (!strncasecmp("rtsp://", mUri.string(), 7)) { 1837cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber if (mLooper == NULL) { 1838cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber mLooper = new ALooper; 1839a814c1fdc2acf0ed2ee3b175110f6039be7c4873Andreas Huber mLooper->setName("rtsp"); 1840cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber mLooper->start(); 1841cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber } 1842cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber mRTSPController = new ARTSPController(mLooper); 1843cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber status_t err = mRTSPController->connect(mUri.string()); 1844cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber 1845cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber LOGI("ARTSPController::connect returned %d", err); 1846cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber 1847cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber if (err != OK) { 1848cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber mRTSPController.clear(); 1849cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber return err; 1850cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber } 1851e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber 1852cf7b9c7aae758ac0b99833915053c63c2ac46e09Andreas Huber sp<MediaExtractor> extractor = mRTSPController.get(); 1853e71d10e7ad55ccbcb0756c007caef1c959090384Andreas Huber return setDataSource_l(extractor); 1854e94bd14078d327ef2f800e69907efce641a13272Andreas Huber } else { 1855e94bd14078d327ef2f800e69907efce641a13272Andreas Huber dataSource = DataSource::CreateFromURI(mUri.string(), &mUriHeaders); 1856e94bd14078d327ef2f800e69907efce641a13272Andreas Huber } 1857bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1858bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (dataSource == NULL) { 1859bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return UNKNOWN_ERROR; 1860bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1861bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1862bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber sp<MediaExtractor> extractor = MediaExtractor::Create(dataSource); 1863bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1864bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (extractor == NULL) { 1865bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return UNKNOWN_ERROR; 1866bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1867bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 1868dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang dataSource->getDrmInfo(&mDecryptHandle, &mDrmManagerClient); 1869b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang if (mDecryptHandle != NULL) { 1870b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang if (RightsStatus::RIGHTS_VALID == mDecryptHandle->status) { 1871b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang if (DecryptApiType::WV_BASED == mDecryptHandle->decryptApiType) { 1872b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang LOGD("Setting mCachedSource to NULL for WVM\n"); 1873b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang mCachedSource.clear(); 1874b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang } 1875b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang } else { 1876b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang notifyListener_l(MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, ERROR_NO_LICENSE); 1877b371426ce4cf2fa6d8c3d1903b61322feb165d35Gloria Wang } 1878dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang } 1879dcd25efb46c41c8d24a0a9cf61fb57f84149709eGloria Wang 1880bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber return setDataSource_l(extractor); 1881bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber} 1882bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 188388d8a83de12592635248aa1a3bd6b9ea46108501Andreas Hubervoid AwesomePlayer::abortPrepare(status_t err) { 188488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber CHECK(err != OK); 188588d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber 188688d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber if (mIsAsyncPrepare) { 188788d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber notifyListener_l(MEDIA_ERROR, MEDIA_ERROR_UNKNOWN, err); 188888d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber } 188988d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber 189088d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mPrepareResult = err; 18916a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber mFlags &= ~(PREPARING|PREPARE_CANCELLED|PREPARING_CONNECTED); 189288d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mAsyncPrepareEvent = NULL; 189388d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber mPreparedCondition.broadcast(); 189488d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber} 189588d8a83de12592635248aa1a3bd6b9ea46108501Andreas Huber 1896e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huber// static 1897e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huberbool AwesomePlayer::ContinuePreparation(void *cookie) { 1898e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huber AwesomePlayer *me = static_cast<AwesomePlayer *>(cookie); 1899e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huber 1900e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huber return (me->mFlags & PREPARE_CANCELLED) == 0; 1901e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huber} 1902e966fb05c7e67a7f5dce65024de60aac83eb6f81Andreas Huber 1903c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Hubervoid AwesomePlayer::onPrepareAsyncEvent() { 19048650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber Mutex::Autolock autoLock(mLock); 1905bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 19068650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mFlags & PREPARE_CANCELLED) { 19078650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber LOGI("prepare was cancelled before doing anything"); 19088650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber abortPrepare(UNKNOWN_ERROR); 19098650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return; 19108650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 1911e94bd14078d327ef2f800e69907efce641a13272Andreas Huber 19128650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mUri.size() > 0) { 19138650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber status_t err = finishSetDataSource_l(); 1914bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 19158650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (err != OK) { 19168650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber abortPrepare(err); 19178650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return; 1918bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 19198650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 1920bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber 19218650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mVideoTrack != NULL && mVideoSource == NULL) { 19228650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber status_t err = initVideoDecoder(); 19231322e7ebc33e8e161fb73cd47e43dd93357608e4Andreas Huber 19248650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (err != OK) { 19258650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber abortPrepare(err); 19268650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return; 19271322e7ebc33e8e161fb73cd47e43dd93357608e4Andreas Huber } 19288650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 19291322e7ebc33e8e161fb73cd47e43dd93357608e4Andreas Huber 19308650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mAudioTrack != NULL && mAudioSource == NULL) { 19318650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber status_t err = initAudioDecoder(); 19321322e7ebc33e8e161fb73cd47e43dd93357608e4Andreas Huber 19338650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (err != OK) { 19348650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber abortPrepare(err); 19358650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber return; 19361322e7ebc33e8e161fb73cd47e43dd93357608e4Andreas Huber } 1937c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber } 1938c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 19396a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber mFlags |= PREPARING_CONNECTED; 19406a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber 19418650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber if (mCachedSource != NULL || mRTSPController != NULL) { 19428650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber postBufferingEvent_l(); 19438650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } else { 19448650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber finishAsyncPrepare_l(); 19458650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber } 19468650e1960905097f6f1d6aa462ccb1c93c656834Andreas Huber} 1947c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 19488650e1960905097f6f1d6aa462ccb1c93c656834Andreas Hubervoid AwesomePlayer::finishAsyncPrepare_l() { 1949bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber if (mIsAsyncPrepare) { 19505daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber if (mVideoSource == NULL) { 1951bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber notifyListener_l(MEDIA_SET_VIDEO_SIZE, 0, 0); 1952bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } else { 19535daeb129a2c2ba3d14ccd94af283b5f561c783eaAndreas Huber notifyVideoSize_l(); 1954bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1955c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1956bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber notifyListener_l(MEDIA_PREPARED); 1957bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber } 1958c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1959bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mPrepareResult = OK; 19606a05c9e912aeb8bfe1ef99516def91a177a481b6Andreas Huber mFlags &= ~(PREPARING|PREPARE_CANCELLED|PREPARING_CONNECTED); 1961bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mFlags |= PREPARED; 1962c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber mAsyncPrepareEvent = NULL; 1963bd22c52280179b29eefac91ef7e7bbbc33d25904Andreas Huber mPreparedCondition.broadcast(); 1964c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber} 1965c23f12af0394aa2f6651968a3c8840f1af317aa1Andreas Huber 1966acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huberuint32_t AwesomePlayer::flags() const { 1967acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber return mExtractorFlags; 1968acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber} 1969acdd9d0f59c3d8bdc3de80664a609527ec3d21e2Andreas Huber 1970ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Hubervoid AwesomePlayer::postAudioEOS() { 1971ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber postCheckAudioStatusEvent_l(); 1972ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber} 1973ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber 1974ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Hubervoid AwesomePlayer::postAudioSeekComplete() { 1975ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber postCheckAudioStatusEvent_l(); 1976ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber} 1977ed54ad0f8619ae416b0968ade6248894cbfc4dbaAndreas Huber 1978bfa6b2d7a1be1832ac40ed90aece1834f720b5c6Andreas Huber} // namespace android 1979