netutils.c 13.6 KB
Newer Older
1
/*****************************************************************************
Michel Kaempf's avatar
Michel Kaempf committed
2
 * netutils.c: various network functions
3
 *****************************************************************************
4
 * Copyright (C) 1999-2001 VideoLAN
5
 * $Id: netutils.c,v 1.70 2002/06/07 21:45:30 sam Exp $
6
 *
7
 * Authors: Vincent Seguin <seguin@via.ecp.fr>
Benoit Steiner's avatar
   
Benoit Steiner committed
8
 *          Benoit Steiner <benny@via.ecp.fr>
Henri Fallon's avatar
   
Henri Fallon committed
9
 *          Henri Fallon <henri@videolan.org>
Xavier Marchesini's avatar
   
Xavier Marchesini committed
10
 *          Xavier Marchesini <xav@alarue.net>
11
12
 *          Christophe Massiot <massiot@via.ecp.fr>
 *          Samuel Hocevar <sam@via.ecp.fr>
13
14
15
16
17
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
Sam Hocevar's avatar
   
Sam Hocevar committed
18
 *
19
20
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
21
22
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
23
 *
24
25
26
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
27
 *****************************************************************************/
Michel Kaempf's avatar
Michel Kaempf committed
28

29
/*****************************************************************************
Michel Kaempf's avatar
Michel Kaempf committed
30
 * Preamble
31
 *****************************************************************************/
32
33
#include <stdlib.h>                             /* free(), realloc(), atoi() */
#include <errno.h>                                                /* errno() */
Sam Hocevar's avatar
   
Sam Hocevar committed
34
#include <string.h>                                              /* memset() */
Sam Hocevar's avatar
   
Sam Hocevar committed
35

36
#include <vlc/vlc.h>
Sam Hocevar's avatar
   
Sam Hocevar committed
37

Sam Hocevar's avatar
   
Sam Hocevar committed
38
#ifdef HAVE_UNISTD_H
Sam Hocevar's avatar
   
Sam Hocevar committed
39
#   include <unistd.h>                                      /* gethostname() */
Sam Hocevar's avatar
   
Sam Hocevar committed
40
#elif defined( _MSC_VER ) && defined( _WIN32 )
Sam Hocevar's avatar
   
Sam Hocevar committed
41
#   include <io.h>
Sam Hocevar's avatar
   
Sam Hocevar committed
42
43
44
#endif

#if !defined( _MSC_VER )
Henri Fallon's avatar
   
Henri Fallon committed
45
#include <sys/time.h>                                        /* gettimeofday */
Sam Hocevar's avatar
   
Sam Hocevar committed
46
#endif
47

Sam Hocevar's avatar
   
Sam Hocevar committed
48
49
#ifdef WIN32
#   include <winsock2.h>
Sam Hocevar's avatar
   
Sam Hocevar committed
50
#else
Sam Hocevar's avatar
   
Sam Hocevar committed
51
52
53
54
55
56
#   include <netdb.h>                                         /* hostent ... */
#   include <sys/socket.h>                           /* BSD: struct sockaddr */
#   include <netinet/in.h>                            /* BSD: struct in_addr */
#   ifdef HAVE_ARPA_INET_H
#       include <arpa/inet.h>                    /* inet_ntoa(), inet_aton() */
#   endif
57
58
#endif

Henri Fallon's avatar
   
Henri Fallon committed
59
60
61
62
#ifdef SYS_LINUX
#include <sys/ioctl.h>                                            /* ioctl() */
#endif

Sam Hocevar's avatar
   
Sam Hocevar committed
63
#if defined( WIN32 )                    /* tools to get the MAC adress from  */
Sam Hocevar's avatar
   
Sam Hocevar committed
64
#include <windows.h>                    /* the interface under Windows       */
Xavier Marchesini's avatar
Xavier Marchesini committed
65
#include <stdio.h>
gbazin's avatar
   
gbazin committed
66
#include <nb30.h>
Xavier Marchesini's avatar
Xavier Marchesini committed
67
68
#endif

