100l, last patch broke window resizing with xv and xvmc.
[mplayer/glamo.git] / stream / stream.c
blobcd63a37170d7a20d9ffb57c37b90142856696ab9
2 #include <stdio.h>
3 #include <stdlib.h>
4 #include <unistd.h>
6 #include <sys/types.h>
7 #include <sys/stat.h>
8 #ifndef __MINGW32__
9 #include <sys/ioctl.h>
10 #include <sys/wait.h>
11 #endif
12 #include <fcntl.h>
13 #include <signal.h>
14 #include <strings.h>
16 #include "config.h"
18 #ifndef HAVE_WINSOCK2
19 #define closesocket close
20 #else
21 #include <winsock2.h>
22 #endif
24 #include "mp_msg.h"
25 #include "help_mp.h"
26 #include "osdep/shmem.h"
28 #include "stream.h"
29 #include "libmpdemux/demuxer.h"
31 #include "m_option.h"
32 #include "m_struct.h"
34 #include "cache2.h"
36 //#include "vcd_read_bincue.h"
38 #ifdef HAVE_VCD
39 extern stream_info_t stream_info_vcd;
40 #endif
41 #ifdef HAVE_CDDA
42 extern stream_info_t stream_info_cdda;
43 #endif
44 #ifdef MPLAYER_NETWORK
45 extern stream_info_t stream_info_netstream;
46 extern stream_info_t stream_info_pnm;
47 extern stream_info_t stream_info_asf;
48 extern stream_info_t stream_info_rtsp;
49 extern stream_info_t stream_info_rtp;
50 extern stream_info_t stream_info_udp;
51 extern stream_info_t stream_info_http1;
52 extern stream_info_t stream_info_http2;
53 #endif
54 #ifdef HAS_DVBIN_SUPPORT
55 extern stream_info_t stream_info_dvb;
56 #endif
57 #ifdef USE_TV
58 extern stream_info_t stream_info_tv;
59 #endif
60 #ifdef USE_RADIO
61 extern stream_info_t stream_info_radio;
62 #endif
63 #ifdef HAVE_PVR
64 extern stream_info_t stream_info_pvr;
65 #endif
66 #ifdef HAVE_FTP
67 extern stream_info_t stream_info_ftp;
68 #endif
69 #ifdef HAVE_VSTREAM
70 extern stream_info_t stream_info_vstream;
71 #endif
72 #ifdef USE_DVDNAV
73 extern stream_info_t stream_info_dvdnav;
74 #endif
75 #ifdef LIBSMBCLIENT
76 extern stream_info_t stream_info_smb;
77 #endif
78 #ifdef STREAMING_LIVE555
79 extern stream_info_t stream_info_sdp;
80 extern stream_info_t stream_info_rtsp_sip;
81 #endif
83 extern stream_info_t stream_info_cue;
84 extern stream_info_t stream_info_null;
85 extern stream_info_t stream_info_mf;
86 extern stream_info_t stream_info_file;
87 #ifdef USE_DVDREAD
88 extern stream_info_t stream_info_dvd;
89 #endif
91 stream_info_t* auto_open_streams[] = {
92 #ifdef HAVE_VCD
93 &stream_info_vcd,
94 #endif
95 #ifdef HAVE_CDDA
96 &stream_info_cdda,
97 #endif
98 #ifdef MPLAYER_NETWORK
99 &stream_info_netstream,
100 &stream_info_http1,
101 &stream_info_asf,
102 &stream_info_pnm,
103 &stream_info_rtsp,
104 #ifdef STREAMING_LIVE555
105 &stream_info_sdp,
106 &stream_info_rtsp_sip,
107 #endif
108 &stream_info_rtp,
109 &stream_info_udp,
110 &stream_info_http2,
111 #endif
112 #ifdef HAS_DVBIN_SUPPORT
113 &stream_info_dvb,
114 #endif
115 #ifdef USE_TV
116 &stream_info_tv,
117 #endif
118 #ifdef USE_RADIO
119 &stream_info_radio,
120 #endif
121 #ifdef HAVE_PVR
122 &stream_info_pvr,
123 #endif
124 #ifdef HAVE_FTP
125 &stream_info_ftp,
126 #endif
127 #ifdef HAVE_VSTREAM
128 &stream_info_vstream,
129 #endif
130 #ifdef LIBSMBCLIENT
131 &stream_info_smb,
132 #endif
133 &stream_info_cue,
134 #ifdef USE_DVDREAD
135 &stream_info_dvd,
136 #endif
137 #ifdef USE_DVDNAV
138 &stream_info_dvdnav,
139 #endif
141 &stream_info_null,
142 &stream_info_mf,
143 &stream_info_file,
144 NULL
147 stream_t* open_stream_plugin(stream_info_t* sinfo,char* filename,int mode,
148 char** options, int* file_format, int* ret) {
149 void* arg = NULL;
150 stream_t* s;
151 m_struct_t* desc = (m_struct_t*)sinfo->opts;
153 // Parse options
154 if(desc) {
155 arg = m_struct_alloc(desc);
156 if(sinfo->opts_url) {
157 m_option_t url_opt =
158 { "stream url", arg , CONF_TYPE_CUSTOM_URL, 0, 0 ,0, sinfo->opts };
159 if(m_option_parse(&url_opt,"stream url",filename,arg,M_CONFIG_FILE) < 0) {
160 mp_msg(MSGT_OPEN,MSGL_ERR, "URL parsing failed on url %s\n",filename);
161 m_struct_free(desc,arg);
162 return NULL;
165 if(options) {
166 int i;
167 for(i = 0 ; options[i] != NULL ; i += 2) {
168 mp_msg(MSGT_OPEN,MSGL_DBG2, "Set stream arg %s=%s\n",
169 options[i],options[i+1]);
170 if(!m_struct_set(desc,arg,options[i],options[i+1]))
171 mp_msg(MSGT_OPEN,MSGL_WARN, "Failed to set stream option %s=%s\n",
172 options[i],options[i+1]);
176 s = new_stream(-2,-2);
177 s->url=strdup(filename);
178 s->flags |= mode;
179 *ret = sinfo->open(s,mode,arg,file_format);
180 if((*ret) != STREAM_OK) {
181 free(s->url);
182 free(s);
183 return NULL;
185 if(s->type <= -2)
186 mp_msg(MSGT_OPEN,MSGL_WARN, "Warning streams need a type !!!!\n");
187 if(s->flags & STREAM_SEEK && !s->seek)
188 s->flags &= ~STREAM_SEEK;
189 if(s->seek && !(s->flags & STREAM_SEEK))
190 s->flags |= STREAM_SEEK;
192 s->mode = mode;
194 mp_msg(MSGT_OPEN,MSGL_V, "STREAM: [%s] %s\n",sinfo->name,filename);
195 mp_msg(MSGT_OPEN,MSGL_V, "STREAM: Description: %s\n",sinfo->info);
196 mp_msg(MSGT_OPEN,MSGL_V, "STREAM: Author: %s\n", sinfo->author);
197 mp_msg(MSGT_OPEN,MSGL_V, "STREAM: Comment: %s\n", sinfo->comment);
199 return s;
203 stream_t* open_stream_full(char* filename,int mode, char** options, int* file_format) {
204 int i,j,l,r;
205 stream_info_t* sinfo;
206 stream_t* s;
208 for(i = 0 ; auto_open_streams[i] ; i++) {
209 sinfo = auto_open_streams[i];
210 if(!sinfo->protocols) {
211 mp_msg(MSGT_OPEN,MSGL_WARN, "Stream type %s has protocols == NULL, it's a bug\n", sinfo->name);
212 continue;
214 for(j = 0 ; sinfo->protocols[j] ; j++) {
215 l = strlen(sinfo->protocols[j]);
216 // l == 0 => Don't do protocol matching (ie network and filenames)
217 if((l == 0 && !strstr(filename, "://")) ||
218 ((strncmp(sinfo->protocols[j],filename,l) == 0) &&
219 (strncmp("://",filename+l,3) == 0))) {
220 *file_format = DEMUXER_TYPE_UNKNOWN;
221 s = open_stream_plugin(sinfo,filename,mode,options,file_format,&r);
222 if(s) return s;
223 if(r != STREAM_UNSUPORTED) {
224 mp_msg(MSGT_OPEN,MSGL_ERR, MSGTR_FailedToOpen,filename);
225 return NULL;
227 break;
232 mp_msg(MSGT_OPEN,MSGL_ERR, "No stream found to handle url %s\n",filename);
233 return NULL;
236 stream_t* open_output_stream(char* filename,char** options) {
237 int file_format; //unused
238 if(!filename) {
239 mp_msg(MSGT_OPEN,MSGL_ERR,"open_output_stream(), NULL filename, report this bug\n");
240 return NULL;
243 return open_stream_full(filename,STREAM_WRITE,options,&file_format);
246 //=================== STREAMER =========================
248 int stream_fill_buffer(stream_t *s){
249 int len;
250 if (/*s->fd == NULL ||*/ s->eof) { s->buf_pos = s->buf_len = 0; return 0; }
251 switch(s->type){
252 case STREAMTYPE_STREAM:
253 #ifdef MPLAYER_NETWORK
254 if( s->streaming_ctrl!=NULL ) {
255 len=s->streaming_ctrl->streaming_read(s->fd,s->buffer,STREAM_BUFFER_SIZE, s->streaming_ctrl);break;
256 } else {
257 len=read(s->fd,s->buffer,STREAM_BUFFER_SIZE);break;
259 #else
260 len=read(s->fd,s->buffer,STREAM_BUFFER_SIZE);break;
261 #endif
262 case STREAMTYPE_DS:
263 len = demux_read_data((demux_stream_t*)s->priv,s->buffer,STREAM_BUFFER_SIZE);
264 break;
267 default:
268 len= s->fill_buffer ? s->fill_buffer(s,s->buffer,STREAM_BUFFER_SIZE) : 0;
270 if(len<=0){ s->eof=1; s->buf_pos=s->buf_len=0; return 0; }
271 s->buf_pos=0;
272 s->buf_len=len;
273 s->pos+=len;
274 // printf("[%d]",len);fflush(stdout);
275 return len;
278 int stream_write_buffer(stream_t *s, unsigned char *buf, int len) {
279 int rd;
280 if(!s->write_buffer)
281 return -1;
282 rd = s->write_buffer(s, buf, len);
283 if(rd < 0)
284 return -1;
285 s->pos += rd;
286 return rd;
289 int stream_seek_long(stream_t *s,off_t pos){
290 off_t newpos=0;
292 // if( mp_msg_test(MSGT_STREAM,MSGL_DBG3) ) printf("seek_long to 0x%X\n",(unsigned int)pos);
294 s->buf_pos=s->buf_len=0;
296 if(s->mode == STREAM_WRITE) {
297 if(!s->seek || !s->seek(s,pos))
298 return 0;
299 return 1;
302 if(s->sector_size)
303 newpos = (pos/s->sector_size)*s->sector_size;
304 else
305 newpos = pos&(~((off_t)STREAM_BUFFER_SIZE-1));
307 if( mp_msg_test(MSGT_STREAM,MSGL_DBG3) ){
308 mp_msg(MSGT_STREAM,MSGL_DBG3, "s->pos=%"PRIX64" newpos=%"PRIX64" new_bufpos=%"PRIX64" buflen=%X \n",
309 (int64_t)s->pos,(int64_t)newpos,(int64_t)pos,s->buf_len);
311 pos-=newpos;
313 if(newpos==0 || newpos!=s->pos){
314 switch(s->type){
315 case STREAMTYPE_STREAM:
316 //s->pos=newpos; // real seek
317 // Some streaming protocol allow to seek backward and forward
318 // A function call that return -1 can tell that the protocol
319 // doesn't support seeking.
320 #ifdef MPLAYER_NETWORK
321 if(s->seek) { // new stream seek is much cleaner than streaming_ctrl one
322 if(!s->seek(s,newpos)) {
323 mp_msg(MSGT_STREAM,MSGL_ERR, "Seek failed\n");
324 return 0;
326 break;
329 if( s->streaming_ctrl!=NULL && s->streaming_ctrl->streaming_seek ) {
330 if( s->streaming_ctrl->streaming_seek( s->fd, pos, s->streaming_ctrl )<0 ) {
331 mp_msg(MSGT_STREAM,MSGL_INFO,"Stream not seekable!\n");
332 return 1;
335 #else
336 if(newpos<s->pos){
337 mp_msg(MSGT_STREAM,MSGL_INFO,"Cannot seek backward in linear streams!\n");
338 return 1;
340 while(s->pos<newpos){
341 if(stream_fill_buffer(s)<=0) break; // EOF
343 #endif
344 break;
345 default:
346 // This should at the beginning as soon as all streams are converted
347 if(!s->seek)
348 return 0;
349 // Now seek
350 if(!s->seek(s,newpos)) {
351 mp_msg(MSGT_STREAM,MSGL_ERR, "Seek failed\n");
352 return 0;
355 // putchar('.');fflush(stdout);
356 //} else {
357 // putchar('%');fflush(stdout);
360 while(stream_fill_buffer(s) > 0 && pos >= 0) {
361 if(pos<=s->buf_len){
362 s->buf_pos=pos; // byte position in sector
363 return 1;
365 pos -= s->buf_len;
368 // if(pos==s->buf_len) printf("XXX Seek to last byte of file -> EOF\n");
370 mp_msg(MSGT_STREAM,MSGL_V,"stream_seek: WARNING! Can't seek to 0x%"PRIX64" !\n",(int64_t)(pos+newpos));
371 return 0;
375 void stream_reset(stream_t *s){
376 if(s->eof){
377 s->pos=0; //ftell(f);
378 // s->buf_pos=s->buf_len=0;
379 s->eof=0;
381 if(s->control) s->control(s,STREAM_CTRL_RESET,NULL);
382 //stream_seek(s,0);
385 int stream_control(stream_t *s, int cmd, void *arg){
386 if(!s->control) return STREAM_UNSUPORTED;
387 return s->control(s, cmd, arg);
390 stream_t* new_memory_stream(unsigned char* data,int len){
391 stream_t *s;
393 if(len < 0)
394 return NULL;
395 s=malloc(sizeof(stream_t)+len);
396 memset(s,0,sizeof(stream_t));
397 s->fd=-1;
398 s->type=STREAMTYPE_MEMORY;
399 s->buf_pos=0; s->buf_len=len;
400 s->start_pos=0; s->end_pos=len;
401 stream_reset(s);
402 s->pos=len;
403 memcpy(s->buffer,data,len);
404 return s;
407 stream_t* new_stream(int fd,int type){
408 stream_t *s=malloc(sizeof(stream_t));
409 if(s==NULL) return NULL;
410 memset(s,0,sizeof(stream_t));
412 #ifdef HAVE_WINSOCK2
414 WSADATA wsdata;
415 int temp = WSAStartup(0x0202, &wsdata); // there might be a better place for this (-> later)
416 mp_msg(MSGT_STREAM,MSGL_V,"WINSOCK2 init: %i\n", temp);
418 #endif
420 s->fd=fd;
421 s->type=type;
422 s->buf_pos=s->buf_len=0;
423 s->start_pos=s->end_pos=0;
424 s->priv=NULL;
425 s->url=NULL;
426 s->cache_pid=0;
427 stream_reset(s);
428 return s;
431 void free_stream(stream_t *s){
432 // printf("\n*** free_stream() called ***\n");
433 #ifdef USE_STREAM_CACHE
434 if(s->cache_pid) {
435 cache_uninit(s);
437 #endif
438 if(s->close) s->close(s);
439 if(s->fd>0){
440 /* on unix we define closesocket to close
441 on windows however we have to distinguish between
442 network socket and file */
443 if(s->url && strstr(s->url,"://"))
444 closesocket(s->fd);
445 else close(s->fd);
447 #ifdef HAVE_WINSOCK2
448 mp_msg(MSGT_STREAM,MSGL_V,"WINSOCK2 uninit\n");
449 WSACleanup(); // there might be a better place for this (-> later)
450 #endif
451 // Disabled atm, i don't like that. s->priv can be anything after all
452 // streams should destroy their priv on close
453 //if(s->priv) free(s->priv);
454 if(s->url) free(s->url);
455 free(s);
458 stream_t* new_ds_stream(demux_stream_t *ds) {
459 stream_t* s = new_stream(-1,STREAMTYPE_DS);
460 s->priv = ds;
461 return s;