blob: bcc3f8b3f98b2033c13ca1a1fce1dfa1dad69f88 [file] [log] [blame]
Andreas Huber5bc087c2010-12-23 10:27:40 -08001/*
2 * Copyright (C) 2010 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17#ifndef HTTP_LIVE_SOURCE_H_
18
19#define HTTP_LIVE_SOURCE_H_
20
21#include "NuPlayer.h"
22#include "NuPlayerSource.h"
23
24namespace android {
25
Andreas Huber5bc087c2010-12-23 10:27:40 -080026struct LiveSession;
27
28struct NuPlayer::HTTPLiveSource : public NuPlayer::Source {
Andreas Huberad0d9c92011-04-19 11:50:27 -070029 HTTPLiveSource(
Andreas Huberb5f25f02013-02-05 10:14:26 -080030 const sp<AMessage> &notify,
Andreas Huberad0d9c92011-04-19 11:50:27 -070031 const char *url,
Andreas Huber9b80c2b2011-06-30 15:47:02 -070032 const KeyedVector<String8, String8> *headers,
33 bool uidValid = false,
34 uid_t uid = 0);
Andreas Huber5bc087c2010-12-23 10:27:40 -080035
Andreas Huber9575c962013-02-05 13:59:56 -080036 virtual void prepareAsync();
Andreas Huber43c3e6c2011-01-05 12:17:08 -080037 virtual void start();
Andreas Huber5bc087c2010-12-23 10:27:40 -080038
Andreas Huber43c3e6c2011-01-05 12:17:08 -080039 virtual status_t dequeueAccessUnit(bool audio, sp<ABuffer> *accessUnit);
Andreas Huber14f76722013-01-15 09:04:18 -080040 virtual sp<AMessage> getFormat(bool audio);
Andreas Huber43c3e6c2011-01-05 12:17:08 -080041
Andreas Huber14f76722013-01-15 09:04:18 -080042 virtual status_t feedMoreTSData();
Andreas Huber43c3e6c2011-01-05 12:17:08 -080043 virtual status_t getDuration(int64_t *durationUs);
Chong Zhangdcb89b32013-08-06 09:44:47 -070044 virtual status_t getTrackInfo(Parcel *reply) const;
45 virtual status_t selectTrack(size_t trackIndex, bool select);
Andreas Huber43c3e6c2011-01-05 12:17:08 -080046 virtual status_t seekTo(int64_t seekTimeUs);
Andreas Huberb7c8e912012-11-27 15:02:53 -080047
Andreas Huber5bc087c2010-12-23 10:27:40 -080048protected:
49 virtual ~HTTPLiveSource();
50
Andreas Huber0df36ec2013-02-06 10:44:39 -080051 virtual void onMessageReceived(const sp<AMessage> &msg);
52
Andreas Huber5bc087c2010-12-23 10:27:40 -080053private:
Andreas Huberad0d9c92011-04-19 11:50:27 -070054 enum Flags {
55 // Don't log any URLs.
56 kFlagIncognito = 1,
57 };
58
Andreas Huber0df36ec2013-02-06 10:44:39 -080059 enum {
60 kWhatSessionNotify,
Chong Zhangdcb89b32013-08-06 09:44:47 -070061 kWhatFetchSubtitleData,
Andreas Huber0df36ec2013-02-06 10:44:39 -080062 };
63
Andreas Huber5bc087c2010-12-23 10:27:40 -080064 AString mURL;
Andreas Huberad0d9c92011-04-19 11:50:27 -070065 KeyedVector<String8, String8> mExtraHeaders;
Andreas Huber9b80c2b2011-06-30 15:47:02 -070066 bool mUIDValid;
67 uid_t mUID;
Andreas Huber7314fa12011-02-24 14:42:48 -080068 uint32_t mFlags;
Andreas Hubereac68ba2011-09-27 12:12:25 -070069 status_t mFinalResult;
Andreas Huber5bc087c2010-12-23 10:27:40 -080070 off64_t mOffset;
71 sp<ALooper> mLiveLooper;
72 sp<LiveSession> mLiveSession;
Chong Zhangdcb89b32013-08-06 09:44:47 -070073 int32_t mFetchSubtitleDataGeneration;
Andreas Huber5bc087c2010-12-23 10:27:40 -080074
Andreas Huber0df36ec2013-02-06 10:44:39 -080075 void onSessionNotify(const sp<AMessage> &msg);
76
Andreas Huber5bc087c2010-12-23 10:27:40 -080077 DISALLOW_EVIL_CONSTRUCTORS(HTTPLiveSource);
78};
79
80} // namespace android
81
82#endif // HTTP_LIVE_SOURCE_H_