Sam Hocevar's avatar
   
Sam Hocevar committed
69
#ifdef HAVE_NET_IF_H
70
71
#include <net/if.h>                            /* interface (arch-dependent) */
#endif
Henri Fallon's avatar
   
Henri Fallon committed
72

Benoit Steiner's avatar
   
Benoit Steiner committed
73
#ifdef HAVE_SYS_SOCKIO_H
Benoit Steiner's avatar
Benoit Steiner committed
74
#include <sys/sockio.h>
Benoit Steiner's avatar
   
Benoit Steiner committed
75
#endif
Michel Kaempf's avatar
Michel Kaempf committed
76

Sam Hocevar's avatar
   
Sam Hocevar committed
77
#include "netutils.h"
78
#include "playlist.h"
Michel Kaempf's avatar
Michel Kaempf committed
79

80
#include "network.h"
Michel Kaempf's avatar
Michel Kaempf committed
81

82
/*****************************************************************************
Henri Fallon's avatar
   
Henri Fallon committed
83
84
85
86
87
88
89
 * input_channel_t: channel library data
 *****************************************************************************
 * Store global channel library data.
 * The part of the code concerning the channel changing process is unstable
 * as it depends on the VideoLAN channel server, which isn't frozen for
 * the time being.
 *****************************************************************************/
90
struct input_channel_s
Henri Fallon's avatar
   
Henri Fallon committed
91
{
Sam Hocevar's avatar
   
Sam Hocevar committed
92
    int         i_channel;                         /* current channel number */
Henri Fallon's avatar
   
Henri Fallon committed
93
    mtime_t     last_change;                             /* last change date */
94
};
Henri Fallon's avatar
   
Henri Fallon committed
95

Xavier Marchesini's avatar
Xavier Marchesini committed
96
/*****************************************************************************
Sam Hocevar's avatar
   
Sam Hocevar committed
97
98
 * Local prototypes
 *****************************************************************************/
99
static int GetMacAddress   ( vlc_object_t *, int i_fd, char *psz_mac );
Sam Hocevar's avatar
   
Sam Hocevar committed
100
101
#ifdef WIN32
static int GetAdapterInfo  ( int i_adapter, char *psz_string );
Xavier Marchesini's avatar
Xavier Marchesini committed
102
103
#endif

Henri Fallon's avatar
   
Henri Fallon committed
104
105
106
107
/*****************************************************************************
 * network_ChannelCreate: initialize global channel method data
 *****************************************************************************
 * Initialize channel input method global data. This function should be called
Sam Hocevar's avatar
   
Sam Hocevar committed
108
 * once before any input thread is created or any call to other
Henri Fallon's avatar
   
Henri Fallon committed
109
110
 * input_Channel*() function is attempted.
 *****************************************************************************/
111
int __network_ChannelCreate( vlc_object_t *p_this )
Henri Fallon's avatar
   
Henri Fallon committed
112
{
113
#if !defined( SYS_LINUX ) && !defined( WIN32 )
114
115
    msg_Err( p_this, "VLAN-based channels are not supported "
                     "on this architecture" );
116
#endif
Sam Hocevar's avatar
   
Sam Hocevar committed
117

Henri Fallon's avatar
   
Henri Fallon committed
118
    /* Allocate structure */
119
120
    p_this->p_vlc->p_channel = malloc( sizeof( input_channel_t ) );
    if( p_this->p_vlc->p_channel == NULL )
Henri Fallon's avatar
   
Henri Fallon committed
121
    {
122
        msg_Err( p_this, "out of memory" );
Henri Fallon's avatar
   
Henri Fallon committed
123
124
125
126
        return( -1 );
    }

    /* Initialize structure */
127
128
    p_this->p_vlc->p_channel->i_channel   = 0;
    p_this->p_vlc->p_channel->last_change = 0;
Henri Fallon's avatar
   
Henri Fallon committed
129

130
    msg_Dbg( p_this, "channels initialized" );
Henri Fallon's avatar
   
Henri Fallon committed
131
132
133
134
135
136
    return( 0 );
}

