StreamingSource.cpp revision fef808d42a9c94b0b5ef3c3d5fb0a090edbc42da
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), 40eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber mFinalResult(OK) { 415bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 435bc087c573c70c84c6a39946457590b42d392a33Andreas HuberNuPlayer::StreamingSource::~StreamingSource() { 445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 455bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 469575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Hubervoid NuPlayer::StreamingSource::prepareAsync() { 47ced1c2f8f6c422063092f5cc5c675ccdebb2dc10Chong Zhang notifyVideoSizeChanged(); 489575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber notifyFlagsChanged(0); 499575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber notifyPrepared(); 509575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber} 519575c96b6e418914e2ffc6741ecc8d71e3968dbeAndreas Huber 525bc087c573c70c84c6a39946457590b42d392a33Andreas Hubervoid NuPlayer::StreamingSource::start() { 535bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mStreamListener = new NuPlayerStreamListener(mSource, 0); 5487f2a558dd12043631e12c361abef301bf603140Andreas Huber 5587f2a558dd12043631e12c361abef301bf603140Andreas Huber uint32_t sourceFlags = mSource->flags(); 5687f2a558dd12043631e12c361abef301bf603140Andreas Huber 5787f2a558dd12043631e12c361abef301bf603140Andreas Huber uint32_t parserFlags = ATSParser::TS_TIMESTAMPS_ARE_ABSOLUTE; 5887f2a558dd12043631e12c361abef301bf603140Andreas Huber if (sourceFlags & IStreamSource::kFlagAlignedVideoData) { 5987f2a558dd12043631e12c361abef301bf603140Andreas Huber parserFlags |= ATSParser::ALIGNED_VIDEO_DATA; 6087f2a558dd12043631e12c361abef301bf603140Andreas Huber } 6187f2a558dd12043631e12c361abef301bf603140Andreas Huber 6287f2a558dd12043631e12c361abef301bf603140Andreas Huber mTSParser = new ATSParser(parserFlags); 635bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 645bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mStreamListener->start(); 655bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 665bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 67eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huberstatus_t NuPlayer::StreamingSource::feedMoreTSData() { 68eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber if (mFinalResult != OK) { 69eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber return mFinalResult; 705bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 715bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 72078cfcf7cce9185ec7559910d08b0bc02bfc88a3Andreas Huber for (int32_t i = 0; i < 50; ++i) { 735bc087c573c70c84c6a39946457590b42d392a33Andreas Huber char buffer[188]; 7432f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber sp<AMessage> extra; 7532f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber ssize_t n = mStreamListener->read(buffer, sizeof(buffer), &extra); 765bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 775bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (n == 0) { 78df64d15042bbd5e0e4933ac49bf3c177dd94752cSteve Block ALOGI("input data EOS reached."); 795bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalEOS(ERROR_END_OF_STREAM); 80eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber mFinalResult = ERROR_END_OF_STREAM; 815bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 825bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n == INFO_DISCONTINUITY) { 83fef808d42a9c94b0b5ef3c3d5fb0a090edbc42daWei Jia int32_t type = ATSParser::DISCONTINUITY_TIME; 8442e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber 85bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber int32_t mask; 8642e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber if (extra != NULL 8742e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber && extra->findInt32( 88bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber IStreamListener::kKeyDiscontinuityMask, &mask)) { 89bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber if (mask == 0) { 9029357bc2c0dd7c43ad3bd0c8e3efa4e6fd9bfd47Steve Block ALOGE("Client specified an illegal discontinuity type."); 91bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber return ERROR_UNSUPPORTED; 92bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber } 93bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber 94bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber type = mask; 9542e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber } 9642e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber 97bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber mTSParser->signalDiscontinuity( 98bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber (ATSParser::DiscontinuityType)type, extra); 995bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n < 0) { 1005bc087c573c70c84c6a39946457590b42d392a33Andreas Huber CHECK_EQ(n, -EWOULDBLOCK); 1015bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 1025bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 1035bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (buffer[0] == 0x00) { 1045bc087c573c70c84c6a39946457590b42d392a33Andreas Huber // XXX legacy 105b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 106b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber if (extra == NULL) { 107b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber extra = new AMessage; 108b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber } 109b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 110b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber uint8_t type = buffer[1]; 111b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 112b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber if (type & 2) { 113b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber int64_t mediaTimeUs; 114b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber memcpy(&mediaTimeUs, &buffer[2], sizeof(mediaTimeUs)); 115b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 116b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber extra->setInt64(IStreamListener::kKeyMediaTimeUs, mediaTimeUs); 117b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber } 118b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber 1195bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalDiscontinuity( 120b7c8e91880463ff4981e3e53e98e45d68e2fe374Andreas Huber ((type & 1) == 0) 121fef808d42a9c94b0b5ef3c3d5fb0a090edbc42daWei Jia ? ATSParser::DISCONTINUITY_TIME 12232f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber : ATSParser::DISCONTINUITY_FORMATCHANGE, 12332f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber extra); 1245bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 12506528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber status_t err = mTSParser->feedTSPacket(buffer, sizeof(buffer)); 12606528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 12706528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber if (err != OK) { 12829357bc2c0dd7c43ad3bd0c8e3efa4e6fd9bfd47Steve Block ALOGE("TS Parser returned error %d", err); 12906528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 13006528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber mTSParser->signalEOS(err); 131eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber mFinalResult = err; 13206528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber break; 13306528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber } 1345bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1355bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1365bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1375bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 138eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber return OK; 1395bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1405bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 141840667883fd09d44015716d79bc3ac4d60edc0f0Andreas Hubersp<MetaData> NuPlayer::StreamingSource::getFormatMeta(bool audio) { 1425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ATSParser::SourceType type = 143386d609dc513e838c7e7c4c46c604493ccd560beAndreas Huber audio ? ATSParser::AUDIO : ATSParser::VIDEO; 1445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1455bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<AnotherPacketSource> source = 1465bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<AnotherPacketSource *>(mTSParser->getSource(type).get()); 1475bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1485bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 1495bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return NULL; 1505bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1515bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1525bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return source->getFormat(); 1535bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1545bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1555bc087c573c70c84c6a39946457590b42d392a33Andreas Huberstatus_t NuPlayer::StreamingSource::dequeueAccessUnit( 1565bc087c573c70c84c6a39946457590b42d392a33Andreas Huber bool audio, sp<ABuffer> *accessUnit) { 1575bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ATSParser::SourceType type = 158386d609dc513e838c7e7c4c46c604493ccd560beAndreas Huber audio ? ATSParser::AUDIO : ATSParser::VIDEO; 1595bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1605bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<AnotherPacketSource> source = 1615bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<AnotherPacketSource *>(mTSParser->getSource(type).get()); 1625bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1635bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 1645bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return -EWOULDBLOCK; 1655bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1665bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1675bc087c573c70c84c6a39946457590b42d392a33Andreas Huber status_t finalResult; 1685bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (!source->hasBufferAvailable(&finalResult)) { 1695bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return finalResult == OK ? -EWOULDBLOCK : finalResult; 1705bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1715bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 17287f2a558dd12043631e12c361abef301bf603140Andreas Huber status_t err = source->dequeueAccessUnit(accessUnit); 17387f2a558dd12043631e12c361abef301bf603140Andreas Huber 17487f2a558dd12043631e12c361abef301bf603140Andreas Huber#if !defined(LOG_NDEBUG) || LOG_NDEBUG == 0 17587f2a558dd12043631e12c361abef301bf603140Andreas Huber if (err == OK) { 17687f2a558dd12043631e12c361abef301bf603140Andreas Huber int64_t timeUs; 17787f2a558dd12043631e12c361abef301bf603140Andreas Huber CHECK((*accessUnit)->meta()->findInt64("timeUs", &timeUs)); 17887f2a558dd12043631e12c361abef301bf603140Andreas Huber ALOGV("dequeueAccessUnit timeUs=%lld us", timeUs); 17987f2a558dd12043631e12c361abef301bf603140Andreas Huber } 18087f2a558dd12043631e12c361abef301bf603140Andreas Huber#endif 18187f2a558dd12043631e12c361abef301bf603140Andreas Huber 18287f2a558dd12043631e12c361abef301bf603140Andreas Huber return err; 1835bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1845bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 185d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huberbool NuPlayer::StreamingSource::isRealTime() const { 186d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber return mSource->flags() & IStreamSource::kFlagIsRealTimeData; 187d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber} 188d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 1895bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} // namespace android 1905bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 191