1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
/*
* 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.
*/
#ifndef RTSP_SOURCE_H_
#define RTSP_SOURCE_H_
#include "NuPlayerSource.h"
#include "ATSParser.h"
namespace android {
struct ALooper;
struct AReplyToken;
struct AnotherPacketSource;
struct MyHandler;
struct SDPLoader;
struct NuPlayer::RTSPSource : public NuPlayer::Source {
RTSPSource(
const sp<AMessage> ¬ify,
const sp<IMediaHTTPService> &httpService,
const char *url,
const KeyedVector<String8, String8> *headers,
bool uidValid = false,
uid_t uid = 0,
bool isSDP = false);
virtual void prepareAsync();
virtual void start();
virtual void stop();
virtual void pause();
virtual void resume();
virtual status_t feedMoreTSData();
virtual status_t dequeueAccessUnit(bool audio, sp<ABuffer> *accessUnit);
virtual status_t getDuration(int64_t *durationUs);
virtual status_t seekTo(int64_t seekTimeUs);
void onMessageReceived(const sp<AMessage> &msg);
protected:
virtual ~RTSPSource();
virtual sp<MetaData> getFormatMeta(bool audio);
private:
enum {
kWhatNotify = 'noti',
kWhatDisconnect = 'disc',
kWhatPerformSeek = 'seek',
};
enum State {
DISCONNECTED,
CONNECTING,
CONNECTED,
SEEKING,
};
enum Flags {
// Don't log any URLs.
kFlagIncognito = 1,
};
struct TrackInfo {
sp<AnotherPacketSource> mSource;
int32_t mTimeScale;
uint32_t mRTPTime;
int64_t mNormalPlaytimeUs;
bool mNPTMappingValid;
};
sp<IMediaHTTPService> mHTTPService;
AString mURL;
KeyedVector<String8, String8> mExtraHeaders;
bool mUIDValid;
uid_t mUID;
uint32_t mFlags;
bool mIsSDP;
State mState;
status_t mFinalResult;
sp<AReplyToken> mDisconnectReplyID;
Mutex mBufferingLock;
bool mBuffering;
sp<ALooper> mLooper;
sp<MyHandler> mHandler;
sp<SDPLoader> mSDPLoader;
Vector<TrackInfo> mTracks;
sp<AnotherPacketSource> mAudioTrack;
sp<AnotherPacketSource> mVideoTrack;
sp<ATSParser> mTSParser;
int32_t mSeekGeneration;
int64_t mEOSTimeoutAudio;
int64_t mEOSTimeoutVideo;
sp<AReplyToken> mSeekReplyID;
sp<AnotherPacketSource> getSource(bool audio);
void onConnected();
void onSDPLoaded(const sp<AMessage> &msg);
void onDisconnected(const sp<AMessage> &msg);
void finishDisconnectIfPossible();
void performSeek(int64_t seekTimeUs);
bool haveSufficientDataOnAllTracks();
void setEOSTimeout(bool audio, int64_t timeout);
void setError(status_t err);
void startBufferingIfNecessary();
bool stopBufferingIfNecessary();
void finishSeek(status_t err);
DISALLOW_EVIL_CONSTRUCTORS(RTSPSource);
};
} // namespace android
#endif // RTSP_SOURCE_H_
|
