2 * This file is part of MPlayer.
4 * MPlayer is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; either version 2 of the License, or
7 * (at your option) any later version.
9 * MPlayer is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License along
15 * with MPlayer; if not, write to the Free Software Foundation, Inc.,
16 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
19 #ifndef MPLAYER_STREAM_H
20 #define MPLAYER_STREAM_H
27 #include <sys/types.h>
34 #define STREAMTYPE_DUMMY -1 // for placeholders, when the actual reading is handled in the demuxer
35 #define STREAMTYPE_FILE 0 // read from seekable file
36 #define STREAMTYPE_VCD 1 // raw mode-2 CDROM reading, 2324 bytes/sector
37 #define STREAMTYPE_STREAM 2 // same as FILE but no seeking (for net/stdin)
38 #define STREAMTYPE_DVD 3 // libdvdread
39 #define STREAMTYPE_MEMORY 4 // read data from memory area
40 #define STREAMTYPE_PLAYLIST 6 // FIXME!!! same as STREAMTYPE_FILE now
41 #define STREAMTYPE_DS 8 // read from a demuxer stream
42 #define STREAMTYPE_DVDNAV 9 // we cannot safely "seek" in this...
43 #define STREAMTYPE_CDDA 10 // raw audio CD reader
44 #define STREAMTYPE_SMB 11 // smb:// url, using libsmbclient (samba)
45 #define STREAMTYPE_VCDBINCUE 12 // vcd directly from bin/cue files
46 #define STREAMTYPE_DVB 13
47 #define STREAMTYPE_VSTREAM 14
48 #define STREAMTYPE_SDP 15
49 #define STREAMTYPE_PVR 16
50 #define STREAMTYPE_TV 17
51 #define STREAMTYPE_MF 18
52 #define STREAMTYPE_RADIO 19
54 #define STREAM_BUFFER_SIZE 2048
56 #define VCD_SECTOR_SIZE 2352
57 #define VCD_SECTOR_OFFS 24
58 #define VCD_SECTOR_DATA 2324
60 /// atm it will always use mode == STREAM_READ
61 /// streams that use the new api should check the mode at open
63 #define STREAM_WRITE 1
64 /// Seek flags, if not mannualy set and s->seek isn't NULL
65 /// MP_STREAM_SEEK is automaticly set
66 #define MP_STREAM_SEEK_BW 2
67 #define MP_STREAM_SEEK_FW 4
68 #define MP_STREAM_SEEK (MP_STREAM_SEEK_BW|MP_STREAM_SEEK_FW)
69 /** This is a HACK for live555 that does not respect the
70 separation between stream an demuxer and thus is not
71 actually a stream cache can not be used */
72 #define STREAM_NON_CACHEABLE 8
74 //////////// Open return code
75 #define STREAM_REDIRECTED -2
76 /// This can't open the requested protocol (used by stream wich have a
77 /// * protocol when they don't know the requested protocol)
78 #define STREAM_UNSUPPORTED -1
79 #define STREAM_ERROR 0
82 #define MAX_STREAM_PROTOCOLS 10
84 #define STREAM_CTRL_RESET 0
85 #define STREAM_CTRL_GET_TIME_LENGTH 1
86 #define STREAM_CTRL_SEEK_TO_CHAPTER 2
87 #define STREAM_CTRL_GET_CURRENT_CHAPTER 3
88 #define STREAM_CTRL_GET_NUM_CHAPTERS 4
89 #define STREAM_CTRL_GET_CURRENT_TIME 5
90 #define STREAM_CTRL_SEEK_TO_TIME 6
91 #define STREAM_CTRL_GET_SIZE 7
92 #define STREAM_CTRL_GET_ASPECT_RATIO 8
93 #define STREAM_CTRL_GET_NUM_ANGLES 9
94 #define STREAM_CTRL_GET_ANGLE 10
95 #define STREAM_CTRL_SET_ANGLE 11
103 typedef struct streaming_control
{
105 streaming_status status
;
106 int buffering
; // boolean
107 unsigned int prebuffer_size
;
109 unsigned int buffer_size
;
110 unsigned int buffer_pos
;
111 unsigned int bandwidth
; // The downstream available
112 int (*streaming_read
)( int fd
, char *buffer
, int buffer_size
, struct streaming_control
*stream_ctrl
);
113 int (*streaming_seek
)( int fd
, off_t pos
, struct streaming_control
*stream_ctrl
);
121 typedef struct stream_info_st
{
126 /// mode isn't used atm (ie always READ) but it shouldn't be ignored
127 /// opts is at least in it's defaults settings and may have been
128 /// altered by url parsing if enabled and the options string parsing.
129 int (*open
)(struct stream
* st
, int mode
, void* opts
, int* file_format
);
130 const char* protocols
[MAX_STREAM_PROTOCOLS
];
132 int opts_url
; /* If this is 1 we will parse the url as an option string
133 * too. Otherwise options are only parsed from the
134 * options string given to open_stream_plugin */
137 typedef struct stream
{
139 int (*fill_buffer
)(struct stream
*s
, char* buffer
, int max_len
);
141 int (*write_buffer
)(struct stream
*s
, char* buffer
, int len
);
143 int (*seek
)(struct stream
*s
,off_t pos
);
145 // Will be later used to let streams like dvd and cdda report
146 // their structure (ie tracks, chapters, etc)
147 int (*control
)(struct stream
*s
,int cmd
,void* arg
);
149 void (*close
)(struct stream
*s
);
151 int fd
; // file descriptor, see man open(2)
152 int type
; // see STREAMTYPE_*
154 int sector_size
; // sector size (seek will be aligned on this size if non 0)
155 unsigned int buf_pos
,buf_len
;
156 off_t pos
,start_pos
,end_pos
;
158 int mode
; //STREAM_READ or STREAM_WRITE
159 unsigned int cache_pid
;
161 void* priv
; // used for DVD, TV, RTSP etc
162 char* url
; // strdup() of filename/url
163 char *lavf_type
; // name of expected demuxer type for lavf
165 #ifdef CONFIG_NETWORK
166 streaming_ctrl_t
*streaming_ctrl
;
168 unsigned char buffer
[STREAM_BUFFER_SIZE
>VCD_SECTOR_SIZE
?STREAM_BUFFER_SIZE
:VCD_SECTOR_SIZE
];
171 #ifdef CONFIG_NETWORK
175 int stream_fill_buffer(stream_t
*s
);
176 int stream_seek_long(stream_t
*s
, off_t pos
);
178 #ifdef CONFIG_STREAM_CACHE
179 int stream_enable_cache(stream_t
*stream
,int size
,int min
,int prefill
);
180 int cache_stream_fill_buffer(stream_t
*s
);
181 int cache_stream_seek_long(stream_t
*s
,off_t pos
);
183 // no cache, define wrappers:
184 #define cache_stream_fill_buffer(x) stream_fill_buffer(x)
185 #define cache_stream_seek_long(x,y) stream_seek_long(x,y)
186 #define stream_enable_cache(x,y,z,w) 1
188 int stream_write_buffer(stream_t
*s
, unsigned char *buf
, int len
);
190 inline static int stream_read_char(stream_t
*s
){
191 return (s
->buf_pos
<s
->buf_len
)?s
->buffer
[s
->buf_pos
++]:
192 (cache_stream_fill_buffer(s
)?s
->buffer
[s
->buf_pos
++]:-256);
193 // if(s->buf_pos<s->buf_len) return s->buffer[s->buf_pos++];
194 // stream_fill_buffer(s);
195 // if(s->buf_pos<s->buf_len) return s->buffer[s->buf_pos++];
199 inline static unsigned int stream_read_word(stream_t
*s
){
201 x
=stream_read_char(s
);
202 y
=stream_read_char(s
);
206 inline static unsigned int stream_read_dword(stream_t
*s
){
208 y
=stream_read_char(s
);
209 y
=(y
<<8)|stream_read_char(s
);
210 y
=(y
<<8)|stream_read_char(s
);
211 y
=(y
<<8)|stream_read_char(s
);
215 #define stream_read_fourcc stream_read_dword_le
217 inline static unsigned int stream_read_word_le(stream_t
*s
){
219 x
=stream_read_char(s
);
220 y
=stream_read_char(s
);
224 inline static unsigned int stream_read_dword_le(stream_t
*s
){
226 y
=stream_read_char(s
);
227 y
|=stream_read_char(s
)<<8;
228 y
|=stream_read_char(s
)<<16;
229 y
|=stream_read_char(s
)<<24;
233 inline static uint64_t stream_read_qword(stream_t
*s
){
235 y
= stream_read_char(s
);
236 y
=(y
<<8)|stream_read_char(s
);
237 y
=(y
<<8)|stream_read_char(s
);
238 y
=(y
<<8)|stream_read_char(s
);
239 y
=(y
<<8)|stream_read_char(s
);
240 y
=(y
<<8)|stream_read_char(s
);
241 y
=(y
<<8)|stream_read_char(s
);
242 y
=(y
<<8)|stream_read_char(s
);
246 inline static uint64_t stream_read_qword_le(stream_t
*s
){
248 y
= stream_read_dword_le(s
);
249 y
|=(uint64_t)stream_read_dword_le(s
)<<32;
253 inline static unsigned int stream_read_int24(stream_t
*s
){
255 y
= stream_read_char(s
);
256 y
=(y
<<8)|stream_read_char(s
);
257 y
=(y
<<8)|stream_read_char(s
);
261 inline static int stream_read(stream_t
*s
,char* mem
,int total
){
265 x
=s
->buf_len
-s
->buf_pos
;
267 if(!cache_stream_fill_buffer(s
)) return total
-len
; // EOF
268 x
=s
->buf_len
-s
->buf_pos
;
270 if(s
->buf_pos
>s
->buf_len
) mp_msg(MSGT_DEMUX
, MSGL_WARN
, "stream_read: WARNING! s->buf_pos>s->buf_len\n");
272 memcpy(mem
,&s
->buffer
[s
->buf_pos
],x
);
273 s
->buf_pos
+=x
; mem
+=x
; len
-=x
;
278 unsigned char* stream_read_line(stream_t
*s
,unsigned char* mem
, int max
, int utf16
);
280 inline static int stream_eof(stream_t
*s
){
284 inline static off_t
stream_tell(stream_t
*s
){
285 return s
->pos
+s
->buf_pos
-s
->buf_len
;
288 inline static int stream_seek(stream_t
*s
,off_t pos
){
290 mp_dbg(MSGT_DEMUX
, MSGL_DBG3
, "seek to 0x%qX\n",(long long)pos
);
295 off_t x
=pos
-(s
->pos
-s
->buf_len
);
299 // putchar('*');fflush(stdout);
304 return cache_stream_seek_long(s
,pos
);
307 inline static int stream_skip(stream_t
*s
,off_t len
){
308 if( (len
<0 && (s
->flags
& MP_STREAM_SEEK_BW
)) || (len
>2*STREAM_BUFFER_SIZE
&& (s
->flags
& MP_STREAM_SEEK_FW
)) ) {
309 // negative or big skip!
310 return stream_seek(s
,stream_tell(s
)+len
);
313 int x
=s
->buf_len
-s
->buf_pos
;
315 if(!cache_stream_fill_buffer(s
)) return 0; // EOF
316 x
=s
->buf_len
-s
->buf_pos
;
319 //memcpy(mem,&s->buf[s->buf_pos],x);
320 s
->buf_pos
+=x
; len
-=x
;
326 void stream_reset(stream_t
*s
);
327 int stream_control(stream_t
*s
, int cmd
, void *arg
);
328 stream_t
* new_stream(int fd
,int type
);
329 void free_stream(stream_t
*s
);
330 stream_t
* new_memory_stream(unsigned char* data
,int len
);
331 stream_t
*open_stream(const char *filename
, struct MPOpts
*options
,
333 stream_t
*open_stream_full(const char *filename
,int mode
,
334 struct MPOpts
*options
, int *file_format
);
335 stream_t
*open_output_stream(const char *filename
, struct MPOpts
*options
);
336 /// Set the callback to be used by libstream to check for user
337 /// interruption during long blocking operations (cache filling, etc).
339 void stream_set_interrupt_callback(int (*cb
)(struct input_ctx
*, int),
340 struct input_ctx
*ctx
);
341 /// Call the interrupt checking callback if there is one.
342 int stream_check_interrupt(int time
);
344 extern int dvd_title
;
345 extern int dvd_chapter
;
346 extern int dvd_last_chapter
;
347 extern int dvd_angle
;
349 extern char * audio_stream
;
352 int id
; // 0 - 31 mpeg; 128 - 159 ac3; 160 - 191 pcm
358 #endif /* MPLAYER_STREAM_H */