PlaylistFetcher.h revision 25f82752942b1c78aec8ee303d61afff85cff9d1
114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber/* 214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * Copyright (C) 2012 The Android Open Source Project 314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * 414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * Licensed under the Apache License, Version 2.0 (the "License"); 514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * you may not use this file except in compliance with the License. 614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * You may obtain a copy of the License at 714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * 814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * http://www.apache.org/licenses/LICENSE-2.0 914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * 1014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * Unless required by applicable law or agreed to in writing, software 1114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * distributed under the License is distributed on an "AS IS" BASIS, 1214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * See the License for the specific language governing permissions and 1414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber * limitations under the License. 1514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber */ 1614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 1714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber#ifndef PLAYLIST_FETCHER_H_ 1814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 1914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber#define PLAYLIST_FETCHER_H_ 2014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 2114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber#include <media/stagefright/foundation/AHandler.h> 2214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 2314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber#include "mpeg2ts/ATSParser.h" 2414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber#include "LiveSession.h" 2514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 2614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Hubernamespace android { 2714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 2814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct ABuffer; 2914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct AnotherPacketSource; 3014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct DataSource; 3114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct HTTPBase; 3214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct LiveDataSource; 3314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct M3UParser; 3486a58cabe322b746ab0eb17f0cade34ed68ba60eBernhard Rosenkränzerclass String8; 3514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 3614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberstruct PlaylistFetcher : public AHandler { 37174609765fb9c8cbd6aeb61f489746c3570bfee2Leena Winterrowd static const int64_t kMinBufferedDurationUs; 38a93fd2be99d21629bed504b9b7df035fc2f54562Leena Winterrowd static const int32_t kDownloadBlockSize; 39964adb17885185808398507d2de88665fe193ee2Chong Zhang static const int64_t kFetcherResumeThreshold; 40174609765fb9c8cbd6aeb61f489746c3570bfee2Leena Winterrowd 4114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber enum { 4214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatStarted, 4314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatPaused, 4414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatStopped, 4514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatError, 4614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatDurationUpdate, 477c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang kWhatTargetDurationUpdate, 4814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatPrepared, 4914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatPreparationFailed, 50777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih kWhatStartedAt, 517c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang kWhatStopReached, 5214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber }; 5314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 5414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber PlaylistFetcher( 5514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber const sp<AMessage> ¬ify, 5614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber const sp<LiveSession> &session, 57b44ce2f84691559672cfaf6bb8fd3a9ac43904f2Robert Shih const char *uri, 5825f82752942b1c78aec8ee303d61afff85cff9d1Chong Zhang int32_t id, 59b44ce2f84691559672cfaf6bb8fd3a9ac43904f2Robert Shih int32_t subtitleGeneration); 6014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 6125f82752942b1c78aec8ee303d61afff85cff9d1Chong Zhang int32_t getFetcherID() const; 6225f82752942b1c78aec8ee303d61afff85cff9d1Chong Zhang 6314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber sp<DataSource> getDataSource(); 6414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 6514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void startAsync( 6614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber const sp<AnotherPacketSource> &audioSource, 6714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber const sp<AnotherPacketSource> &videoSource, 6814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber const sp<AnotherPacketSource> &subtitleSource, 69309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih int64_t startTimeUs = -1ll, // starting timestamps 70309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih int64_t segmentStartTimeUs = -1ll, // starting position within playlist 71309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih // startTimeUs!=segmentStartTimeUs only when playlist is live 727c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang int32_t startDiscontinuitySeq = -1, 73a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang LiveSession::SeekMode seekMode = LiveSession::kSeekModeExactPosition); 7414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 75a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang void pauseAsync(float thresholdRatio); 7614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 77309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih void stopAsync(bool clear = true); 7814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 79777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih void resumeUntilAsync(const sp<AMessage> ¶ms); 80777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih 8173d2847af14cdd5fdf8bd1ac80fb7ddf9ae7d9a7Robert Shih uint32_t getStreamTypeMask() const { 8273d2847af14cdd5fdf8bd1ac80fb7ddf9ae7d9a7Robert Shih return mStreamTypeMask; 8373d2847af14cdd5fdf8bd1ac80fb7ddf9ae7d9a7Robert Shih } 8473d2847af14cdd5fdf8bd1ac80fb7ddf9ae7d9a7Robert Shih 8514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberprotected: 8614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber virtual ~PlaylistFetcher(); 8714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber virtual void onMessageReceived(const sp<AMessage> &msg); 8814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 8914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huberprivate: 9014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber enum { 9114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kMaxNumRetries = 5, 9214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber }; 9314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 9414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber enum { 9514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatStart = 'strt', 9614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatPause = 'paus', 9714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatStop = 'stop', 9814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber kWhatMonitorQueue = 'moni', 99777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih kWhatResumeUntil = 'rsme', 100777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih kWhatDownloadNext = 'dlnx', 10114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber }; 10214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 103a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang struct DownloadState; 104a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang 1056708a45ba1b5eacf583d5e80b2075b68940fe0abLajos Molnar static const int64_t kMaxMonitorDelayUs; 106777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih static const int32_t kNumSkipFrames; 10714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 10843ca783effd99bba0e6e2dd6fe177a8888578ef8Robert Shih static bool bufferStartsWithTsSyncByte(const sp<ABuffer>& buffer); 1097d8e3ccfbf326b5e190b416590e956c2fc3021f7Lajos Molnar static bool bufferStartsWithWebVTTMagicSequence(const sp<ABuffer>& buffer); 11043ca783effd99bba0e6e2dd6fe177a8888578ef8Robert Shih 111777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih // notifications to mSession 11214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber sp<AMessage> mNotify; 113777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih sp<AMessage> mStartTimeUsNotify; 114777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih 115a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang sp<HTTPBase> mHTTPDataSource; 11614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber sp<LiveSession> mSession; 11714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber AString mURI; 11814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 11925f82752942b1c78aec8ee303d61afff85cff9d1Chong Zhang int32_t mFetcherID; 12025f82752942b1c78aec8ee303d61afff85cff9d1Chong Zhang 12114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber uint32_t mStreamTypeMask; 12214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int64_t mStartTimeUs; 123f78f62bd6b0a99747db53828d281a50b9270a646Robert Shih 124f78f62bd6b0a99747db53828d281a50b9270a646Robert Shih // Start time relative to the beginning of the first segment in the initial 125f78f62bd6b0a99747db53828d281a50b9270a646Robert Shih // playlist. It's value is initialized to a non-negative value only when we are 126f78f62bd6b0a99747db53828d281a50b9270a646Robert Shih // adapting or switching tracks. 127309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih int64_t mSegmentStartTimeUs; 128f78f62bd6b0a99747db53828d281a50b9270a646Robert Shih 1294604458dfe57b0e91a464aefafea50ae7b9876c1Chong Zhang int32_t mDiscontinuitySeq; 130309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih bool mStartTimeUsRelative; 131777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih sp<AMessage> mStopParams; // message containing the latest timestamps we should fetch. 13214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 13314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber KeyedVector<LiveSession::StreamType, sp<AnotherPacketSource> > 13414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber mPacketSources; 13514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 13614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber KeyedVector<AString, sp<ABuffer> > mAESKeyForURI; 13714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 13814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int64_t mLastPlaylistFetchTimeUs; 13914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber sp<M3UParser> mPlaylist; 14014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int32_t mSeqNumber; 14114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int32_t mNumRetries; 14214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber bool mStartup; 143c4547ba77f78632172db3647a09659d9863d3b5cChong Zhang bool mIDRFound; 144a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang int32_t mSeekMode; 145c4547ba77f78632172db3647a09659d9863d3b5cChong Zhang bool mTimeChangeSignaled; 14614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int64_t mNextPTSTimeUs; 14714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 14814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int32_t mMonitorQueueGeneration; 149b44ce2f84691559672cfaf6bb8fd3a9ac43904f2Robert Shih const int32_t mSubtitleGeneration; 15014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 151c4547ba77f78632172db3647a09659d9863d3b5cChong Zhang int32_t mLastDiscontinuitySeq; 152c4547ba77f78632172db3647a09659d9863d3b5cChong Zhang 15314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber enum RefreshState { 15414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber INITIAL_MINIMUM_RELOAD_DELAY, 15514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber FIRST_UNCHANGED_RELOAD_ATTEMPT, 15614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber SECOND_UNCHANGED_RELOAD_ATTEMPT, 15714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber THIRD_UNCHANGED_RELOAD_ATTEMPT 15814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber }; 15914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber RefreshState mRefreshState; 16014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 16114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber uint8_t mPlaylistHash[16]; 16214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 16314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber sp<ATSParser> mTSParser; 16414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 16514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber bool mFirstPTSValid; 166309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih int64_t mFirstTimeUs; 167a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang int64_t mSegmentFirstPTS; 168309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih sp<AnotherPacketSource> mVideoBuffer; 16914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 1702cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // Stores the initialization vector to decrypt the next block of cipher text, which can 1712cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // either be derived from the sequence number, read from the manifest, or copied from 1722cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // the last block of cipher text (cipher-block chaining). 1732cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih unsigned char mAESInitVec[16]; 1742cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih 175a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang Mutex mThresholdLock; 176a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang float mThresholdRatio; 177a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang 178a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang sp<DownloadState> mDownloadState; 179a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang 1802cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // Set first to true if decrypting the first segment of a playlist segment. When 1812cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // first is true, reset the initialization vector based on the available 1822cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // information in the manifest; otherwise, use the initialization vector as 1832cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // updated by the last call to AES_cbc_encrypt. 1842cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // 1852cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // For the input to decrypt correctly, decryptBuffer must be called on 1862cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // consecutive byte ranges on block boundaries, e.g. 0..15, 16..47, 48..63, 1872cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih // and so on. 18814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber status_t decryptBuffer( 1892cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih size_t playlistIndex, const sp<ABuffer> &buffer, 1902cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih bool first = true); 1912cd94583868b775a548233a4f7cd1d988fc6344fRobert Shih status_t checkDecryptPadding(const sp<ABuffer> &buffer); 19214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 1936708a45ba1b5eacf583d5e80b2075b68940fe0abLajos Molnar void postMonitorQueue(int64_t delayUs = 0, int64_t minDelayUs = 0); 19414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void cancelMonitorQueue(); 195a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang void setStoppingThreshold(float thresholdRatio); 1967c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang bool shouldPauseDownload(); 19714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 1986708a45ba1b5eacf583d5e80b2075b68940fe0abLajos Molnar int64_t delayUsToRefreshPlaylist() const; 1996708a45ba1b5eacf583d5e80b2075b68940fe0abLajos Molnar status_t refreshPlaylist(); 20014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 20114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber // Returns the media time in us of the segment specified by seqNumber. 20214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber // This is computed by summing the durations of all segments before it. 20314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int64_t getSegmentStartTimeUs(int32_t seqNumber) const; 2047c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang // Returns the duration time in us of the segment specified. 2057c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang int64_t getSegmentDurationUs(int32_t seqNumber) const; 20614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 20714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber status_t onStart(const sp<AMessage> &msg); 20814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void onPause(); 209ceeabe15f4e7bc73efdfcafed917202de9d515cbRobert Shih void onStop(const sp<AMessage> &msg); 21014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void onMonitorQueue(); 21114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void onDownloadNext(); 212a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang bool initDownloadState( 213a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang AString &uri, 214a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang sp<AMessage> &itemMeta, 215a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang int32_t &firstSeqNumberInPlaylist, 216a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang int32_t &lastSeqNumberInPlaylist); 21714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 218777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih // Resume a fetcher to continue until the stopping point stored in msg. 219777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih status_t onResumeUntil(const sp<AMessage> &msg); 220777ee5ed736c8f6c3f7d196ea022f7432bfd23e1Robert Shih 221309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih const sp<ABuffer> &setAccessUnitProperties( 222309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih const sp<ABuffer> &accessUnit, 223309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih const sp<AnotherPacketSource> &source, 224309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih bool discard = false); 22543ca783effd99bba0e6e2dd6fe177a8888578ef8Robert Shih status_t extractAndQueueAccessUnitsFromTs(const sp<ABuffer> &buffer); 22643ca783effd99bba0e6e2dd6fe177a8888578ef8Robert Shih 227dcb89b3b505522efde173c105a851c412f947178Chong Zhang status_t extractAndQueueAccessUnits( 228dcb89b3b505522efde173c105a851c412f947178Chong Zhang const sp<ABuffer> &buffer, const sp<AMessage> &itemMeta); 22914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 2307c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang void notifyStopReached(); 23114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void notifyError(status_t err); 23214f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 23314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void queueDiscontinuity( 23414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber ATSParser::DiscontinuityType type, const sp<AMessage> &extra); 23514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 236a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang int32_t getSeqNumberWithAnchorTime( 237a48d372833ccec13c96ece9efcc226e8beac7f59Chong Zhang int64_t anchorTimeUs, int64_t targetDurationUs) const; 238309aa8bf5e4cd66fe988adf2654cac3fadc2a1c3Robert Shih int32_t getSeqNumberForDiscontinuity(size_t discontinuitySeq) const; 23914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber int32_t getSeqNumberForTime(int64_t timeUs) const; 24014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 24114f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber void updateDuration(); 2427c8708046117e03c0d38006bdd9685139df3ac6bChong Zhang void updateTargetDuration(); 24314f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 24414f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber DISALLOW_EVIL_CONSTRUCTORS(PlaylistFetcher); 24514f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber}; 24614f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 24714f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber} // namespace android 24814f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 24914f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber#endif // PLAYLIST_FETCHER_H_ 25014f7672b5d450ed26a06fd3bb3ce045ea78b11b2Andreas Huber 251