StreamingSource.cpp revision 1d15ab58bf8239069ef343de6cb21aabf3ef7d78
15bc087c573c70c84c6a39946457590b42d392a33Andreas Huber/* 25bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * Copyright (C) 2010 The Android Open Source Project 35bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * 45bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * Licensed under the Apache License, Version 2.0 (the "License"); 55bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * you may not use this file except in compliance with the License. 65bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * You may obtain a copy of the License at 75bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * 85bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * http://www.apache.org/licenses/LICENSE-2.0 95bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * 105bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * Unless required by applicable law or agreed to in writing, software 115bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * distributed under the License is distributed on an "AS IS" BASIS, 125bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 135bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * See the License for the specific language governing permissions and 145bc087c573c70c84c6a39946457590b42d392a33Andreas Huber * limitations under the License. 155bc087c573c70c84c6a39946457590b42d392a33Andreas Huber */ 165bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 175bc087c573c70c84c6a39946457590b42d392a33Andreas Huber//#define LOG_NDEBUG 0 185bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#define LOG_TAG "StreamingSource" 195bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <utils/Log.h> 205bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 215bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "StreamingSource.h" 225bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 235bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "ATSParser.h" 245bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "AnotherPacketSource.h" 255bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "NuPlayerStreamListener.h" 265bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 275bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/foundation/ABuffer.h> 285bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/foundation/ADebug.h> 295bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/foundation/AMessage.h> 305bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/MediaSource.h> 315bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/MetaData.h> 325bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 335bc087c573c70c84c6a39946457590b42d392a33Andreas Hubernamespace android { 345bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 35b5f25f005bc1d3ae35f45b58c88345e183dc336dAndreas HuberNuPlayer::StreamingSource::StreamingSource( 36b5f25f005bc1d3ae35f45b58c88345e183dc336dAndreas Huber const sp<AMessage> ¬ify, 37b5f25f005bc1d3ae35f45b58c88345e183dc336dAndreas Huber const sp<IStreamSource> &source) 38b5f25f005bc1d3ae35f45b58c88345e183dc336dAndreas Huber : Source(notify), 39b5f25f005bc1d3ae35f45b58c88345e183dc336dAndreas Huber mSource(source), 40180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mFinalResult(OK), 41180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mBuffering(false) { 425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 435bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 445bc087c573c70c84c6a39946457590b42d392a33Andreas HuberNuPlayer::StreamingSource::~StreamingSource() { 45180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (mLooper != NULL) { 46180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mLooper->unregisterHandler(id()); 47180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mLooper->stop(); 48180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 495bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 505bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 519575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Hubervoid NuPlayer::StreamingSource::prepareAsync() { 52180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (mLooper == NULL) { 53180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mLooper = new ALooper; 54180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mLooper->setName("streaming"); 55180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mLooper->start(); 56180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 57180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mLooper->registerHandler(this); 58180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 59180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 60ced1c2f8f6c422063092f5cc5c675ccdebb2dc10Chong Zhang notifyVideoSizeChanged(); 619575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber notifyFlagsChanged(0); 629575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber notifyPrepared(); 639575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber} 649575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber 655bc087c573c70c84c6a39946457590b42d392a33Andreas Hubervoid NuPlayer::StreamingSource::start() { 661d15ab58bf8239069ef343de6cb21aabf3ef7d78Lajos Molnar mStreamListener = new NuPlayerStreamListener(mSource, NULL); 6787f2a558dd12043631e12c361abef301bf603140Andreas Huber 6887f2a558dd12043631e12c361abef301bf603140Andreas Huber uint32_t sourceFlags = mSource->flags(); 6987f2a558dd12043631e12c361abef301bf603140Andreas Huber 7087f2a558dd12043631e12c361abef301bf603140Andreas Huber uint32_t parserFlags = ATSParser::TS_TIMESTAMPS_ARE_ABSOLUTE; 7187f2a558dd12043631e12c361abef301bf603140Andreas Huber if (sourceFlags & IStreamSource::kFlagAlignedVideoData) { 7287f2a558dd12043631e12c361abef301bf603140Andreas Huber parserFlags |= ATSParser::ALIGNED_VIDEO_DATA; 7387f2a558dd12043631e12c361abef301bf603140Andreas Huber } 7487f2a558dd12043631e12c361abef301bf603140Andreas Huber 7587f2a558dd12043631e12c361abef301bf603140Andreas Huber mTSParser = new ATSParser(parserFlags); 765bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 775bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mStreamListener->start(); 78180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 79180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang postReadBuffer(); 805bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 815bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 82eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huberstatus_t NuPlayer::StreamingSource::feedMoreTSData() { 83180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return postReadBuffer(); 84180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang} 855bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 86180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangvoid NuPlayer::StreamingSource::onReadBuffer() { 87078cfcf7cce9185ec7559910d08b0bc02bfc88a3Andreas Huber for (int32_t i = 0; i < 50; ++i) { 885bc087c573c70c84c6a39946457590b42d392a33Andreas Huber char buffer[188]; 8932f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber sp<AMessage> extra; 9032f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber ssize_t n = mStreamListener->read(buffer, sizeof(buffer), &extra); 915bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 925bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (n == 0) { 93df64d15042bbd5e0e4933ac49bf3c177dd94752cSteve Block ALOGI("input data EOS reached."); 945bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalEOS(ERROR_END_OF_STREAM); 95180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang setError(ERROR_END_OF_STREAM); 965bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 975bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n == INFO_DISCONTINUITY) { 98fef808d42a9c94b0b5ef3c3d5fb0a090edbc42daWei Jia int32_t type = ATSParser::DISCONTINUITY_TIME; 9942e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber 100bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber int32_t mask; 10142e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber if (extra != NULL 10242e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber && extra->findInt32( 103bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber IStreamListener::kKeyDiscontinuityMask, &mask)) { 104bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber if (mask == 0) { 10529357bc2c0dd7c43ad3bd0c8e3efa4e6fd9bfd47Steve Block ALOGE("Client specified an illegal discontinuity type."); 106180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang setError(ERROR_UNSUPPORTED); 107180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang break; 108bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber } 109bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber 110bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber type = mask; 11142e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber } 11242e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber 113bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber mTSParser->signalDiscontinuity( 114bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber (ATSParser::DiscontinuityType)type, extra); 1155bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n < 0) { 1165bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 1175bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 1185bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (buffer[0] == 0x00) { 1195bc087c573c70c84c6a39946457590b42d392a33Andreas Huber // XXX legacy 120b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 121b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber if (extra == NULL) { 122b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber extra = new AMessage; 123b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber } 124b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 125b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber uint8_t type = buffer[1]; 126b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 127b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber if (type & 2) { 128b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber int64_t mediaTimeUs; 129b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber memcpy(&mediaTimeUs, &buffer[2], sizeof(mediaTimeUs)); 130b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 131b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber extra->setInt64(IStreamListener::kKeyMediaTimeUs, mediaTimeUs); 132b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber } 133b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 1345bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalDiscontinuity( 135b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber ((type & 1) == 0) 136fef808d42a9c94b0b5ef3c3d5fb0a090edbc42daWei Jia ? ATSParser::DISCONTINUITY_TIME 13732f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber : ATSParser::DISCONTINUITY_FORMATCHANGE, 13832f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber extra); 1395bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 14006528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber status_t err = mTSParser->feedTSPacket(buffer, sizeof(buffer)); 14106528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 14206528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber if (err != OK) { 14329357bc2c0dd7c43ad3bd0c8e3efa4e6fd9bfd47Steve Block ALOGE("TS Parser returned error %d", err); 14406528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 14506528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber mTSParser->signalEOS(err); 146180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang setError(err); 14706528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber break; 14806528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber } 1495bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1505bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1515bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 152180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang} 153180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 154180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangstatus_t NuPlayer::StreamingSource::postReadBuffer() { 155180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang { 156180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang Mutex::Autolock _l(mBufferingLock); 157180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (mFinalResult != OK) { 158180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return mFinalResult; 159180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 160180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (mBuffering) { 161180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return OK; 162180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 163180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mBuffering = true; 164180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 1655bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1661d15ab58bf8239069ef343de6cb21aabf3ef7d78Lajos Molnar (new AMessage(kWhatReadBuffer, this))->post(); 167eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber return OK; 1685bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1695bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 170180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangbool NuPlayer::StreamingSource::haveSufficientDataOnAllTracks() { 171180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang // We're going to buffer at least 2 secs worth data on all tracks before 172180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang // starting playback (both at startup and after a seek). 173180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 174180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang static const int64_t kMinDurationUs = 2000000ll; 175180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 176180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang sp<AnotherPacketSource> audioTrack = getSource(true /*audio*/); 177180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang sp<AnotherPacketSource> videoTrack = getSource(false /*audio*/); 178180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 179180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang status_t err; 180180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang int64_t durationUs; 181180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (audioTrack != NULL 182180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang && (durationUs = audioTrack->getBufferedDurationUs(&err)) 183180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang < kMinDurationUs 184180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang && err == OK) { 185180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang ALOGV("audio track doesn't have enough data yet. (%.2f secs buffered)", 186180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang durationUs / 1E6); 187180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return false; 188180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 189180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 190180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (videoTrack != NULL 191180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang && (durationUs = videoTrack->getBufferedDurationUs(&err)) 192180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang < kMinDurationUs 193180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang && err == OK) { 194180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang ALOGV("video track doesn't have enough data yet. (%.2f secs buffered)", 195180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang durationUs / 1E6); 196180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return false; 197180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 198180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 199180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return true; 200180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang} 201180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 202180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangvoid NuPlayer::StreamingSource::setError(status_t err) { 203180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang Mutex::Autolock _l(mBufferingLock); 204180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mFinalResult = err; 205180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang} 206180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 207180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangsp<AnotherPacketSource> NuPlayer::StreamingSource::getSource(bool audio) { 208ab05b4ccb8ea59079d7f773aa0e090029c479badWei Jia if (mTSParser == NULL) { 209ab05b4ccb8ea59079d7f773aa0e090029c479badWei Jia return NULL; 210ab05b4ccb8ea59079d7f773aa0e090029c479badWei Jia } 211ab05b4ccb8ea59079d7f773aa0e090029c479badWei Jia 212180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang sp<MediaSource> source = mTSParser->getSource( 213180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang audio ? ATSParser::AUDIO : ATSParser::VIDEO); 2145bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 215180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang return static_cast<AnotherPacketSource *>(source.get()); 216180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang} 217180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 218180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangsp<MetaData> NuPlayer::StreamingSource::getFormatMeta(bool audio) { 219180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang sp<AnotherPacketSource> source = getSource(audio); 2205bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 2215bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 2225bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return NULL; 2235bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 2245bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 2255bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return source->getFormat(); 2265bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 2275bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 2285bc087c573c70c84c6a39946457590b42d392a33Andreas Huberstatus_t NuPlayer::StreamingSource::dequeueAccessUnit( 2295bc087c573c70c84c6a39946457590b42d392a33Andreas Huber bool audio, sp<ABuffer> *accessUnit) { 230180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang sp<AnotherPacketSource> source = getSource(audio); 2315bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 2325bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 2335bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return -EWOULDBLOCK; 2345bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 2355bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 236180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang if (!haveSufficientDataOnAllTracks()) { 237180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang postReadBuffer(); 238180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 239180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 2405bc087c573c70c84c6a39946457590b42d392a33Andreas Huber status_t finalResult; 2415bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (!source->hasBufferAvailable(&finalResult)) { 2425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return finalResult == OK ? -EWOULDBLOCK : finalResult; 2435bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 2445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 24587f2a558dd12043631e12c361abef301bf603140Andreas Huber status_t err = source->dequeueAccessUnit(accessUnit); 24687f2a558dd12043631e12c361abef301bf603140Andreas Huber 24787f2a558dd12043631e12c361abef301bf603140Andreas Huber#if !defined(LOG_NDEBUG) || LOG_NDEBUG == 0 24887f2a558dd12043631e12c361abef301bf603140Andreas Huber if (err == OK) { 24987f2a558dd12043631e12c361abef301bf603140Andreas Huber int64_t timeUs; 25087f2a558dd12043631e12c361abef301bf603140Andreas Huber CHECK((*accessUnit)->meta()->findInt64("timeUs", &timeUs)); 25187f2a558dd12043631e12c361abef301bf603140Andreas Huber ALOGV("dequeueAccessUnit timeUs=%lld us", timeUs); 25287f2a558dd12043631e12c361abef301bf603140Andreas Huber } 25387f2a558dd12043631e12c361abef301bf603140Andreas Huber#endif 25487f2a558dd12043631e12c361abef301bf603140Andreas Huber 25587f2a558dd12043631e12c361abef301bf603140Andreas Huber return err; 2565bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 2575bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 258d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huberbool NuPlayer::StreamingSource::isRealTime() const { 259d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber return mSource->flags() & IStreamSource::kFlagIsRealTimeData; 260d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber} 261d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 262180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhangvoid NuPlayer::StreamingSource::onMessageReceived( 263180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang const sp<AMessage> &msg) { 264180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang switch (msg->what()) { 265180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang case kWhatReadBuffer: 266180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang { 267180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang onReadBuffer(); 268180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 269180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang { 270180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang Mutex::Autolock _l(mBufferingLock); 271180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang mBuffering = false; 272180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 273180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang break; 274180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 275180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang default: 276180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang { 277180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang TRESPASS(); 278180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 279180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang } 280180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang} 281180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 282180d1b96ee2312f1056a58e26884a89d25ab62c8Chong Zhang 2835bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} // namespace android 2845bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 285