* ./plugins/dummy/intf_dummy.c, ./plugins/chroma/i420_yuy2.c,
[vlc.git] / plugins / network / ipv6.c
1 /*****************************************************************************
2  * ipv6.c: IPv6 network abstraction layer
3  *****************************************************************************
4  * Copyright (C) 2002 VideoLAN
5  * $Id: ipv6.c,v 1.10 2002/06/01 16:45:34 sam Exp $
6  *
7  * Authors: Alexis Guillard <alexis.guillard@bt.com>
8  *          Christophe Massiot <massiot@via.ecp.fr>
9  *
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.
14  * 
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.
19  *
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., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
23  *****************************************************************************/
24
25 /*****************************************************************************
26  * Preamble
27  *****************************************************************************/
28 #include <stdlib.h>
29 #include <sys/types.h>
30 #include <sys/stat.h>
31 #include <string.h>
32 #include <errno.h>
33 #include <fcntl.h>
34
35 #include <vlc/vlc.h>
36
37 #ifdef HAVE_UNISTD_H
38 #   include <unistd.h>
39 #elif defined( _MSC_VER ) && defined( _WIN32 )
40 #   include <io.h>
41 #endif
42
43 #ifdef WIN32
44 #   include <winsock2.h>
45 #   include <ws2tcpip.h>
46 #elif !defined( SYS_BEOS ) && !defined( SYS_NTO )
47 #   include <netdb.h>                                         /* hostent ... */
48 #   include <sys/socket.h>
49 #   include <netinet/in.h>
50 #   ifdef HAVE_ARPA_INET_H
51 #       include <arpa/inet.h>                    /* inet_ntoa(), inet_aton() */
52 #   endif
53 #endif
54
55 #include "network.h"
56
57 /* Default MTU used for UDP socket. FIXME: we should issue some ioctl()
58  * call to get that value from the interface driver. */
59 #define DEFAULT_MTU 1500
60
61 #if defined(WIN32)
62 static const struct in6_addr in6addr_any = {{IN6ADDR_ANY_INIT}};
63 #endif
64
65 /*****************************************************************************
66  * Local prototypes
67  *****************************************************************************/
68 static void getfunctions( function_list_t * );
69 static int  NetworkOpen( vlc_object_t *, network_socket_t * );
70
71 /*****************************************************************************
72  * Build configuration tree.
73  *****************************************************************************/
74 MODULE_CONFIG_START
75 MODULE_CONFIG_STOP
76  
77 MODULE_INIT_START
78     SET_DESCRIPTION( _("IPv6 network abstraction layer") )
79     ADD_CAPABILITY( NETWORK, 40 )
80 MODULE_INIT_STOP
81  
82 MODULE_ACTIVATE_START
83     getfunctions( &p_module->p_functions->network );
84 MODULE_ACTIVATE_STOP
85  
86 MODULE_DEACTIVATE_START
87 MODULE_DEACTIVATE_STOP
88
89 /*****************************************************************************
90  * Functions exported as capabilities. They are declared as static so that
91  * we don't pollute the namespace too much.
92  *****************************************************************************/
93 static void getfunctions( function_list_t * p_function_list )
94 {
95 #define f p_function_list->functions.network
96     f.pf_open = NetworkOpen;
97 #undef f
98 }
99
100 /*****************************************************************************
101  * BuildAddr: utility function to build a struct sockaddr_in6
102  *****************************************************************************/
103 static int BuildAddr( struct sockaddr_in6 * p_socket,
104                       char * psz_address, int i_port )
105 {
106 #if defined(WIN32)
107     /* Try to get getaddrinfo() and freeaddrinfo() from wship6.dll */
108     typedef int (CALLBACK * GETADDRINFO) ( const char *nodename,
109                                             const char *servname,
110                                             const struct addrinfo *hints,
111                                             struct addrinfo **res );
112     typedef void (CALLBACK * FREEADDRINFO) ( struct addrinfo FAR *ai );
113
114     struct addrinfo hints, *res;
115     GETADDRINFO _getaddrinfo = NULL;
116     FREEADDRINFO _freeaddrinfo = NULL;
117
118     HINSTANCE wship6_dll = LoadLibrary("wship6.dll");
119     if( wship6_dll )
120     {
121         _getaddrinfo = (GETADDRINFO) GetProcAddress( wship6_dll,
122                                                      "getaddrinfo" );
123         _freeaddrinfo = (FREEADDRINFO) GetProcAddress( wship6_dll,
124                                                        "freeaddrinfo" );
125     }
126     if( !_getaddrinfo || !_freeaddrinfo )
127     {
128 //X        msg_Err( p_this, "no IPv6 stack installed" );
129         if( wship6_dll ) FreeLibrary( wship6_dll );
130         return( -1 );
131     }
132 #endif
133
134     /* Reset struct */
135     memset( p_socket, 0, sizeof( struct sockaddr_in6 ) );
136     p_socket->sin6_family = AF_INET6;                              /* family */
137     p_socket->sin6_port = htons( i_port );
138     if( !*psz_address )
139     {
140         p_socket->sin6_addr = in6addr_any;
141     }
142     else if( psz_address[0] == '['
143               && psz_address[strlen(psz_address) - 1] == ']' )
144     {
145         psz_address++;
146         psz_address[strlen(psz_address) - 1] = '\0' ;
147
148 #if !defined( WIN32 )
149         inet_pton(AF_INET6, psz_address, &p_socket->sin6_addr.s6_addr); 
150
151 #else
152         memset(&hints, 0, sizeof(hints));
153         hints.ai_family = AF_INET6;
154         hints.ai_flags = AI_NUMERICHOST;
155
156         if( _getaddrinfo( psz_address, NULL, &hints, &res ) )
157         {
158             FreeLibrary( wship6_dll );
159             return( -1 );
160         }
161         memcpy( &p_socket->sin6_addr,
162                 &((struct sockaddr_in6 *)res->ai_addr)->sin6_addr,
163                 sizeof(struct in6_addr) );
164         _freeaddrinfo( res );
165
166 #endif
167     }
168     else
169     {
170 #ifdef HAVE_GETHOSTBYNAME2
171         struct hostent    * p_hostent;
172
173         /* We have a fqdn, try to find its address */
174         if ( (p_hostent = gethostbyname2( psz_address, AF_INET6 )) == NULL )
175         {
176 //X            intf_ErrMsg( "ipv6 error: unknown host %s", psz_address );
177             return( -1 );
178         }
179
180         /* Copy the first address of the host in the socket address */
181         memcpy( &p_socket->sin6_addr, p_hostent->h_addr_list[0],
182                  p_hostent->h_length );
183
184 #elif defined(WIN32)
185         if( _getaddrinfo( psz_address, NULL, &hints, &res ) )
186         {
187             FreeLibrary( wship6_dll );
188             return( -1 );
189         }
190         memcpy( &p_socket->sin6_addr,
191                 &((struct sockaddr_in6 *)res->ai_addr)->sin6_addr,
192                 sizeof(struct in6_addr) );
193         _freeaddrinfo( res );
194
195 #else
196 //X        intf_ErrMsg( "ipv6 error: IPv6 address %s is invalid", psz_address );
197         return( -1 );
198 #endif
199     }
200
201 #if defined(WIN32)
202     FreeLibrary( wship6_dll );
203 #endif
204
205     return( 0 );
206 }
207
208 /*****************************************************************************
209  * OpenUDP: open a UDP socket
210  *****************************************************************************
211  * psz_bind_addr, i_bind_port : address and port used for the bind()
212  *   system call. If psz_bind_addr == NULL, the socket is bound to
213  *   in6addr_any and broadcast reception is enabled. If i_bind_port == 0,
214  *   1234 is used. If psz_bind_addr is a multicast (class D) address,
215  *   join the multicast group.
216  * psz_server_addr, i_server_port : address and port used for the connect()
217  *   system call. It can avoid receiving packets from unauthorized IPs.
218  *   Its use leads to great confusion and is currently discouraged.
219  * This function returns -1 in case of error.
220  *****************************************************************************/
221 static int OpenUDP( vlc_object_t * p_this, network_socket_t * p_socket )
222 {
223     char * psz_bind_addr = p_socket->psz_bind_addr;
224     int i_bind_port = p_socket->i_bind_port;
225     char * psz_server_addr = p_socket->psz_server_addr;
226     int i_server_port = p_socket->i_server_port;
227
228     int i_handle, i_opt, i_opt_size;
229     struct sockaddr_in6 sock;
230
231     if( i_bind_port == 0 )
232     {
233 //X        i_bind_port = config_GetInt( "server-port" );
234     }
235
236     /* Open a SOCK_DGRAM (UDP) socket, in the AF_INET6 domain, automatic (0)
237      * protocol */
238     if( (i_handle = socket( AF_INET6, SOCK_DGRAM, 0 )) == -1 )
239     {
240         msg_Err( p_this, "cannot create socket (%s)", strerror(errno) );
241         return( -1 );
242     }
243
244     /* We may want to reuse an already used socket */
245     i_opt = 1;
246     if( setsockopt( i_handle, SOL_SOCKET, SO_REUSEADDR,
247                     (void *) &i_opt, sizeof( i_opt ) ) == -1 )
248     {
249         msg_Err( p_this, "cannot configure socket (SO_REUSEADDR: %s)",
250                          strerror(errno) );
251         close( i_handle );
252         return( -1 );
253     }
254
255     /* Increase the receive buffer size to 1/2MB (8Mb/s during 1/2s) to avoid
256      * packet loss caused by scheduling problems */
257     i_opt = 0x80000;
258     if( setsockopt( i_handle, SOL_SOCKET, SO_RCVBUF,
259                     (void *) &i_opt, sizeof( i_opt ) ) == -1 )
260     {
261         msg_Warn( p_this, "cannot configure socket (SO_RCVBUF: %s)",
262                           strerror(errno) );
263     }
264  
265     /* Check if we really got what we have asked for, because Linux, etc.
266      * will silently limit the max buffer size to net.core.rmem_max which
267      * is typically only 65535 bytes */
268     i_opt = 0;
269     i_opt_size = sizeof( i_opt );
270     if( getsockopt( i_handle, SOL_SOCKET, SO_RCVBUF,
271                     (void*) &i_opt, &i_opt_size ) == -1 )
272     {
273         msg_Warn( p_this, "cannot query socket (SO_RCVBUF: %s)",
274                           strerror(errno) );
275     }
276     else if( i_opt < 0x80000 )
277     {
278         msg_Warn( p_this, "socket buffer size is 0x%x instead of 0x%x",
279                           i_opt, 0x80000 );
280     }
281     
282     /* Build the local socket */
283     if ( BuildAddr( &sock, psz_bind_addr, i_bind_port ) == -1 )        
284     {
285         close( i_handle );
286         return( -1 );
287     }
288  
289     /* Bind it */
290     if( bind( i_handle, (struct sockaddr *)&sock, sizeof( sock ) ) < 0 )
291     {
292         msg_Err( p_this, "cannot bind socket (%s)", strerror(errno) );
293         close( i_handle );
294         return( -1 );
295     }
296
297     /* Allow broadcast reception if we bound on in6addr_any */
298     if( !*psz_bind_addr )
299     {
300         i_opt = 1;
301         if( setsockopt( i_handle, SOL_SOCKET, SO_BROADCAST,
302                         (void*) &i_opt, sizeof( i_opt ) ) == -1 )
303         {
304             msg_Warn( p_this, "ipv6 warning: cannot configure socket "
305                               "(SO_BROADCAST: %s)", strerror(errno) );
306         }
307     }
308  
309     /* Join the multicast group if the socket is a multicast address */
310     /* FIXME: To be written */
311
312     if( *psz_server_addr )
313     {
314         /* Build socket for remote connection */
315         if ( BuildAddr( &sock, psz_server_addr, i_server_port ) == -1 )
316         {
317             msg_Err( p_this, "cannot build remote address" );
318             close( i_handle );
319             return( -1 );
320         }
321  
322         /* Connect the socket */
323         if( connect( i_handle, (struct sockaddr *) &sock,
324                      sizeof( sock ) ) == (-1) )
325         {
326             msg_Err( p_this, "cannot connect socket (%s)", strerror(errno) );
327             close( i_handle );
328             return( -1 );
329         }
330     }
331
332     p_socket->i_handle = i_handle;
333     p_socket->i_mtu = DEFAULT_MTU;
334     return( 0 );
335 }
336
337 /*****************************************************************************
338  * OpenTCP: open a TCP socket
339  *****************************************************************************
340  * psz_server_addr, i_server_port : address and port used for the connect()
341  *   system call. If i_server_port == 0, 80 is used.
342  * Other parameters are ignored.
343  * This function returns -1 in case of error.
344  *****************************************************************************/
345 static int OpenTCP( vlc_object_t * p_this, network_socket_t * p_socket )
346 {
347     char * psz_server_addr = p_socket->psz_server_addr;
348     int i_server_port = p_socket->i_server_port;
349
350     int i_handle;
351     struct sockaddr_in6 sock;
352
353     if( i_server_port == 0 )
354     {
355         i_server_port = 80;
356     }
357
358     /* Open a SOCK_STREAM (TCP) socket, in the AF_INET6 domain, automatic (0)
359      * protocol */
360     if( (i_handle = socket( AF_INET6, SOCK_STREAM, 0 )) == -1 )
361     {
362         msg_Err( p_this, "cannot create socket (%s)", strerror(errno) );
363         return( -1 );
364     }
365
366     /* Build remote address */
367     if ( BuildAddr( &sock, psz_server_addr, i_server_port ) == -1 )
368     {
369         close( i_handle );
370         return( -1 );
371     }
372
373     /* Connect the socket */
374     if( connect( i_handle, (struct sockaddr *) &sock,
375                  sizeof( sock ) ) == (-1) )
376     {
377         msg_Err( p_this, "cannot connect socket (%s)", strerror(errno) );
378         close( i_handle );
379         return( -1 );
380     }
381
382     p_socket->i_handle = i_handle;
383     p_socket->i_mtu = 0; /* There is no MTU notion in TCP */
384
385     return( 0 );
386 }
387
388 /*****************************************************************************
389  * NetworkOpen: wrapper around OpenUDP and OpenTCP
390  *****************************************************************************/
391 static int NetworkOpen( vlc_object_t * p_this, network_socket_t * p_socket )
392 {
393     if( p_socket->i_type == NETWORK_UDP )
394     {
395         return OpenUDP( p_this, p_socket );
396     }
397     else
398     {
399         return OpenTCP( p_this, p_socket );
400     }
401 }