/* * Copyright (C) 2010 The Android Open Source Project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ //#define LOG_NDEBUG 0 #define LOG_TAG "HTTPLiveSource" #include #include "HTTPLiveSource.h" #include "AnotherPacketSource.h" #include "LiveDataSource.h" #include "LiveSession.h" #include #include #include #include #include #include namespace android { NuPlayer::HTTPLiveSource::HTTPLiveSource( const sp ¬ify, const sp &httpService, const char *url, const KeyedVector *headers) : Source(notify), mHTTPService(httpService), mURL(url), mFlags(0), mFinalResult(OK), mOffset(0), mFetchSubtitleDataGeneration(0) { if (headers) { mExtraHeaders = *headers; ssize_t index = mExtraHeaders.indexOfKey(String8("x-hide-urls-from-log")); if (index >= 0) { mFlags |= kFlagIncognito; mExtraHeaders.removeItemsAt(index); } } } NuPlayer::HTTPLiveSource::~HTTPLiveSource() { if (mLiveSession != NULL) { mLiveSession->disconnect(); mLiveLooper->unregisterHandler(mLiveSession->id()); mLiveLooper->unregisterHandler(id()); mLiveLooper->stop(); mLiveSession.clear(); mLiveLooper.clear(); } } void NuPlayer::HTTPLiveSource::prepareAsync() { if (mLiveLooper == NULL) { mLiveLooper = new ALooper; mLiveLooper->setName("http live"); mLiveLooper->start(); mLiveLooper->registerHandler(this); } sp notify = new AMessage(kWhatSessionNotify, id()); mLiveSession = new LiveSession( notify, (mFlags & kFlagIncognito) ? LiveSession::kFlagIncognito : 0, mHTTPService); mLiveLooper->registerHandler(mLiveSession); mLiveSession->connectAsync( mURL.c_str(), mExtraHeaders.isEmpty() ? NULL : &mExtraHeaders); } void NuPlayer::HTTPLiveSource::start() { } sp NuPlayer::HTTPLiveSource::getFormat(bool audio) { if (mLiveSession == NULL) { return NULL; } sp format; status_t err = mLiveSession->getStreamFormat( audio ? LiveSession::STREAMTYPE_AUDIO : LiveSession::STREAMTYPE_VIDEO, &format); if (err != OK) { return NULL; } return format; } status_t NuPlayer::HTTPLiveSource::feedMoreTSData() { return OK; } status_t NuPlayer::HTTPLiveSource::dequeueAccessUnit( bool audio, sp *accessUnit) { return mLiveSession->dequeueAccessUnit( audio ? LiveSession::STREAMTYPE_AUDIO : LiveSession::STREAMTYPE_VIDEO, accessUnit); } status_t NuPlayer::HTTPLiveSource::getDuration(int64_t *durationUs) { return mLiveSession->getDuration(durationUs); } size_t NuPlayer::HTTPLiveSource::getTrackCount() const { return mLiveSession->getTrackCount(); } sp NuPlayer::HTTPLiveSource::getTrackInfo(size_t trackIndex) const { return mLiveSession->getTrackInfo(trackIndex); } ssize_t NuPlayer::HTTPLiveSource::getSelectedTrack(media_track_type type) const { if (mLiveSession == NULL) { return -1; } else { return mLiveSession->getSelectedTrack(type); } } status_t NuPlayer::HTTPLiveSource::selectTrack(size_t trackIndex, bool select, int64_t /*timeUs*/) { status_t err = mLiveSession->selectTrack(trackIndex, select); if (err == OK) { mFetchSubtitleDataGeneration++; if (select) { sp msg = new AMessage(kWhatFetchSubtitleData, id()); msg->setInt32("generation", mFetchSubtitleDataGeneration); msg->post(); } } // LiveSession::selectTrack returns BAD_VALUE when selecting the currently // selected track, or unselecting a non-selected track. In this case it's an // no-op so we return OK. return (err == OK || err == BAD_VALUE) ? (status_t)OK : err; } status_t NuPlayer::HTTPLiveSource::seekTo(int64_t seekTimeUs) { return mLiveSession->seekTo(seekTimeUs); } void NuPlayer::HTTPLiveSource::onMessageReceived(const sp &msg) { switch (msg->what()) { case kWhatSessionNotify: { onSessionNotify(msg); break; } case kWhatFetchSubtitleData: { int32_t generation; CHECK(msg->findInt32("generation", &generation)); if (generation != mFetchSubtitleDataGeneration) { // stale break; } sp buffer; if (mLiveSession->dequeueAccessUnit( LiveSession::STREAMTYPE_SUBTITLES, &buffer) == OK) { sp notify = dupNotify(); notify->setInt32("what", kWhatSubtitleData); notify->setBuffer("buffer", buffer); notify->post(); int64_t timeUs, baseUs, durationUs, delayUs; CHECK(buffer->meta()->findInt64("baseUs", &baseUs)); CHECK(buffer->meta()->findInt64("timeUs", &timeUs)); CHECK(buffer->meta()->findInt64("durationUs", &durationUs)); delayUs = baseUs + timeUs - ALooper::GetNowUs(); msg->post(delayUs > 0ll ? delayUs : 0ll); } else { // try again in 1 second msg->post(1000000ll); } break; } default: Source::onMessageReceived(msg); break; } } void NuPlayer::HTTPLiveSource::onSessionNotify(const sp &msg) { int32_t what; CHECK(msg->findInt32("what", &what)); switch (what) { case LiveSession::kWhatPrepared: { // notify the current size here if we have it, otherwise report an initial size of (0,0) sp format = getFormat(false /* audio */); int32_t width; int32_t height; if (format != NULL && format->findInt32("width", &width) && format->findInt32("height", &height)) { notifyVideoSizeChanged(format); } else { notifyVideoSizeChanged(); } uint32_t flags = FLAG_CAN_PAUSE; if (mLiveSession->isSeekable()) { flags |= FLAG_CAN_SEEK; flags |= FLAG_CAN_SEEK_BACKWARD; flags |= FLAG_CAN_SEEK_FORWARD; } if (mLiveSession->hasDynamicDuration()) { flags |= FLAG_DYNAMIC_DURATION; } notifyFlagsChanged(flags); notifyPrepared(); break; } case LiveSession::kWhatPreparationFailed: { status_t err; CHECK(msg->findInt32("err", &err)); notifyPrepared(err); break; } case LiveSession::kWhatStreamsChanged: { uint32_t changedMask; CHECK(msg->findInt32( "changedMask", (int32_t *)&changedMask)); bool audio = changedMask & LiveSession::STREAMTYPE_AUDIO; bool video = changedMask & LiveSession::STREAMTYPE_VIDEO; sp reply; CHECK(msg->findMessage("reply", &reply)); sp notify = dupNotify(); notify->setInt32("what", kWhatQueueDecoderShutdown); notify->setInt32("audio", audio); notify->setInt32("video", video); notify->setMessage("reply", reply); notify->post(); break; } case LiveSession::kWhatError: { break; } default: TRESPASS(); } } } // namespace android