19 #define closesocket close
26 #include "osdep/shmem.h"
29 #include "libmpdemux/demuxer.h"
35 void cache_uninit(stream_t
*s
); // defined in cache2.c
37 //#include "vcd_read_bincue.h"
40 extern stream_info_t stream_info_vcd
;
43 extern stream_info_t stream_info_cdda
;
45 #ifdef MPLAYER_NETWORK
46 extern stream_info_t stream_info_netstream
;
47 extern stream_info_t stream_info_pnm
;
48 extern stream_info_t stream_info_asf
;
49 extern stream_info_t stream_info_rtsp
;
50 extern stream_info_t stream_info_rtp
;
51 extern stream_info_t stream_info_udp
;
52 extern stream_info_t stream_info_http1
;
53 extern stream_info_t stream_info_http2
;
55 #ifdef HAS_DVBIN_SUPPORT
56 extern stream_info_t stream_info_dvb
;
59 extern stream_info_t stream_info_tv
;
62 extern stream_info_t stream_info_radio
;
65 extern stream_info_t stream_info_pvr
;
68 extern stream_info_t stream_info_ftp
;
71 extern stream_info_t stream_info_vstream
;
74 extern stream_info_t stream_info_dvdnav
;
77 extern stream_info_t stream_info_smb
;
79 #ifdef STREAMING_LIVE555
80 extern stream_info_t stream_info_sdp
;
81 extern stream_info_t stream_info_rtsp_sip
;
84 extern stream_info_t stream_info_cue
;
85 extern stream_info_t stream_info_null
;
86 extern stream_info_t stream_info_mf
;
87 extern stream_info_t stream_info_file
;
89 extern stream_info_t stream_info_dvd
;
92 stream_info_t
* auto_open_streams
[] = {
99 #ifdef MPLAYER_NETWORK
100 &stream_info_netstream
,
105 #ifdef STREAMING_LIVE555
107 &stream_info_rtsp_sip
,
113 #ifdef HAS_DVBIN_SUPPORT
129 &stream_info_vstream
,
148 stream_t
* open_stream_plugin(stream_info_t
* sinfo
,char* filename
,int mode
,
149 char** options
, int* file_format
, int* ret
) {
152 m_struct_t
* desc
= (m_struct_t
*)sinfo
->opts
;
156 arg
= m_struct_alloc(desc
);
157 if(sinfo
->opts_url
) {
159 { "stream url", arg
, CONF_TYPE_CUSTOM_URL
, 0, 0 ,0, sinfo
->opts
};
160 if(m_option_parse(&url_opt
,"stream url",filename
,arg
,M_CONFIG_FILE
) < 0) {
161 mp_msg(MSGT_OPEN
,MSGL_ERR
, "URL parsing failed on url %s\n",filename
);
162 m_struct_free(desc
,arg
);
168 for(i
= 0 ; options
[i
] != NULL
; i
+= 2) {
169 mp_msg(MSGT_OPEN
,MSGL_DBG2
, "Set stream arg %s=%s\n",
170 options
[i
],options
[i
+1]);
171 if(!m_struct_set(desc
,arg
,options
[i
],options
[i
+1]))
172 mp_msg(MSGT_OPEN
,MSGL_WARN
, "Failed to set stream option %s=%s\n",
173 options
[i
],options
[i
+1]);
177 s
= new_stream(-2,-2);
178 s
->url
=strdup(filename
);
180 *ret
= sinfo
->open(s
,mode
,arg
,file_format
);
181 if((*ret
) != STREAM_OK
) {
187 mp_msg(MSGT_OPEN
,MSGL_WARN
, "Warning streams need a type !!!!\n");
188 if(s
->flags
& STREAM_SEEK
&& !s
->seek
)
189 s
->flags
&= ~STREAM_SEEK
;
190 if(s
->seek
&& !(s
->flags
& STREAM_SEEK
))
191 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) || ((strncmp(sinfo
->protocols
[j
],filename
,l
) == 0) &&
218 (strncmp("://",filename
+l
,3) == 0))) {
219 *file_format
= DEMUXER_TYPE_UNKNOWN
;
220 s
= open_stream_plugin(sinfo
,filename
,mode
,options
,file_format
,&r
);
222 if(r
!= STREAM_UNSUPORTED
) {
223 mp_msg(MSGT_OPEN
,MSGL_ERR
, MSGTR_FailedToOpen
,filename
);
231 mp_msg(MSGT_OPEN
,MSGL_ERR
, "No stream found to handle url %s\n",filename
);
235 //=================== STREAMER =========================
237 int stream_fill_buffer(stream_t
*s
){
239 if (/*s->fd == NULL ||*/ s
->eof
) { s
->buf_pos
= s
->buf_len
= 0; return 0; }
241 case STREAMTYPE_STREAM
:
242 #ifdef MPLAYER_NETWORK
243 if( s
->streaming_ctrl
!=NULL
) {
244 len
=s
->streaming_ctrl
->streaming_read(s
->fd
,s
->buffer
,STREAM_BUFFER_SIZE
, s
->streaming_ctrl
);break;
246 len
=read(s
->fd
,s
->buffer
,STREAM_BUFFER_SIZE
);break;
249 len
=read(s
->fd
,s
->buffer
,STREAM_BUFFER_SIZE
);break;
252 len
= demux_read_data((demux_stream_t
*)s
->priv
,s
->buffer
,STREAM_BUFFER_SIZE
);
257 len
= s
->fill_buffer
? s
->fill_buffer(s
,s
->buffer
,STREAM_BUFFER_SIZE
) : 0;
259 if(len
<=0){ s
->eof
=1; s
->buf_pos
=s
->buf_len
=0; return 0; }
263 // printf("[%d]",len);fflush(stdout);
267 int stream_seek_long(stream_t
*s
,off_t pos
){
270 // if( mp_msg_test(MSGT_STREAM,MSGL_DBG3) ) printf("seek_long to 0x%X\n",(unsigned int)pos);
272 s
->buf_pos
=s
->buf_len
=0;
275 case STREAMTYPE_STREAM
:
276 #ifdef _LARGEFILE_SOURCE
277 newpos
=pos
&(~((long long)STREAM_BUFFER_SIZE
-1));break;
279 newpos
=pos
&(~(STREAM_BUFFER_SIZE
-1));break;
282 // Round on sector size
284 newpos
=(pos
/s
->sector_size
)*s
->sector_size
;
285 else { // Otherwise on the buffer size
286 #ifdef _LARGEFILE_SOURCE
287 newpos
=pos
&(~((long long)STREAM_BUFFER_SIZE
-1));break;
289 newpos
=pos
&(~(STREAM_BUFFER_SIZE
-1));break;
295 if( mp_msg_test(MSGT_STREAM
,MSGL_DBG3
) ){
296 mp_msg(MSGT_STREAM
,MSGL_DBG3
, "s->pos=%"PRIX64
" newpos=%"PRIX64
" new_bufpos=%"PRIX64
" buflen=%X \n",
297 (int64_t)s
->pos
,(int64_t)newpos
,(int64_t)pos
,s
->buf_len
);
301 if(newpos
==0 || newpos
!=s
->pos
){
303 case STREAMTYPE_STREAM
:
304 //s->pos=newpos; // real seek
305 // Some streaming protocol allow to seek backward and forward
306 // A function call that return -1 can tell that the protocol
307 // doesn't support seeking.
308 #ifdef MPLAYER_NETWORK
309 if(s
->seek
) { // new stream seek is much cleaner than streaming_ctrl one
310 if(!s
->seek(s
,newpos
)) {
311 mp_msg(MSGT_STREAM
,MSGL_ERR
, "Seek failed\n");
317 if( s
->streaming_ctrl
!=NULL
&& s
->streaming_ctrl
->streaming_seek
) {
318 if( s
->streaming_ctrl
->streaming_seek( s
->fd
, pos
, s
->streaming_ctrl
)<0 ) {
319 mp_msg(MSGT_STREAM
,MSGL_INFO
,"Stream not seekable!\n");
325 mp_msg(MSGT_STREAM
,MSGL_INFO
,"Cannot seek backward in linear streams!\n");
328 while(s
->pos
<newpos
){
329 if(stream_fill_buffer(s
)<=0) break; // EOF
334 // This should at the beginning as soon as all streams are converted
338 if(!s
->seek(s
,newpos
)) {
339 mp_msg(MSGT_STREAM
,MSGL_ERR
, "Seek failed\n");
343 // putchar('.');fflush(stdout);
345 // putchar('%');fflush(stdout);
348 while(stream_fill_buffer(s
) > 0 && pos
>= 0) {
350 s
->buf_pos
=pos
; // byte position in sector
356 // if(pos==s->buf_len) printf("XXX Seek to last byte of file -> EOF\n");
358 mp_msg(MSGT_STREAM
,MSGL_V
,"stream_seek: WARNING! Can't seek to 0x%"PRIX64
" !\n",(int64_t)(pos
+newpos
));
363 void stream_reset(stream_t
*s
){
365 s
->pos
=0; //ftell(f);
366 // s->buf_pos=s->buf_len=0;
369 if(s
->control
) s
->control(s
,STREAM_CTRL_RESET
,NULL
);
373 int stream_control(stream_t
*s
, int cmd
, void *arg
){
374 if(!s
->control
) return STREAM_UNSUPORTED
;
375 return s
->control(s
, cmd
, arg
);
378 stream_t
* new_memory_stream(unsigned char* data
,int len
){
383 s
=malloc(sizeof(stream_t
)+len
);
384 memset(s
,0,sizeof(stream_t
));
386 s
->type
=STREAMTYPE_MEMORY
;
387 s
->buf_pos
=0; s
->buf_len
=len
;
388 s
->start_pos
=0; s
->end_pos
=len
;
391 memcpy(s
->buffer
,data
,len
);
395 stream_t
* new_stream(int fd
,int type
){
396 stream_t
*s
=malloc(sizeof(stream_t
));
397 if(s
==NULL
) return NULL
;
398 memset(s
,0,sizeof(stream_t
));
403 int temp
= WSAStartup(0x0202, &wsdata
); // there might be a better place for this (-> later)
404 mp_msg(MSGT_STREAM
,MSGL_V
,"WINSOCK2 init: %i\n", temp
);
410 s
->buf_pos
=s
->buf_len
=0;
411 s
->start_pos
=s
->end_pos
=0;
419 void free_stream(stream_t
*s
){
420 // printf("\n*** free_stream() called ***\n");
421 #ifdef USE_STREAM_CACHE
426 if(s
->close
) s
->close(s
);
428 /* on unix we define closesocket to close
429 on windows however we have to distinguish between
430 network socket and file */
431 if(s
->url
&& strstr(s
->url
,"://"))
436 mp_msg(MSGT_STREAM
,MSGL_V
,"WINSOCK2 uninit\n");
437 WSACleanup(); // there might be a better place for this (-> later)
439 // Disabled atm, i don't like that. s->priv can be anything after all
440 // streams should destroy their priv on close
441 //if(s->priv) free(s->priv);
442 if(s
->url
) free(s
->url
);
446 stream_t
* new_ds_stream(demux_stream_t
*ds
) {
447 stream_t
* s
= new_stream(-1,STREAMTYPE_DS
);