/*****************************************************************************
 * network_ChannelJoin: join a channel
 *****************************************************************************
Sam Hocevar's avatar
   
Sam Hocevar committed
137
138
139
140
 * This function will try to join a channel. If the relevant interface is
 * already on the good channel, nothing will be done. Else, and if possible
 * (if the interface is not locked), the channel server will be contacted
 * and a change will be requested. The function will block until the change
Sam Hocevar's avatar
   
Sam Hocevar committed
141
 * is effective. Note that once a channel is no more used, its interface
Henri Fallon's avatar
   
Henri Fallon committed
142
143
144
 * should be unlocked using input_ChannelLeave().
 * Non 0 will be returned in case of error.
 *****************************************************************************/
145
int __network_ChannelJoin( vlc_object_t *p_this, int i_channel )
Henri Fallon's avatar
   
Henri Fallon committed
146
{
147
#define VLCS_VERSION 13
Sam Hocevar's avatar
   
Sam Hocevar committed
148
#define MESSAGE_LENGTH 256
Sam Hocevar's avatar
   
Sam Hocevar committed
149

150
151
152
    module_t *       p_network;
    char *           psz_network = NULL;
    network_socket_t socket_desc;
Sam Hocevar's avatar
   
Sam Hocevar committed
153
154
    char psz_mess[ MESSAGE_LENGTH ];
    char psz_mac[ 40 ];
155
    int i_fd, i_port;
Sam Hocevar's avatar
   
Sam Hocevar committed
156
157
158
    char *psz_vlcs;
    struct timeval delay;
    fd_set fds;
Sam Hocevar's avatar
   
Sam Hocevar committed
159

Sam Hocevar's avatar
Sam Hocevar committed
160
161
162
163
164
    if( p_this->p_vlc->p_channel->i_channel == i_channel )
    {
        return 0;
    }

165
    if( !config_GetInt( p_this, "network-channel" ) )
Henri Fallon's avatar
   
Henri Fallon committed
166
    {
167
168
        msg_Err( p_this, "channels disabled, to enable them, use the"
                         " --channels option" );
Sam Hocevar's avatar
   
Sam Hocevar committed
169
        return -1;
Henri Fallon's avatar
   
Henri Fallon committed
170
    }
Sam Hocevar's avatar
   
Sam Hocevar committed
171

172
    if( config_GetInt( p_this, "ipv4" ) )
Sam Hocevar's avatar
   
Sam Hocevar committed
173
    {
174
        psz_network = "ipv4";
Sam Hocevar's avatar
   
Sam Hocevar committed
175
    }
176
    if( config_GetInt( p_this, "ipv6" ) )
Sam Hocevar's avatar
   
Sam Hocevar committed
177
    {
178
        psz_network = "ipv6";
Sam Hocevar's avatar
   
Sam Hocevar committed
179
180
    }

Sam Hocevar's avatar
   
Sam Hocevar committed
181
    /* Getting information about the channel server */
182
    if( !(psz_vlcs = config_GetPsz( p_this, "channel-server" )) )
gbazin's avatar
   
gbazin committed
183
    {
184
        msg_Err( p_this, "configuration variable channel-server empty" );
gbazin's avatar
   
gbazin committed
185
186
187
        return -1;
    }

188
    i_port = config_GetInt( p_this, "channel-port" );
Henri Fallon's avatar
   
Henri Fallon committed
189

190
    msg_Dbg( p_this, "connecting to %s:%d", psz_vlcs, i_port );
Marc Ariberti's avatar
Marc Ariberti committed
191

192
193
    /* Prepare the network_socket_t structure */
    socket_desc.i_type = NETWORK_UDP;
Sam Hocevar's avatar
   
Sam Hocevar committed
194
    socket_desc.psz_bind_addr = "";
195
196
197
198
199
    socket_desc.i_bind_port = 4321;
    socket_desc.psz_server_addr = psz_vlcs;
    socket_desc.i_server_port = i_port;

    /* Find an appropriate network module */
200
    p_network = module_Need( p_this, MODULE_CAPABILITY_NETWORK, psz_network,
201
202
                             &socket_desc );
    if( p_network == NULL )
Sam Hocevar's avatar
   
Sam Hocevar committed
203
    {
204
        return( -1 );
Sam Hocevar's avatar
   
Sam Hocevar committed
205
    }
206
207
208
209
    module_Unneed( p_network );

    free( psz_vlcs ); /* Do we really need this ? -- Meuuh */
    i_fd = socket_desc.i_handle;
Sam Hocevar's avatar
   
Sam Hocevar committed
210
211

    /* Look for the interface MAC address */
212
    if( GetMacAddress( p_this, i_fd, psz_mac ) )
Henri Fallon's avatar
   
Henri Fallon committed
213
    {
214
        msg_Err( p_this, "failed getting MAC address" );
Sam Hocevar's avatar
   
Sam Hocevar committed
215
        close( i_fd );
Sam Hocevar's avatar
   
Sam Hocevar committed
216
        return -1;
Marc Ariberti's avatar
Marc Ariberti committed
217
    }
Henri Fallon's avatar
   
Henri Fallon committed
218

219
    msg_Dbg( p_this, "MAC address is %s", psz_mac );
Henri Fallon's avatar
   
Henri Fallon committed
220

Sam Hocevar's avatar
   
Sam Hocevar committed
221
222
    /* Build the message */
    sprintf( psz_mess, "%d %u %lu %s \n", i_channel, VLCS_VERSION,
223
                       (unsigned long)(mdate() / (u64)1000000),
Sam Hocevar's avatar
   
Sam Hocevar committed
224
                       psz_mac );
Sam Hocevar's avatar
   
Sam Hocevar committed
225

Sam Hocevar's avatar
   
Sam Hocevar committed
226
    /* Send the message */
227
    send( i_fd, psz_mess, MESSAGE_LENGTH, 0 );
Henri Fallon's avatar
   
Henri Fallon committed
228

229
    msg_Dbg( p_this, "attempting to join channel %d", i_channel );
Henri Fallon's avatar
   
Henri Fallon committed
230

Sam Hocevar's avatar
   
Sam Hocevar committed
231
    /* We have changed channels ! (or at least, we tried) */
232
233
    p_this->p_vlc->p_channel->last_change = mdate();
    p_this->p_vlc->p_channel->i_channel = i_channel;
Sam Hocevar's avatar
   
Sam Hocevar committed
234

Sam Hocevar's avatar
   
Sam Hocevar committed
235
236
237
    /* Wait 5 sec for an answer from the server */
    delay.tv_sec = 5;
    delay.tv_usec = 0;
Sam Hocevar's avatar
   
Sam Hocevar committed
238
    FD_ZERO( &fds );
Sam Hocevar's avatar
   
Sam Hocevar committed
239
    FD_SET( i_fd, &fds );
Sam Hocevar's avatar
   
Sam Hocevar committed
240

Sam Hocevar's avatar
   
Sam Hocevar committed
241
    switch( select( i_fd + 1, &fds, NULL, NULL, &delay ) )
Henri Fallon's avatar
   
Henri Fallon committed
242
    {
Sam Hocevar's avatar
   
Sam Hocevar committed
243
        case 0:
244
            msg_Err( p_this, "no answer from vlcs" );
Sam Hocevar's avatar
   
Sam Hocevar committed
245
246
247
248
            close( i_fd );
            return -1;

        case -1:
249
            msg_Err( p_this, "error while listening to vlcs" );
Sam Hocevar's avatar
   
Sam Hocevar committed
250
251
252
            close( i_fd );
            return -1;
    }
Sam Hocevar's avatar
   
Sam Hocevar committed
253

254
255
    recv( i_fd, psz_mess, MESSAGE_LENGTH, 0 );
    psz_mess[ MESSAGE_LENGTH - 1 ] = '\0';
Sam Hocevar's avatar
   
Sam Hocevar committed
256

257
    if( !strncasecmp( psz_mess, "E:", 2 ) )
Sam Hocevar's avatar
   
Sam Hocevar committed
258
    {
259
        msg_Err( p_this, "vlcs said '%s'", psz_mess + 2 );
Sam Hocevar's avatar
   
Sam Hocevar committed
260
261
262
        close( i_fd );
        return -1;
    }
263
    else if( !strncasecmp( psz_mess, "I:", 2 ) )
Sam Hocevar's avatar
   
Sam Hocevar committed
264
    {
265
        msg_Dbg( p_this, "vlcs said '%s'", psz_mess + 2 );
Sam Hocevar's avatar
   
Sam Hocevar committed
266
    }
267
    else
Sam Hocevar's avatar
   
Sam Hocevar committed
268
    {
269
270
271
272
273
        /* We got something to play ! */
        playlist_t *p_playlist;
        p_playlist = vlc_object_find( p_this, VLC_OBJECT_PLAYLIST,
                                              FIND_ANYWHERE );
        if( p_playlist != NULL )
274
        {
275
276
277
            playlist_Add( p_playlist, psz_mess,
                          PLAYLIST_APPEND | PLAYLIST_GO, PLAYLIST_END );
            vlc_object_release( p_playlist );
278
        }
Henri Fallon's avatar
   
Henri Fallon committed
279
    }
Sam Hocevar's avatar
   
Sam Hocevar committed
280

Sam Hocevar's avatar
   
Sam Hocevar committed
281
    /* Close the socket and return nicely */
282
#ifndef WIN32
Sam Hocevar's avatar
   
Sam Hocevar committed
283
    close( i_fd );
284
285
286
#else
    closesocket( i_fd );
#endif
Henri Fallon's avatar
   
Henri Fallon committed
287

Sam Hocevar's avatar
   
Sam Hocevar committed
288
    return 0;
Henri Fallon's avatar
   
Henri Fallon committed
289
}
Sam Hocevar's avatar
   
