19 #define closesocket close
26 #include "osdep/shmem.h"
29 #include "libmpdemux/demuxer.h"
36 //#include "vcd_read_bincue.h"
39 extern stream_info_t stream_info_vcd
;
42 extern stream_info_t stream_info_cdda
;
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
;
54 #ifdef HAS_DVBIN_SUPPORT
55 extern stream_info_t stream_info_dvb
;
58 extern stream_info_t stream_info_tv
;
61 extern stream_info_t stream_info_radio
;
64 extern stream_info_t stream_info_pvr
;
67 extern stream_info_t stream_info_ftp
;
70 extern stream_info_t stream_info_vstream
;
73 extern stream_info_t stream_info_dvdnav
;
76 extern stream_info_t stream_info_smb
;
78 #ifdef STREAMING_LIVE555
79 extern stream_info_t stream_info_sdp
;
80 extern stream_info_t stream_info_rtsp_sip
;
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
;
88 extern stream_info_t stream_info_dvd
;
91 stream_info_t
* auto_open_streams
[] = {
98 #ifdef MPLAYER_NETWORK
99 &stream_info_netstream
,
104 #ifdef STREAMING_LIVE555
106 &stream_info_rtsp_sip
,
112 #ifdef HAS_DVBIN_SUPPORT
128 &stream_info_vstream
,
147 stream_t
* open_stream_plugin(stream_info_t
* sinfo
,char* filename
,int mode
,
148 char** options
, int* file_format
, int* ret
) {
151 m_struct_t
* desc
= (m_struct_t
*)sinfo
->opts
;
155 arg
= m_struct_alloc(desc
);
156 if(sinfo
->opts_url
) {
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
);
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
);
179 *ret
= sinfo
->open(s
,mode
,arg
,file_format
);
180 if((*ret
) != STREAM_OK
) {
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
;
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
);
203 stream_t
* open_stream_full(char* filename
,int mode
, char** options
, int* file_format
) {
205 stream_info_t
* sinfo
;
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
);
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
);
223 if(r
!= STREAM_UNSUPORTED
) {
224 mp_msg(MSGT_OPEN
,MSGL_ERR
, MSGTR_FailedToOpen
,filename
);
232 mp_msg(MSGT_OPEN
,MSGL_ERR
, "No stream found to handle url %s\n",filename
);
236 stream_t
* open_output_stream(char* filename
,char** options
) {
237 int file_format
; //unused
239 mp_msg(MSGT_OPEN
,MSGL_ERR
,"open_output_stream(), NULL filename, report this bug\n");
243 return open_stream_full(filename
,STREAM_WRITE
,options
,&file_format
);
246 //=================== STREAMER =========================
248 int stream_fill_buffer(stream_t
*s
){
250 if (/*s->fd == NULL ||*/ s
->eof
) { s
->buf_pos
= s
->buf_len
= 0; return 0; }
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;
257 len
=read(s
->fd
,s
->buffer
,STREAM_BUFFER_SIZE
);break;
260 len
=read(s
->fd
,s
->buffer
,STREAM_BUFFER_SIZE
);break;
263 len
= demux_read_data((demux_stream_t
*)s
->priv
,s
->buffer
,STREAM_BUFFER_SIZE
);
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; }
274 // printf("[%d]",len);fflush(stdout);
278 int stream_write_buffer(stream_t
*s
, unsigned char *buf
, int len
) {
282 rd
= s
->write_buffer(s
, buf
, len
);
289 int stream_seek_long(stream_t
*s
,off_t pos
){
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
))
303 newpos
= (pos
/s
->sector_size
)*s
->sector_size
;
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
);
313 if(newpos
==0 || newpos
!=s
->pos
){
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");
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");
337 mp_msg(MSGT_STREAM
,MSGL_INFO
,"Cannot seek backward in linear streams!\n");
340 while(s
->pos
<newpos
){
341 if(stream_fill_buffer(s
)<=0) break; // EOF
346 // This should at the beginning as soon as all streams are converted
350 if(!s
->seek(s
,newpos
)) {
351 mp_msg(MSGT_STREAM
,MSGL_ERR
, "Seek failed\n");
355 // putchar('.');fflush(stdout);
357 // putchar('%');fflush(stdout);
360 while(stream_fill_buffer(s
) > 0 && pos
>= 0) {
362 s
->buf_pos
=pos
; // byte position in sector
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
));
375 void stream_reset(stream_t
*s
){
377 s
->pos
=0; //ftell(f);
378 // s->buf_pos=s->buf_len=0;
381 if(s
->control
) s
->control(s
,STREAM_CTRL_RESET
,NULL
);
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
){
395 s
=malloc(sizeof(stream_t
)+len
);
396 memset(s
,0,sizeof(stream_t
));
398 s
->type
=STREAMTYPE_MEMORY
;
399 s
->buf_pos
=0; s
->buf_len
=len
;
400 s
->start_pos
=0; s
->end_pos
=len
;
403 memcpy(s
->buffer
,data
,len
);
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
));
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
);
422 s
->buf_pos
=s
->buf_len
=0;
423 s
->start_pos
=s
->end_pos
=0;
431 void free_stream(stream_t
*s
){
432 // printf("\n*** free_stream() called ***\n");
433 #ifdef USE_STREAM_CACHE
438 if(s
->close
) s
->close(s
);
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
,"://"))
448 mp_msg(MSGT_STREAM
,MSGL_V
,"WINSOCK2 uninit\n");
449 WSACleanup(); // there might be a better place for this (-> later)
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
);
458 stream_t
* new_ds_stream(demux_stream_t
*ds
) {
459 stream_t
* s
= new_stream(-1,STREAMTYPE_DS
);