git.sesse.net Git - vlc/blob - src/input/input_vlan.c

   1 /*******************************************************************************
   2  * input_vlan.c: vlan management library
   3  * (c)1999 VideoLAN
   4  *******************************************************************************/
   5
   6 /*******************************************************************************
   7  * Preamble
   8  *******************************************************************************/
   9 #include <errno.h>
  10 #include <stdio.h>
  11 #include <unistd.h>
  12 #include <string.h>
  13 #include <stdlib.h>
  14
  15 #include <arpa/inet.h>
  16 #include <net/if.h>
  17 #include <netinet/in.h>
  18 #include <sys/ioctl.h>
  19 #include <sys/socket.h>
  20
  21 #include "config.h"
  22 #include "common.h"
  23 #include "mtime.h"
  24 #include "vlc_thread.h"
  25 #include "netutils.h"
  26 #include "input_vlan.h"
  27 #include "intf_msg.h"
  28 #include "main.h"
  29
  30 /*******************************************************************************
  31  * input_vlan_t: vlan library data
  32  *******************************************************************************
  33  * Store global vlan library data.
  34  *******************************************************************************/
  35 typedef struct input_vlan_s
  36 {
  37     int         i_vlan_id;                              /* current vlan number */
  38     mtime_t     last_change;                               /* last change date */
  39 } input_vlan_t;
  40
  41 /*******************************************************************************
  42  * Local prototypes
  43  *******************************************************************************/
  44 static int ZeTrucMucheFunction( int Channel );
  45
  46 /*******************************************************************************
  47  * input_VlanCreate: initialize global vlan method data
  48  *******************************************************************************
  49  * Initialize vlan input method global data. This function should be called
  50  * once before any input thread is created or any call to other input_Vlan*()
  51  * function is attempted.
  52  *******************************************************************************/
  53 int input_VlanCreate( void )
  54 {
  55     /* Allocate structure */
  56     p_main->p_vlan = malloc( sizeof( input_vlan_t ) );
  57     if( p_main->p_vlan == NULL )
  58     {
  59         intf_ErrMsg("error: %s\n", strerror(ENOMEM));
  60         return( 1 );
  61     }
  62
  63     /* Initialize structure */
  64     p_main->p_vlan->i_vlan_id   = 0;
  65     p_main->p_vlan->last_change = 0;
  66
  67     intf_Msg("VLANs initialized\n");
  68     return( 0 );
  69 }
  70
  71 /*******************************************************************************
  72  * input_VlanDestroy: free global vlan method data
  73  *******************************************************************************
  74  * Free resources allocated by input_VlanMethodInit. This function should be
  75  * called at the end of the program.
  76  *******************************************************************************/
  77 void input_VlanDestroy( void )
  78 {
  79     /* Return to default vlan */
  80     if( p_main->p_vlan->i_vlan_id != 0 )
  81     {
  82         input_VlanJoin( 0 );
  83     }
  84
  85     /* Free structure */
  86     free( p_main->p_vlan );
  87 }
  88
  89 /*******************************************************************************
  90  * input_VlanJoin: join a vlan
  91  *******************************************************************************
  92  * This function will try to join a vlan. If the relevant interface is already
  93  * on the good vlan, nothing will be done. Else, and if possible (if the
  94  * interface is not locked), the vlan server will be contacted and a change will
  95  * be requested. The function will block until the change is effective. Note
  96  * that once a vlan is no more used, it's interface should be unlocked using
  97  * input_VlanLeave().
  98  * Non 0 will be returned in case of error.
  99  *******************************************************************************/
 100 int input_VlanJoin( int i_vlan_id )
 101 {
 102     /* If last change is too recent, wait a while */
 103     if( mdate() - p_main->p_vlan->last_change < INPUT_VLAN_CHANGE_DELAY )
 104     {
 105         intf_Msg("Waiting before changing VLAN...\n");
 106         mwait( p_main->p_vlan->last_change + INPUT_VLAN_CHANGE_DELAY );
 107     }
 108     p_main->p_vlan->last_change = mdate();
 109     p_main->p_vlan->i_vlan_id = i_vlan_id;
 110
 111     intf_Msg("Joining VLAN %d (channel %d)\n", i_vlan_id + 2, i_vlan_id );
 112     return( ZeTrucMucheFunction( i_vlan_id ) ); // ?? join vlan
 113 }
 114
 115 /*******************************************************************************
 116  * input_VlanLeave: leave a vlan
 117  *******************************************************************************
 118  * This function tells the vlan library that the designed interface is no more
 119  * locked and than vlan changes can occur.
 120  *******************************************************************************/
 121 void input_VlanLeave( int i_vlan_id )
 122 {
 123     // ??
 124 }
 125
 126 /* following functions are local */
 127
 128 static int ZeTrucMucheFunction( int Channel)
 129 {
 130         int                     i_socket;
 131         char    *               ipaddr;
 132         struct ifreq            interface;
 133         struct sockaddr_in      sa_server;
 134         struct sockaddr_in      sa_client;
 135         char mess[80];
 136
 137         return( 0 );
 138
 139         /*
 140          *Looking for informations about the eth0 interface
 141          */
 142
 143         interface.ifr_addr.sa_family = AF_INET;
 144         strcpy( interface.ifr_name, main_GetPszVariable( INPUT_IFACE_VAR, INPUT_IFACE_DEFAULT ) );
 145
 146         i_socket = socket( AF_INET, SOCK_DGRAM, 0 );
 147
 148         /* Looking for the interface IP address */
 149         ioctl( i_socket, SIOCGIFDSTADDR, &interface );
 150         ipaddr = inet_ntoa((*(struct sockaddr_in *)(&(interface.ifr_addr))).sin_addr );
 151
 152         /* Looking for the interface MAC address */
 153         ioctl( i_socket, SIOCGIFHWADDR, &interface );
 154         close( i_socket );
 155
 156         /*
 157          * Getting address, port, ... of the server
 158          */
 159
 160         /* Initialize */
 161         bzero( &sa_server, sizeof(struct sockaddr_in) );
 162         /* sin_family is ALWAYS set to AF_INET (see in man 7 ip)*/
 163         sa_server.sin_family = AF_INET;
 164         /* Giving port on to connect after having convert it*/
 165         sa_server.sin_port = htons ( main_GetIntVariable( INPUT_VLAN_PORT_VAR, INPUT_VLAN_PORT_DEFAULT ));
 166         /* Giving address after having convert it into binary data*/
 167         inet_aton( main_GetPszVariable( INPUT_VLAN_SERVER_VAR, INPUT_VLAN_SERVER_DEFAULT ), &(sa_server.sin_addr) );
 168
 169         /*
 170          * Getting address, port, ... of the client
 171          */
 172
 173         /* Initialize */
 174         bzero( &sa_client, sizeof(struct sockaddr_in) );
 175         /* sin_family is ALWAYS set to AF_INET (see in man 7 ip)*/
 176         sa_client.sin_family = AF_INET;
 177         /* Giving port on to connect after having convert it*/
 178         sa_client.sin_port = htons( 0 );
 179         /* Giving address after having convert it into binary data*/
 180         inet_aton( ipaddr, &(sa_client.sin_addr) );
 181
 182         /* Initialization of the socket */
 183         i_socket = socket(AF_INET, SOCK_DGRAM, 17 ); // ?? UDP
 184          /*  SOCK_DGRAM because here we use DATAGRAM
 185           * Sachant qu'il y a un #define AF_INET = PF_INET dans sys/socket.h et que PF_INET est le IP protocol family ...
 186           * Protocol is in #define, should be 17 for udp */
 187
 188         /* Elaborate the message to send */
 189         sprintf( mess , "%d %s %2.2x%2.2x%2.2x%2.2x%2.2x%2.2x %2.2x:%2.2x:%2.2x:%2.2x:%2.2x:%2.2x \n",
 190                     Channel, ipaddr,
 191                     interface.ifr_hwaddr.sa_data[0] & 0xff,
 192                     interface.ifr_hwaddr.sa_data[1] & 0xff,
 193                     interface.ifr_hwaddr.sa_data[2] & 0xff,
 194                     interface.ifr_hwaddr.sa_data[3] & 0xff,
 195                     interface.ifr_hwaddr.sa_data[4] & 0xff,
 196                     interface.ifr_hwaddr.sa_data[5] & 0xff,
 197                     interface.ifr_hwaddr.sa_data[0] & 0xff,
 198                     interface.ifr_hwaddr.sa_data[1] & 0xff,
 199                     interface.ifr_hwaddr.sa_data[2] & 0xff,
 200                     interface.ifr_hwaddr.sa_data[3] & 0xff,
 201                     interface.ifr_hwaddr.sa_data[4] & 0xff,
 202                     interface.ifr_hwaddr.sa_data[5] & 0xff
 203             );
 204
 205         /* Send the message */
 206         intf_DbgMsg("%s\n", mess);
 207         sendto(i_socket,mess,80,0,(struct sockaddr *)&sa_server,sizeof(struct sockaddr));
 208
 209         /*Close the socket */
 210         close( i_socket );
 211
 212         return 0;
 213 }