Sam Hocevar committed
290

Sam Hocevar's avatar
   
Sam Hocevar committed
291
292
293
294
295
/* Following functions are local */

/*****************************************************************************
 * GetMacAddress: extract the MAC Address
 *****************************************************************************/
296
static int GetMacAddress( vlc_object_t *p_this, int i_fd, char *psz_mac )
Sam Hocevar's avatar
   
Sam Hocevar committed
297
298
299
300
{
#if defined( SYS_LINUX )
    struct ifreq interface;
    int i_ret;
gbazin's avatar
   
gbazin committed
301
    char *psz_interface;
Sam Hocevar's avatar
   
Sam Hocevar committed
302
303
304
305
306

    /*
     * Looking for information about the eth0 interface
     */
    interface.ifr_addr.sa_family = AF_INET;
307
    if( !(psz_interface = config_GetPsz( p_this, "iface" )) )
gbazin's avatar
   
gbazin committed
308
    {
309
        msg_Err( p_this, "configuration variable iface empty" );
gbazin's avatar
   
gbazin committed
310
311
312
313
        return -1;
    }
    strcpy( interface.ifr_name, psz_interface );
    free( psz_interface );
Sam Hocevar's avatar
   
Sam Hocevar committed
314

Sam Hocevar's avatar
   
Sam Hocevar committed
315
    i_ret = ioctl( i_fd, SIOCGIFHWADDR, &interface );
Sam Hocevar's avatar
   
Sam Hocevar committed
316
317
318

    if( i_ret )
    {
319
        msg_Err( p_this, "ioctl SIOCGIFHWADDR failed" );
Sam Hocevar's avatar
   
Sam Hocevar committed
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
        return( i_ret );
    }

    sprintf( psz_mac, "%2.2x:%2.2x:%2.2x:%2.2x:%2.2x:%2.2x",
                      interface.ifr_hwaddr.sa_data[0] & 0xff,
                      interface.ifr_hwaddr.sa_data[1] & 0xff,
                      interface.ifr_hwaddr.sa_data[2] & 0xff,
                      interface.ifr_hwaddr.sa_data[3] & 0xff,
                      interface.ifr_hwaddr.sa_data[4] & 0xff,
                      interface.ifr_hwaddr.sa_data[5] & 0xff );

    return( 0 );

#elif defined( WIN32 )
    int i, i_ret = -1;

    /* Get adapter list - support for more than one adapter */
    LANA_ENUM AdapterList;
    NCB       Ncb;

340
    msg_Dbg( p_this, "looking for MAC address" );
Sam Hocevar's avatar
   
Sam Hocevar committed
341
342
343
344
345
346
347
348
349
350
351
352

    memset( &Ncb, 0, sizeof( NCB ) );
    Ncb.ncb_command = NCBENUM;
    Ncb.ncb_buffer = (unsigned char *)&AdapterList;
    Ncb.ncb_length = sizeof( AdapterList );
    Netbios( &Ncb );

    /* Get all of the local ethernet addresses */
    for ( i = 0; i < AdapterList.length ; ++i )
    {
        if ( GetAdapterInfo ( AdapterList.lana[ i ], psz_mac ) == 0 )
        {
Sam Hocevar's avatar
   
Sam Hocevar committed
353
            i_ret = 0;
Sam Hocevar's avatar
   
Sam Hocevar committed
354
355
356
357
358
        }
    }

    return( i_ret );

Sam Hocevar's avatar
   
Sam Hocevar committed
359
#else
360
361
    strcpy( psz_mac, "00:00:00:00:00:00" );
    return( 0 );
Sam Hocevar's avatar
   
Sam Hocevar committed
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385

#endif
}

