HTTPLiveSource.cpp revision dc9bacd838442a524585887e6ea6696836be2eda
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 "HTTPLiveSource" 195bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <utils/Log.h> 205bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 215bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "HTTPLiveSource.h" 225bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 235bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "ATSParser.h" 245bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "AnotherPacketSource.h" 255bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "LiveDataSource.h" 265bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include "LiveSession.h" 275bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 285bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/foundation/ABuffer.h> 295bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/foundation/ADebug.h> 305bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/foundation/AMessage.h> 315bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/MediaErrors.h> 325bc087c573c70c84c6a39946457590b42d392a33Andreas Huber#include <media/stagefright/MetaData.h> 335bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 345bc087c573c70c84c6a39946457590b42d392a33Andreas Hubernamespace android { 355bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 36ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas HuberNuPlayer::HTTPLiveSource::HTTPLiveSource( 37ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber const char *url, 389b80c2bdb205bc143104f54d0743b6eedd67b14eAndreas Huber const KeyedVector<String8, String8> *headers, 399b80c2bdb205bc143104f54d0743b6eedd67b14eAndreas Huber bool uidValid, uid_t uid) 405bc087c573c70c84c6a39946457590b42d392a33Andreas Huber : mURL(url), 419b80c2bdb205bc143104f54d0743b6eedd67b14eAndreas Huber mUIDValid(uidValid), 429b80c2bdb205bc143104f54d0743b6eedd67b14eAndreas Huber mUID(uid), 43ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mFlags(0), 445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mEOS(false), 455bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mOffset(0) { 46ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber if (headers) { 47ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mExtraHeaders = *headers; 48ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber 49ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber ssize_t index = 50ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mExtraHeaders.indexOfKey(String8("x-hide-urls-from-log")); 51ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber 52ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber if (index >= 0) { 53ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mFlags |= kFlagIncognito; 54ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber 55ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mExtraHeaders.removeItemsAt(index); 56ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber } 57ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber } 585bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 595bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 605bc087c573c70c84c6a39946457590b42d392a33Andreas HuberNuPlayer::HTTPLiveSource::~HTTPLiveSource() { 612048d0cfccce48be26816dec8711a6691ebff71cAndreas Huber if (mLiveSession != NULL) { 622048d0cfccce48be26816dec8711a6691ebff71cAndreas Huber mLiveSession->disconnect(); 632048d0cfccce48be26816dec8711a6691ebff71cAndreas Huber mLiveLooper->stop(); 642048d0cfccce48be26816dec8711a6691ebff71cAndreas Huber } 655bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 665bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 675bc087c573c70c84c6a39946457590b42d392a33Andreas Hubervoid NuPlayer::HTTPLiveSource::start() { 685bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mLiveLooper = new ALooper; 695bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mLiveLooper->setName("http live"); 705bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mLiveLooper->start(); 715bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 727314fa17093d514199fedcb55ac41136a1b31cb3Andreas Huber mLiveSession = new LiveSession( 739b80c2bdb205bc143104f54d0743b6eedd67b14eAndreas Huber (mFlags & kFlagIncognito) ? LiveSession::kFlagIncognito : 0, 749b80c2bdb205bc143104f54d0743b6eedd67b14eAndreas Huber mUIDValid, mUID); 757314fa17093d514199fedcb55ac41136a1b31cb3Andreas Huber 765bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mLiveLooper->registerHandler(mLiveSession); 775bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 78ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mLiveSession->connect( 79ad0d9c9c39a24b7fbd94e935a5855c9025341929Andreas Huber mURL.c_str(), mExtraHeaders.isEmpty() ? NULL : &mExtraHeaders); 805bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 815bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser = new ATSParser; 825bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 835bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 845bc087c573c70c84c6a39946457590b42d392a33Andreas Hubersp<MetaData> NuPlayer::HTTPLiveSource::getFormat(bool audio) { 855bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ATSParser::SourceType type = 86386d609dc513e838c7e7c4c46c604493ccd560beAndreas Huber audio ? ATSParser::AUDIO : ATSParser::VIDEO; 875bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 885bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<AnotherPacketSource> source = 895bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<AnotherPacketSource *>(mTSParser->getSource(type).get()); 905bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 915bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 925bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return NULL; 935bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 945bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 955bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return source->getFormat(); 965bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 975bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 985bc087c573c70c84c6a39946457590b42d392a33Andreas Huberbool NuPlayer::HTTPLiveSource::feedMoreTSData() { 995bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (mEOS) { 1005bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return false; 1015bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1025bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1035bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<LiveDataSource> source = 1045bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<LiveDataSource *>(mLiveSession->getDataSource().get()); 1055bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 10622fc52f6f72f39e33c3970d0291de3569118aa5cAndreas Huber for (int32_t i = 0; i < 50; ++i) { 1075bc087c573c70c84c6a39946457590b42d392a33Andreas Huber char buffer[188]; 1085bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ssize_t n = source->readAtNonBlocking(mOffset, buffer, sizeof(buffer)); 1095bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1105bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (n == -EWOULDBLOCK) { 1115bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 1125bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else if (n < 0) { 113dc9bacd838442a524585887e6ea6696836be2edaAndreas Huber if (n != ERROR_END_OF_STREAM) { 114dc9bacd838442a524585887e6ea6696836be2edaAndreas Huber LOGI("input data EOS reached, error %d", n); 115dc9bacd838442a524585887e6ea6696836be2edaAndreas Huber } else { 116dc9bacd838442a524585887e6ea6696836be2edaAndreas Huber LOGI("input data EOS reached."); 117dc9bacd838442a524585887e6ea6696836be2edaAndreas Huber } 1181aef211b4e5dc952081727bfd2318b2cb5ca4506Andreas Huber mTSParser->signalEOS(n); 1195bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mEOS = true; 1205bc087c573c70c84c6a39946457590b42d392a33Andreas Huber break; 1215bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 1225bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (buffer[0] == 0x00) { 1235bc087c573c70c84c6a39946457590b42d392a33Andreas Huber // XXX legacy 12432f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber sp<AMessage> extra; 1255bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mTSParser->signalDiscontinuity( 1265bc087c573c70c84c6a39946457590b42d392a33Andreas Huber buffer[1] == 0x00 1275bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ? ATSParser::DISCONTINUITY_SEEK 12832f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber : ATSParser::DISCONTINUITY_FORMATCHANGE, 12932f3cefa373cd55e63deda36ca9d07c7fe22eaafAndreas Huber extra); 1305bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } else { 13106528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber status_t err = mTSParser->feedTSPacket(buffer, sizeof(buffer)); 13206528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber 13306528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber if (err != OK) { 13406528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber LOGE("TS Parser returned error %d", err); 13506528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber mTSParser->signalEOS(err); 13606528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber mEOS = true; 13706528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber break; 13806528d7f18ad01377357d337eaa3e875a242bd2dAndreas Huber } 1395bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1405bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1415bc087c573c70c84c6a39946457590b42d392a33Andreas Huber mOffset += n; 1425bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1435bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1445bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1455bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return true; 1465bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1475bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1485bc087c573c70c84c6a39946457590b42d392a33Andreas Huberstatus_t NuPlayer::HTTPLiveSource::dequeueAccessUnit( 1495bc087c573c70c84c6a39946457590b42d392a33Andreas Huber bool audio, sp<ABuffer> *accessUnit) { 1505bc087c573c70c84c6a39946457590b42d392a33Andreas Huber ATSParser::SourceType type = 151386d609dc513e838c7e7c4c46c604493ccd560beAndreas Huber audio ? ATSParser::AUDIO : ATSParser::VIDEO; 1525bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1535bc087c573c70c84c6a39946457590b42d392a33Andreas Huber sp<AnotherPacketSource> source = 1545bc087c573c70c84c6a39946457590b42d392a33Andreas Huber static_cast<AnotherPacketSource *>(mTSParser->getSource(type).get()); 1555bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1565bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (source == NULL) { 1575bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return -EWOULDBLOCK; 1585bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1595bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1605bc087c573c70c84c6a39946457590b42d392a33Andreas Huber status_t finalResult; 1615bc087c573c70c84c6a39946457590b42d392a33Andreas Huber if (!source->hasBufferAvailable(&finalResult)) { 1625bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return finalResult == OK ? -EWOULDBLOCK : finalResult; 1635bc087c573c70c84c6a39946457590b42d392a33Andreas Huber } 1645bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 1655bc087c573c70c84c6a39946457590b42d392a33Andreas Huber return source->dequeueAccessUnit(accessUnit); 1665bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} 1675bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 16843c3e6ce02215ca99d506458f596cb1211639f29Andreas Huberstatus_t NuPlayer::HTTPLiveSource::getDuration(int64_t *durationUs) { 16943c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber return mLiveSession->getDuration(durationUs); 17043c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber} 17143c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber 17243c3e6ce02215ca99d506458f596cb1211639f29Andreas Huberstatus_t NuPlayer::HTTPLiveSource::seekTo(int64_t seekTimeUs) { 17343c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber // We need to make sure we're not seeking until we have seen the very first 17443c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber // PTS timestamp in the whole stream (from the beginning of the stream). 17543c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber while (!mTSParser->PTSTimeDeltaEstablished() && feedMoreTSData()) { 17643c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber usleep(100000); 17743c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber } 17843c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber 17943c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber mLiveSession->seekTo(seekTimeUs); 18043c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber 18143c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber return OK; 18243c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber} 18343c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber 18443c3e6ce02215ca99d506458f596cb1211639f29Andreas Huberbool NuPlayer::HTTPLiveSource::isSeekable() { 18543c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber return mLiveSession->isSeekable(); 18643c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber} 18743c3e6ce02215ca99d506458f596cb1211639f29Andreas Huber 1885bc087c573c70c84c6a39946457590b42d392a33Andreas Huber} // namespace android 1895bc087c573c70c84c6a39946457590b42d392a33Andreas Huber 190