blob: 90d56d0242a80b65620b8a82b69180e077cbe2d6 [file] [log] [blame]
* 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
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* See the License for the specific language governing permissions and
* limitations under the License.
#include <media/stagefright/foundation/AHandler.h>
#include <media/mediaplayer.h>
#include <utils/String8.h>
#include "mpeg2ts/ATSParser.h"
namespace android {
struct ABuffer;
struct AReplyToken;
struct AnotherPacketSource;
class DataSource;
struct HTTPBase;
struct IMediaHTTPService;
struct LiveDataSource;
struct M3UParser;
struct PlaylistFetcher;
struct HLSTime;
struct HTTPDownloader;
struct LiveSession : public AHandler {
enum Flags {
// Don't log any URLs.
kFlagIncognito = 1,
enum StreamIndex {
kAudioIndex = 0,
kVideoIndex = 1,
kSubtitleIndex = 2,
kMaxStreams = 3,
kMetaDataIndex = 3,
kNumSources = 4,
enum StreamType {
STREAMTYPE_AUDIO = 1 << kAudioIndex,
STREAMTYPE_VIDEO = 1 << kVideoIndex,
STREAMTYPE_SUBTITLES = 1 << kSubtitleIndex,
STREAMTYPE_METADATA = 1 << kMetaDataIndex,
enum SeekMode {
kSeekModeExactPosition = 0, // used for seeking
kSeekModeNextSample = 1, // used for seamless switching
kSeekModeNextSegment = 2, // used for seamless switching
const sp<AMessage> &notify,
uint32_t flags,
const sp<IMediaHTTPService> &httpService);
int64_t calculateMediaTimeUs(int64_t firstTimeUs, int64_t timeUs, int32_t discontinuitySeq);
status_t dequeueAccessUnit(StreamType stream, sp<ABuffer> *accessUnit);
status_t getStreamFormat(StreamType stream, sp<AMessage> *format);
sp<HTTPDownloader> getHTTPDownloader();
void connectAsync(
const char *url,
const KeyedVector<String8, String8> *headers = NULL);
status_t disconnect();
// Blocks until seek is complete.
status_t seekTo(int64_t timeUs);
status_t getDuration(int64_t *durationUs) const;
size_t getTrackCount() const;
sp<AMessage> getTrackInfo(size_t trackIndex) const;
status_t selectTrack(size_t index, bool select);
ssize_t getSelectedTrack(media_track_type /* type */) const;
bool isSeekable() const;
bool hasDynamicDuration() const;
static const char *getKeyForStream(StreamType type);
static const char *getNameForStream(StreamType type);
static ATSParser::SourceType getSourceTypeForStream(StreamType type);
enum {
virtual ~LiveSession();
virtual void onMessageReceived(const sp<AMessage> &msg);
friend struct PlaylistFetcher;
enum {
kWhatConnect = 'conn',
kWhatDisconnect = 'disc',
kWhatSeek = 'seek',
kWhatFetcherNotify = 'notf',
kWhatChangeConfiguration = 'chC0',
kWhatChangeConfiguration2 = 'chC2',
kWhatChangeConfiguration3 = 'chC3',
kWhatPollBuffering = 'poll',
// Bandwidth Switch Mark Defaults
static const int64_t kUpSwitchMarkUs;
static const int64_t kDownSwitchMarkUs;
static const int64_t kUpSwitchMarginUs;
static const int64_t kResumeThresholdUs;
// Buffer Prepare/Ready/Underflow Marks
static const int64_t kReadyMarkUs;
static const int64_t kPrepareMarkUs;
static const int64_t kUnderflowMarkUs;
struct BandwidthEstimator;
struct BandwidthItem {
size_t mPlaylistIndex;
unsigned long mBandwidth;
int64_t mLastFailureUs;
struct FetcherInfo {
sp<PlaylistFetcher> mFetcher;
int64_t mDurationUs;
bool mToBeRemoved;
bool mToBeResumed;
struct StreamItem {
const char *mType;
AString mUri, mNewUri;
SeekMode mSeekMode;
size_t mCurDiscontinuitySeq;
int64_t mLastDequeuedTimeUs;
int64_t mLastSampleDurationUs;
: StreamItem("") {}
StreamItem(const char *type)
: mType(type),
mSeekMode(kSeekModeExactPosition) {
void reset() {
mCurDiscontinuitySeq = 0;
mLastDequeuedTimeUs = -1ll;
mLastSampleDurationUs = 0ll;
AString uriKey() {
AString key(mType);
return key;
StreamItem mStreams[kMaxStreams];
sp<AMessage> mNotify;
uint32_t mFlags;
sp<IMediaHTTPService> mHTTPService;
bool mBuffering;
bool mInPreparationPhase;
int32_t mPollBufferingGeneration;
int32_t mPrevBufferPercentage;
KeyedVector<String8, String8> mExtraHeaders;
AString mMasterURL;
Vector<BandwidthItem> mBandwidthItems;
ssize_t mCurBandwidthIndex;
ssize_t mOrigBandwidthIndex;
int32_t mLastBandwidthBps;
bool mLastBandwidthStable;
sp<BandwidthEstimator> mBandwidthEstimator;
sp<M3UParser> mPlaylist;
int32_t mMaxWidth;
int32_t mMaxHeight;
sp<ALooper> mFetcherLooper;
KeyedVector<AString, FetcherInfo> mFetcherInfos;
uint32_t mStreamMask;
// Masks used during reconfiguration:
// mNewStreamMask: streams in the variant playlist we're switching to;
// we don't want to immediately overwrite the original value.
uint32_t mNewStreamMask;
// mSwapMask: streams that have started to playback content in the new variant playlist;
// we use this to track reconfiguration progress.
uint32_t mSwapMask;
KeyedVector<StreamType, sp<AnotherPacketSource> > mPacketSources;
// A second set of packet sources that buffer content for the variant we're switching to.
KeyedVector<StreamType, sp<AnotherPacketSource> > mPacketSources2;
int32_t mSwitchGeneration;
int32_t mSubtitleGeneration;
size_t mContinuationCounter;
sp<AMessage> mContinuation;
sp<AMessage> mSeekReply;
int64_t mLastDequeuedTimeUs;
int64_t mRealTimeBaseUs;
bool mReconfigurationInProgress;
bool mSwitchInProgress;
int64_t mUpSwitchMark;
int64_t mDownSwitchMark;
int64_t mUpSwitchMargin;
sp<AReplyToken> mDisconnectReplyID;
sp<AReplyToken> mSeekReplyID;
bool mFirstTimeUsValid;
int64_t mFirstTimeUs;
int64_t mLastSeekTimeUs;
bool mHasMetadata;
KeyedVector<size_t, int64_t> mDiscontinuityAbsStartTimesUs;
KeyedVector<size_t, int64_t> mDiscontinuityOffsetTimesUs;
sp<PlaylistFetcher> addFetcher(const char *uri);
void onConnect(const sp<AMessage> &msg);
void onMasterPlaylistFetched(const sp<AMessage> &msg);
void onSeek(const sp<AMessage> &msg);
bool UriIsSameAsIndex( const AString &uri, int32_t index, bool newUri);
sp<AnotherPacketSource> getPacketSourceForStreamIndex(size_t trackIndex, bool newUri);
sp<AnotherPacketSource> getMetadataSource(
sp<AnotherPacketSource> sources[kNumSources], uint32_t streamMask, bool newUri);
bool resumeFetcher(
const AString &uri, uint32_t streamMask,
int64_t timeUs = -1ll, bool newUri = false);
float getAbortThreshold(
ssize_t currentBWIndex, ssize_t targetBWIndex) const;
void addBandwidthMeasurement(size_t numBytes, int64_t delayUs);
size_t getBandwidthIndex(int32_t bandwidthBps);
ssize_t getLowestValidBandwidthIndex() const;
HLSTime latestMediaSegmentStartTime() const;
static bool isBandwidthValid(const BandwidthItem &item);
static int SortByBandwidth(const BandwidthItem *, const BandwidthItem *);
static StreamType indexToType(int idx);
static ssize_t typeToIndex(int32_t type);
void changeConfiguration(
int64_t timeUs, ssize_t bwIndex = -1, bool pickTrack = false);
void onChangeConfiguration(const sp<AMessage> &msg);
void onChangeConfiguration2(const sp<AMessage> &msg);
void onChangeConfiguration3(const sp<AMessage> &msg);
void swapPacketSource(StreamType stream);
void tryToFinishBandwidthSwitch(const AString &oldUri);
void cancelBandwidthSwitch(bool resume = false);
bool checkSwitchProgress(
sp<AMessage> &msg, int64_t delayUs, bool *needResumeUntil);
bool switchBandwidthIfNeeded(bool bufferHigh, bool bufferLow);
bool tryBandwidthFallback();
void schedulePollBuffering();
void cancelPollBuffering();
void restartPollBuffering();
void onPollBuffering();
bool checkBuffering(bool &underflow, bool &ready, bool &down, bool &up);
void startBufferingIfNecessary();
void stopBufferingIfNecessary();
void notifyBufferingUpdate(int32_t percentage);
void finishDisconnect();
void postPrepared(status_t err);
void postError(status_t err);
} // namespace android
#endif // LIVE_SESSION_H_