#ifdef WIN32
/*****************************************************************************
 * GetAdapterInfo : gets some informations about the interface using NETBIOS
 *****************************************************************************/
static int GetAdapterInfo( int i_adapter, char *psz_string )
{
    struct ASTAT
    {
        ADAPTER_STATUS adapt;
        NAME_BUFFER    psz_name[30];
    } Adapter;

    /* Reset the LAN adapter so that we can begin querying it */
    NCB Ncb;
    memset( &Ncb, 0, sizeof ( Ncb ) );
    Ncb.ncb_command  = NCBRESET;
    Ncb.ncb_lana_num = i_adapter;

    if( Netbios( &Ncb ) != NRC_GOODRET )
    {
386
//X        intf_ErrMsg( "network error: reset returned %i", Ncb.ncb_retcode );
Sam Hocevar's avatar
   
Sam Hocevar committed
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
        return -1;
    }

    /* Prepare to get the adapter status block */
    memset( &Ncb, 0, sizeof( Ncb ) ) ;     /* Initialization */
    Ncb.ncb_command = NCBASTAT;
    Ncb.ncb_lana_num = i_adapter;

    strcpy( (char *)Ncb.ncb_callname, "*" );

    memset( &Adapter, 0, sizeof ( Adapter ) );
    Ncb.ncb_buffer = ( unsigned char * ) &Adapter;
    Ncb.ncb_length = sizeof ( Adapter );

    /* Get the adapter's info and, if this works, return it in standard,
     * colon-delimited form. */
    if ( Netbios( &Ncb ) == 0 )
    {
        sprintf ( psz_string, "%02X:%02X:%02X:%02X:%02X:%02X",
                (int) ( Adapter.adapt.adapter_address[0] ),
                (int) ( Adapter.adapt.adapter_address[1] ),
                (int) ( Adapter.adapt.adapter_address[2] ),
                (int) ( Adapter.adapt.adapter_address[3] ),
                (int) ( Adapter.adapt.adapter_address[4] ),
                (int) ( Adapter.adapt.adapter_address[5] ) );

413
//X        intf_WarnMsg( 2, "network: found MAC address %s", psz_string );
Sam Hocevar's avatar
   
Sam Hocevar committed
414
415
416
417
418

        return 0;
    }
    else
    {
419
//X        intf_ErrMsg( "network error: ASTAT returned %i", Ncb.ncb_retcode );
Sam Hocevar's avatar
   
Sam Hocevar committed
420
421
422
423
424
        return -1;
    }
}
#endif /* WIN32 */