1 /*****************************************************************************
3 *****************************************************************************
4 * Copyright (C) 2001-2009 the VideoLAN team
7 * Authors: Laurent Aimar <fenrir@via.ecp.fr>
8 * Jon Lech Johansen <jon@nanocrew.net>
10 * This program is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
23 *****************************************************************************/
25 /*****************************************************************************
27 *****************************************************************************/
33 #include <vlc_common.h>
34 #include <vlc_plugin.h>
36 #include <vlc_block.h>
39 #include <vlc_input.h>
40 #include <vlc_playlist.h>
42 #if 0 //def HAVE_AVAHI_CLIENT
46 #define DIRECTORY_SEPARATOR '\\'
48 #define DIRECTORY_SEPARATOR '/'
52 #include <vlc_httpd.h>
54 #define DEFAULT_PORT 8080
55 #define DEFAULT_SSL_PORT 8443
57 /*****************************************************************************
59 *****************************************************************************/
60 static int Open ( vlc_object_t
* );
61 static void Close( vlc_object_t
* );
63 #define SOUT_CFG_PREFIX "sout-http-"
65 #define USER_TEXT N_("Username")
66 #define USER_LONGTEXT N_("User name that will be " \
67 "requested to access the stream." )
68 #define PASS_TEXT N_("Password")
69 #define PASS_LONGTEXT N_("Password that will be " \
70 "requested to access the stream." )
71 #define MIME_TEXT N_("Mime")
72 #define MIME_LONGTEXT N_("MIME returned by the server (autodetected " \
73 "if not specified)." )
74 #define CERT_TEXT N_( "Certificate file" )
75 #define CERT_LONGTEXT N_( "Path to the x509 PEM certificate file that will "\
76 "be used for HTTPS." )
77 #define KEY_TEXT N_( "Private key file" )
78 #define KEY_LONGTEXT N_( "Path to the x509 PEM private key file that will " \
79 "be used for HTTPS. Leave " \
80 "empty if you don't have one." )
81 #define CA_TEXT N_( "Root CA file" )
82 #define CA_LONGTEXT N_( "Path to the x509 PEM trusted root CA certificates " \
83 "(certificate authority) file that will be used for " \
84 "HTTPS. Leave empty if you " \
86 #define CRL_TEXT N_( "CRL file" )
87 #define CRL_LONGTEXT N_( "Path to the x509 PEM Certificates Revocation List " \
88 "file that will be used for SSL. Leave " \
89 "empty if you don't have one." )
90 #define BONJOUR_TEXT N_( "Advertise with Bonjour")
91 #define BONJOUR_LONGTEXT N_( "Advertise the stream with the Bonjour protocol." )
95 set_description( N_("HTTP stream output") )
96 set_capability( "sout access", 0 )
97 set_shortname( "HTTP" )
98 add_shortcut( "http", "https", "mmsh" )
99 set_category( CAT_SOUT
)
100 set_subcategory( SUBCAT_SOUT_ACO
)
101 add_string( SOUT_CFG_PREFIX
"user", "",
102 USER_TEXT
, USER_LONGTEXT
, true )
103 add_password( SOUT_CFG_PREFIX
"pwd", "", NULL
,
104 PASS_TEXT
, PASS_LONGTEXT
, true )
105 add_string( SOUT_CFG_PREFIX
"mime", "",
106 MIME_TEXT
, MIME_LONGTEXT
, true )
107 add_string( SOUT_CFG_PREFIX
"cert", "vlc.pem",
108 CERT_TEXT
, CERT_LONGTEXT
, true )
109 add_string( SOUT_CFG_PREFIX
"key", NULL
,
110 KEY_TEXT
, KEY_LONGTEXT
, true )
111 add_string( SOUT_CFG_PREFIX
"ca", NULL
,
112 CA_TEXT
, CA_LONGTEXT
, true )
113 add_string( SOUT_CFG_PREFIX
"crl", NULL
,
114 CRL_TEXT
, CRL_LONGTEXT
, true )
115 #if 0 //def HAVE_AVAHI_CLIENT
116 add_bool( SOUT_CFG_PREFIX
"bonjour", false, NULL
,
117 BONJOUR_TEXT
, BONJOUR_LONGTEXT
, true);
119 set_callbacks( Open
, Close
)
123 /*****************************************************************************
124 * Exported prototypes
125 *****************************************************************************/
126 static const char *const ppsz_sout_options
[] = {
127 "user", "pwd", "mime", "cert", "key", "ca", "crl", NULL
130 static ssize_t
Write( sout_access_out_t
*, block_t
* );
131 static int Seek ( sout_access_out_t
*, off_t
);
132 static int Control( sout_access_out_t
*, int, va_list );
134 struct sout_access_out_sys_t
137 httpd_host_t
*p_httpd_host
;
140 httpd_stream_t
*p_httpd_stream
;
142 /* gather header from stream */
143 int i_header_allocated
;
146 bool b_header_complete
;
148 #if 0 //def HAVE_AVAHI_CLIENT
153 /*****************************************************************************
154 * Open: open the file
155 *****************************************************************************/
156 static int Open( vlc_object_t
*p_this
)
158 sout_access_out_t
*p_access
= (sout_access_out_t
*)p_this
;
159 sout_access_out_sys_t
*p_sys
;
169 char *psz_cert
= NULL
, *psz_key
= NULL
, *psz_ca
= NULL
,
172 if( !( p_sys
= p_access
->p_sys
=
173 malloc( sizeof( sout_access_out_sys_t
) ) ) )
176 config_ChainParse( p_access
, SOUT_CFG_PREFIX
, ppsz_sout_options
, p_access
->p_cfg
);
178 /* p_access->psz_path = "hostname:port/filename" */
179 psz_bind_addr
= strdup( p_access
->psz_path
);
183 psz_parser
= strchr( psz_bind_addr
, '/' );
186 psz_file_name
= strdup( psz_parser
);
190 psz_file_name
= strdup( "/" );
192 if( psz_bind_addr
[0] == '[' )
195 psz_parser
= strstr( psz_bind_addr
, "]:" );
199 i_bind_port
= atoi( psz_parser
+ 2 );
201 psz_parser
= psz_bind_addr
- 1;
205 psz_parser
= strrchr( psz_bind_addr
, ':' );
209 i_bind_port
= atoi( psz_parser
+ 1 );
211 psz_parser
= psz_bind_addr
;
215 if( p_access
->psz_access
&& !strcmp( p_access
->psz_access
, "https" ) )
217 psz_cert
= var_CreateGetNonEmptyString( p_this
, SOUT_CFG_PREFIX
"cert" );
218 psz_key
= var_CreateGetNonEmptyString( p_this
, SOUT_CFG_PREFIX
"key" );
219 psz_ca
= var_CreateGetNonEmptyString( p_this
, SOUT_CFG_PREFIX
"ca" );
220 psz_crl
= var_CreateGetNonEmptyString( p_this
, SOUT_CFG_PREFIX
"crl" );
222 if( i_bind_port
<= 0 )
223 i_bind_port
= DEFAULT_SSL_PORT
;
227 if( i_bind_port
<= 0 )
228 i_bind_port
= DEFAULT_PORT
;
231 p_sys
->p_httpd_host
= httpd_TLSHostNew( VLC_OBJECT(p_access
),
232 psz_bind_addr
, i_bind_port
,
233 psz_cert
, psz_key
, psz_ca
,
240 if( p_sys
->p_httpd_host
== NULL
)
242 msg_Err( p_access
, "cannot listen on %s port %d",
243 psz_bind_addr
, i_bind_port
);
244 free( psz_file_name
);
251 psz_user
= var_GetNonEmptyString( p_access
, SOUT_CFG_PREFIX
"user" );
252 psz_pwd
= var_GetNonEmptyString( p_access
, SOUT_CFG_PREFIX
"pwd" );
253 if( p_access
->psz_access
&& !strcmp( p_access
->psz_access
, "mmsh" ) )
255 psz_mime
= strdup( "video/x-ms-asf-stream" );
259 psz_mime
= var_GetNonEmptyString( p_access
, SOUT_CFG_PREFIX
"mime" );
262 p_sys
->p_httpd_stream
=
263 httpd_StreamNew( p_sys
->p_httpd_host
, psz_file_name
, psz_mime
,
264 psz_user
, psz_pwd
, NULL
);
269 if( p_sys
->p_httpd_stream
== NULL
)
271 msg_Err( p_access
, "cannot add stream %s", psz_file_name
);
272 httpd_HostDelete( p_sys
->p_httpd_host
);
274 free( psz_file_name
);
279 #if 0 //def HAVE_AVAHI_CLIENT
280 if( var_InheritBool(p_this
, SOUT_CFG_PREFIX
"bonjour") )
282 char *psz_txt
, *psz_name
;
283 playlist_t
*p_playlist
= pl_Get( p_access
);
285 char *psz_uri
= input_item_GetURI( p_playlist
->status
.p_item
->p_input
);
286 char *psz_newuri
= psz_uri
;
287 psz_name
= strrchr( psz_newuri
, DIRECTORY_SEPARATOR
);
288 if( psz_name
!= NULL
) psz_name
++;
289 else psz_name
= psz_newuri
;
292 asprintf( &psz_txt
, "path=%s", psz_file_name
) == -1 )
298 p_sys
->p_bonjour
= bonjour_start_service( (vlc_object_t
*)p_access
,
299 strcmp( p_access
->psz_access
, "https" )
300 ? "_vlc-http._tcp" : "_vlc-https._tcp",
301 psz_name
, i_bind_port
, psz_txt
);
305 if( p_sys
->p_bonjour
== NULL
)
306 msg_Err( p_access
, "unable to start requested Bonjour announce" );
309 p_sys
->p_bonjour
= NULL
;
312 free( psz_file_name
);
314 p_sys
->i_header_allocated
= 1024;
315 p_sys
->i_header_size
= 0;
316 p_sys
->p_header
= xmalloc( p_sys
->i_header_allocated
);
317 p_sys
->b_header_complete
= false;
319 p_access
->pf_write
= Write
;
320 p_access
->pf_seek
= Seek
;
321 p_access
->pf_control
= Control
;
326 /*****************************************************************************
327 * Close: close the target
328 *****************************************************************************/
329 static void Close( vlc_object_t
* p_this
)
331 sout_access_out_t
*p_access
= (sout_access_out_t
*)p_this
;
332 sout_access_out_sys_t
*p_sys
= p_access
->p_sys
;
334 #if 0 //def HAVE_AVAHI_CLIENT
335 if( p_sys
->p_bonjour
!= NULL
)
336 bonjour_stop_service( p_sys
->p_bonjour
);
339 httpd_StreamDelete( p_sys
->p_httpd_stream
);
340 httpd_HostDelete( p_sys
->p_httpd_host
);
342 free( p_sys
->p_header
);
344 msg_Dbg( p_access
, "Close" );
349 static int Control( sout_access_out_t
*p_access
, int i_query
, va_list args
)
355 case ACCESS_OUT_CONTROLS_PACE
:
356 *va_arg( args
, bool * ) = false;
365 /*****************************************************************************
367 *****************************************************************************/
368 static ssize_t
Write( sout_access_out_t
*p_access
, block_t
*p_buffer
)
370 sout_access_out_sys_t
*p_sys
= p_access
->p_sys
;
378 if( p_buffer
->i_flags
& BLOCK_FLAG_HEADER
)
381 if( p_sys
->b_header_complete
)
383 /* free previously gathered header */
384 p_sys
->i_header_size
= 0;
385 p_sys
->b_header_complete
= false;
387 if( (int)(p_buffer
->i_buffer
+ p_sys
->i_header_size
) >
388 p_sys
->i_header_allocated
)
390 p_sys
->i_header_allocated
=
391 p_buffer
->i_buffer
+ p_sys
->i_header_size
+ 1024;
392 p_sys
->p_header
= xrealloc( p_sys
->p_header
,
393 p_sys
->i_header_allocated
);
395 memcpy( &p_sys
->p_header
[p_sys
->i_header_size
],
397 p_buffer
->i_buffer
);
398 p_sys
->i_header_size
+= p_buffer
->i_buffer
;
400 else if( !p_sys
->b_header_complete
)
402 p_sys
->b_header_complete
= true;
404 httpd_StreamHeader( p_sys
->p_httpd_stream
, p_sys
->p_header
,
405 p_sys
->i_header_size
);
408 i_len
+= p_buffer
->i_buffer
;
410 i_err
= httpd_StreamSend( p_sys
->p_httpd_stream
, p_buffer
->p_buffer
,
411 p_buffer
->i_buffer
);
413 p_next
= p_buffer
->p_next
;
414 block_Release( p_buffer
);
425 block_ChainRelease( p_buffer
);
428 return( i_err
< 0 ? VLC_EGENERIC
: i_len
);
431 /*****************************************************************************
432 * Seek: seek to a specific location in a file
433 *****************************************************************************/
434 static int Seek( sout_access_out_t
*p_access
, off_t i_pos
)
437 msg_Warn( p_access
, "HTTP sout access cannot seek" );