StreamingSource.cpp revision bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813
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 355bc087c573c70c84c6a39946457590b42d392a33Andreas HuberNuPlayer::StreamingSource::StreamingSource(const sp<IStreamSource> &source) 365bc087c573c70c84c6a39946457590b42d392a33Andreas Huber : mSource(source), 37eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber mFinalResult(OK) { 385bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 395bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 405bc087c573c70c84c6a39946457590b42d392a33Andreas HuberNuPlayer::StreamingSource::~StreamingSource() { 415bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 435bc087c573c70c84c6a39946457590b42d392a33Andreas Hubervoid NuPlayer::StreamingSource::start() { 445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mStreamListener = new NuPlayerStreamListener(mSource, 0); 45c4c17d47b674b425fb6c399822c0ab3258543c0aAndreas Huber mTSParser = new ATSParser(ATSParser::TS_TIMESTAMPS_ARE_ABSOLUTE); 465bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 475bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mStreamListener->start(); 485bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 495bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 50eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huberstatus_t NuPlayer::StreamingSource::feedMoreTSData() { 51eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber if (mFinalResult != OK) { 52eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber return mFinalResult; 535bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 545bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 55078cfcf7cce9185ec7559910d08b0bc02bfc88a3Andreas Huber for (int32_t i = 0; i < 50; ++i) { 565bc087c573c70c84c6a39946457590b42d392a33Andreas Huber char buffer[188]; 5732f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber sp<AMessage> extra; 5832f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber ssize_t n = mStreamListener->read(buffer, sizeof(buffer), &extra); 595bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 605bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (n == 0) { 615bc087c573c70c84c6a39946457590b42d392a33Andreas Huber LOGI("input data EOS reached."); 625bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalEOS(ERROR_END_OF_STREAM); 63eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber mFinalResult = ERROR_END_OF_STREAM; 645bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 655bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n == INFO_DISCONTINUITY) { 66bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber int32_t type = ATSParser::DISCONTINUITY_SEEK; 6742e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber 68bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber int32_t mask; 6942e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber if (extra != NULL 7042e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber && extra->findInt32( 71bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber IStreamListener::kKeyDiscontinuityMask, &mask)) { 72bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber if (mask == 0) { 73bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber LOGE("Client specified an illegal discontinuity type."); 74bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber return ERROR_UNSUPPORTED; 75bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber } 76bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber 77bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber type = mask; 7842e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber } 7942e549e4ab54802d788c43e3a04a85b7a1a95e97Andreas Huber 80bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber mTSParser->signalDiscontinuity( 81bfcc8d8ab7c56bc013bd221a29e1ecf3a6390813Andreas Huber (ATSParser::DiscontinuityType)type, extra); 825bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n < 0) { 835bc087c573c70c84c6a39946457590b42d392a33Andreas Huber CHECK_EQ(n, -EWOULDBLOCK); 845bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 855bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 865bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (buffer[0] == 0x00) { 875bc087c573c70c84c6a39946457590b42d392a33Andreas Huber // XXX legacy 885bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalDiscontinuity( 895bc087c573c70c84c6a39946457590b42d392a33Andreas Huber buffer[1] == 0x00 905bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ? ATSParser::DISCONTINUITY_SEEK 9132f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber : ATSParser::DISCONTINUITY_FORMATCHANGE, 9232f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber extra); 935bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 9406528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber status_t err = mTSParser->feedTSPacket(buffer, sizeof(buffer)); 9506528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 9606528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber if (err != OK) { 9706528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber LOGE("TS Parser returned error %d", err); 9806528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 9906528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber mTSParser->signalEOS(err); 100eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber mFinalResult = err; 10106528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber break; 10206528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber } 1035bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1045bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1055bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1065bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 107eac68baf095aeef54865c28b6888924dc6295cbdAndreas Huber return OK; 1085bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1095bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1105bc087c573c70c84c6a39946457590b42d392a33Andreas Hubersp<MetaData> NuPlayer::StreamingSource::getFormat(bool audio) { 1115bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ATSParser::SourceType type = 112386d609dc513e838c7e7c4c46c604493ccd560beAndreas Huber audio ? ATSParser::AUDIO : ATSParser::VIDEO; 1135bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1145bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<AnotherPacketSource> source = 1155bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<AnotherPacketSource *>(mTSParser->getSource(type).get()); 1165bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1175bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 1185bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return NULL; 1195bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1205bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1215bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return source->getFormat(); 1225bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1235bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1245bc087c573c70c84c6a39946457590b42d392a33Andreas Huberstatus_t NuPlayer::StreamingSource::dequeueAccessUnit( 1255bc087c573c70c84c6a39946457590b42d392a33Andreas Huber bool audio, sp<ABuffer> *accessUnit) { 1265bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ATSParser::SourceType type = 127386d609dc513e838c7e7c4c46c604493ccd560beAndreas Huber audio ? ATSParser::AUDIO : ATSParser::VIDEO; 1285bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1295bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<AnotherPacketSource> source = 1305bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<AnotherPacketSource *>(mTSParser->getSource(type).get()); 1315bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1325bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 1335bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return -EWOULDBLOCK; 1345bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1355bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1365bc087c573c70c84c6a39946457590b42d392a33Andreas Huber status_t finalResult; 1375bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (!source->hasBufferAvailable(&finalResult)) { 1385bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return finalResult == OK ? -EWOULDBLOCK : finalResult; 1395bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1405bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1415bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return source->dequeueAccessUnit(accessUnit); 1425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1435bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} // namespace android 1455bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 146