---

dhcp.c

Go to the documentation of this file.

/*! \file dhcp.c
    Main entry point for the DHCP server.
 */


#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <pwd.h>
#include <grp.h>
#include <time.h>

#ifdef READ_PACKET_FROM_FILE
  #include <sys/stat.h>
  #include <fcntl.h>
  #include <dirent.h>
#endif

#ifdef DUMP_PACKETS
  #include <sys/stat.h>
  #include <fcntl.h>
#endif

#include "dhcp.h"
#include "modem.h"
#include "sockets.h"
#include "server_config.h"
#include "mysql_header.h"
#include "mysql_interface.h"
#include "logging.h"
#include "deamon.h"
#include "logistic.h"
#include "packets_data.h"
#include "conversion.h"
#include "packets.h"
#include "find_ip_and_reply.h"
#include "packets_operations.h"

#ifdef READ_PACKET_FROM_FILE
  #define INPUT_PACKET_DIRECTORY        "/tmp/dhcp"
  #define INPUT_PACKET_FILE_NAME_SIZE   2048
#endif

/*! \brief Last MySql error message. This variable is defined in the file 'mysql.c'.
 */

extern char mysql_error_str[MYSQL_MAX_ERROR_SIZE];

/*! \brief Last MySql error code. This variable is defined in the file 'mysql.c'.
 */

extern int mysql_error_errno;

/*! \brief This structure contains the global server configuration.
           It is defined in the C file 'configuration.c'.
 */

extern struct global_config configuration_globale;

/*! \brief This structure contains the configuration for the connection to the local DHCP database.
           This database is access only for READ operations.
 */

static struct smysql conf_mysql_dhcp_read_only;

/*! \brief This structure contains the configuration for the connection to the POOL database.
           This database contains the pool of dynamic IP addresses.
           It is accessed for READ and WRITE operations.
 */

static struct smysql conf_mysql_dhcp_read_write;

/*! \brief This structure contains the configuration for the connection to the Radonline database.
 */

static struct smysql conf_mysql_radonline;

/*! \brief This structure contains the configuration for the connection to the Mydns database.
 */

static struct smysql conf_mysql_mydns;

/*! \brief This structure contains the configuration for the connection to the Logistic database.
 */

static struct smysql conf_mysql_logistic;

/*! \brief This array contains the configuration tags associated to the local DHCP database
           (read only database).
 */

static char *tags_read[MYSQL_CONFIGURATION_TAG_NUMBER] =
       {
         "mysql-host-dhcp-read",
         "mysql-user-dhcp-read",
         "mysql-passwd-dhcp-read",
         "mysql-db-dhcp-read",
         "mysql-port-dhcp-read",
         "mysql-socket-dhcp-read",
         "mysql-retry-dhcp-read",
         "mysql-timeout-dhcp-read",
         "mysql-sleep-dhcp-read",
         "mysql-debug-dhcp-read",
         "mysql-log-file-dhcp-read",
         "mysql-reconnection-delay-dhcp-read"
       };

/*! \brief This array contains the configuration tags associated to the POOL DHCP database.
           (read/write database).
 */

static char *tags_read_write[MYSQL_CONFIGURATION_TAG_NUMBER] =
       {
         "mysql-host-dhcp-read-write",
         "mysql-user-dhcp-read-write",
         "mysql-passwd-dhcp-read-write",
         "mysql-db-dhcp-read-write",
         "mysql-port-dhcp-read-write",
         "mysql-socket-dhcp-read-write",
         "mysql-retry-dhcp-read-write",
         "mysql-timeout-dhcp-read-write",
         "mysql-sleep-dhcp-read-write",
         "mysql-debug-dhcp-read-write",
         "mysql-log-file-dhcp-read-write",
         "mysql-reconnection-delay-dhcp-read-write"
       };

/*! \brief This array contains the configuration tags associated to the radonline database.
 */

static char *tags_radonline[MYSQL_CONFIGURATION_TAG_NUMBER] =
       {
         "mysql-host-radonline",
         "mysql-user-radonline",
         "mysql-passwd-radonline",
         "mysql-db-radonline",
         "mysql-port-radonline",
         "mysql-socket-radonline",
         "mysql-retry-radonline",
         "mysql-timeout-radonline",
         "mysql-sleep-radonline",
         "mysql-debug-radonline",
         "mysql-log-file-radonline",
         "mysql-reconnection-delay-radonline"
       };

/*! \brief This array contains the configuration tags associated to the mydns database.
 */

static char *tags_mydns[MYSQL_CONFIGURATION_TAG_NUMBER] =
       {
         "mysql-host-mydns",
         "mysql-user-mydns",
         "mysql-passwd-mydns",
         "mysql-db-mydns",
         "mysql-port-mydns",
         "mysql-socket-mydns",
         "mysql-retry-mydns",
         "mysql-timeout-mydns",
         "mysql-sleep-mydns",
         "mysql-debug-mydns",
         "mysql-log-file-mydns",
         "mysql-reconnection-delay-mydns"
       };

/*! \brief This array contains the configuration tags associated to the Logistic database.
 */

static char *tags_logistic[MYSQL_CONFIGURATION_TAG_NUMBER] =
       {
         "mysql-host-logistic",
         "mysql-user-logistic",
         "mysql-passwd-logistic",
         "mysql-db-logistic",
         "mysql-port-logistic",
         "mysql-socket-logistic",
         "mysql-retry-logistic",
         "mysql-timeout-logistic",
         "mysql-sleep-logistic",
         "mysql-debug-logistic",
         "mysql-log-file-logistic",
         "mysql-reconnection-delay-logistic"
       };

/*! \brief Build information. The tags __DATE__ and __HOST__ will be replaced by the output of commands
           'date' and 'uname -a'.
 */

#define BUILD "This binary was build the __DATE__ on __HOST__"

/*! \brief CVS tags for all sources.
 */

#define CVS_TAGS "__CVSTAGS__"


#ifdef XID_FILTERING
  #define BUFFSIZE 32
  int packet_testing (unsigned long int xid);
#endif


#ifdef TEST_MYSQL_NOW

#define MTSQL_TESTING(n,s) \
        if (mtest == n) \
        { my_syslog (configuration_globale.log_file, "[MYSQL TESTING] [%s:%d] Step %d (%s), wait 15 secondes", \
                     __FILE__, __LINE__, n, s); sleep(15); }
#else

#define MTSQL_TESTING(n,s)

#endif



static void dump_packet_hexa (void* packet, int size, char* file);

/*! \brief File descriptor associated to the file used to synchronize access to the dump file.
 */

int dump_sync_fd = 0;

/*! \brief Main entry point for the DHCP server.
    \author Denis BEURIVE
 */

int main (int argc, char **argv)
{
  int                    sck, mess_size, adress_size, rc;

  #ifdef TEST_MYSQL_NOW
     int                 mtest;
  #endif

  #ifdef DUMP_PACKETS
     int                 dumpfd;
  #endif

  #ifdef READ_PACKET_FROM_FILE
     char                input_packet_file_name[INPUT_PACKET_FILE_NAME_SIZE];
     struct dirent       *input_packet_from_dir;
     DIR                 *input_directory;
     int                 packet_file;
  #endif

  struct dhcp_packet     packet_in;
  char                   interface[IFNAMSIZ], *error;
  struct sockaddr_in     addr_server, addr_original;
  unsigned long int      broadcast, netmask, server_ip;
  FILE                   *pid_file;
  pid_t                  pid;
  struct passwd          *passwords;
  struct group           *groups;
  gid_t                  grp_id;
  uid_t                  user_id;
  struct mysql_tables    mysql_tables;
  int                    modem_manufacturor;


  fprintf (stdout, "%s\n\n", BUILD);
  fprintf (stdout, "%s\n\n", CVS_TAGS);

  #ifdef READ_PACKET_FROM_FILE

     fprintf (stdout, "WARNING !!!!\n\n");
     fprintf (stdout, "This version of the DHCP server has been compiled with the option ");
     fprintf (stdout, "READ_PACKET_FROM_FILE! This means that it will __NOT__ listen to ");
     fprintf (stdout, "the network. It will load data from the directory <%s>\n\n",
              INPUT_PACKET_DIRECTORY);

  #endif

  /* ------------------------------------------------ */
  /* Check the command line                           */
  /* ------------------------------------------------ */

  #ifndef TEST_MYSQL_NOW
  if (argc != 2)
  {
    fprintf (stderr, "Usage: mydhcpd <path to configuration file>\n");
    fprintf (stderr, "       Log tag is [session ID] [mac address] [DSLAM's ID]\n");
    fprintf (stderr, "       session ID: Refers to a client's request.\n");
    fprintf (stderr, "       mac address: Mac address sent by the modem.\n");
    fprintf (stderr, "       DSLAM's ID: node/shelf/slot/port/vci/vlanID/gateway.\n\n");
    fprintf (stderr, "       CSV structure is:\n\n");

    fprintf (stderr, "       1  Date\n");
    fprintf (stderr, "       2  Auto increment\n");
    fprintf (stderr, "       3  Host name\n");
    fprintf (stderr, "       4  Direction (IN or OUT)\n");
    fprintf (stderr, "       5  Sender's IP address (if direction is IN)\n");
    fprintf (stderr, "       6  Sender's TCP port (if direction is IN)\n");
    fprintf (stderr, "       7  Receiver's IP address (if direction is OUT)\n");
    fprintf (stderr, "       8  Receiver's TCP port (if direction is OUT)\n");
    fprintf (stderr, "       9  Type of DHCP request\n");
    fprintf (stderr, "       10 Number of bytes of the UDP packet\n");
    fprintf (stderr, "       11 Opcode\n");
    fprintf (stderr, "       12 Hardware address type\n");
    fprintf (stderr, "       13 Hardware address length\n");
    fprintf (stderr, "       14 Hop count\n");
    fprintf (stderr, "       15 Transaction ID\n");
    fprintf (stderr, "       16 Ellapsed time\n");
    fprintf (stderr, "       17 Flags\n");
    fprintf (stderr, "       18 Client's IP address, as defined in the DHCP packet\n");
    fprintf (stderr, "       19 Your IP address, as defined in the DHCP packet\n"); 
    fprintf (stderr, "       20 Server IP address, as defined in the DHCP packet\n");
    fprintf (stderr, "       21 Gateway IP address, as defined in the DHCP packet\n");
    fprintf (stderr, "       22 Client's hardware address\n"); 
    fprintf (stderr, "       23 Server's host name\n");
    fprintf (stderr, "       24 Boot file name\n");
    fprintf (stderr, "       25 Modem's constructor\n");
    fprintf (stderr, "       26 82\n");
    fprintf (stderr, "       27 vendor ID\n");
    fprintf (stderr, "       28 port type\n");
    fprintf (stderr, "       29 version\n");
    fprintf (stderr, "       30 vlan ID\n");
    fprintf (stderr, "       31 nas mac\n");
    fprintf (stderr, "       32 nas IP\n");
    fprintf (stderr, "       33 node ID\n");
    fprintf (stderr, "       34 shelf\n");
    fprintf (stderr, "       35 slot\n");
    fprintf (stderr, "       36 port\n");
    fprintf (stderr, "       37 VPI\n");
    fprintf (stderr, "       38 VCI\n");
    fprintf (stderr, "       39 vendor\n");
    fprintf (stderr, "       40 Subnet (option 1)\n");
    fprintf (stderr, "       41 Router (option 3)\n");
    fprintf (stderr, "       42 Domain name (option 15)\n");
    fprintf (stderr, "       43 DNS (option 6)\n");
    fprintf (stderr, "       44 Option code|Literal description|Option value\n");
    fprintf (stderr, "       45 Option code|Literal description|Option value\n");
    fprintf (stderr, "       ...\n\n");
    return 1;
  }
  #else
  if (argc != 3)
  {
    fprintf (stderr, "This binary is compiled for MySql testing\n\n");
    fprintf (stderr, "Usage: mydhcpd <path to configuration file> <test ID>\n");
    return 1;
  }

  mtest = atoi(argv[2]);

  fprintf (stdout, "Testing step number %d\n\n\n", mtest); fflush(stdout);
  #endif

  /* ------------------------------------------------ */
  /* Load configuration file                          */
  /* ------------------------------------------------ */

  if (configuration_load (argv[1], &error) == 1)
  {
    fprintf (stderr, "[FATAL] %s\n", error);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Test access to the log file                      */
  /* ------------------------------------------------ */

  init_syslogger();

  if (configuration_globale.log_size_management) { activate_log_size_management(); }

  if (my_syslog (configuration_globale.log_file, "[%s:%d] [INFO] Starting MyDhcp server (%s)",
                 __FILE__, __LINE__, BUILD))
  {
    fprintf (stderr, "[FATAL] Could not access my log file <%s> : %s\n",
             configuration_globale.log_file,
             logger_last_error());
    return 1;
  }

  #ifdef 0
  my_syslog (configuration_globale.log_file, "[%s:%d] [INFO] CVS: %s",
             __FILE__, __LINE__, CVS_TAGS);
  #endif

  /* ------------------------------------------------ */
  /* Give access to anybody for all logs              */
  /* ------------------------------------------------ */

  if (chmod(configuration_globale.log_file, S_IROTH | S_IWOTH | S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP) == -1)
  {
    fprintf (stderr, "[FATAL] Could not change access rights for log file <%s>. Please check permissions\n",
             configuration_globale.log_file);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not change access rights for log file <%s>. Please check permissions.",
               __FILE__,
               __LINE__,
               configuration_globale.log_file);
    return 1;
  }

  if (access (configuration_globale.debug_file, F_OK) == 0)
  {
    if (chmod(configuration_globale.debug_file, S_IROTH | S_IWOTH | S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP) == -1)
    {
      fprintf (stderr, "[FATAL] Could not change access rights for dumper file <%s>. Please check permissions\n",
               configuration_globale.debug_file);
      my_syslog (configuration_globale.log_file,
                 "[FATAL] [%s:%d] Could not change access rights for dumper file <%s>. Please check permissions",
                 __FILE__,
                 __LINE__,
                 configuration_globale.debug_file);
      return 1;
    }
  }

  /* ------------------------------------------------ */
  /* Open synchronization files, create if necessary  */
  /* ------------------------------------------------ */

  dump_sync_fd = -1;

  if (strcmp (configuration_globale.sync_dump, "Desactivate synchronisation") != 0)
  {
     my_syslog (configuration_globale.log_file,
                "[INFO] [%s:%d] Get synchronization file (%s) for dump access",
                 __FILE__,
                 __LINE__,
                 configuration_globale.sync_dump);
     
     dump_sync_fd = open (configuration_globale.sync_dump, O_CREAT);
   
     if (dump_sync_fd == -1)
     {
       fprintf (stderr, "[FATAL] Could not open sybchronization gile (%s) for dump access.",
                configuration_globale.sync_dump);
       my_syslog (configuration_globale.log_file,
                  "[FATAL] [%s:%d] Could not open sybchronization gile (%s) for dump access.",
                  __FILE__,
                  __LINE__,
                  configuration_globale.sync_dump);
       return 1;
     }
  }

  /* ------------------------------------------------ */
  /* Convert symbolic UID and GID into system IDs     */
  /* ------------------------------------------------ */

  passwords = getpwnam (configuration_globale.deamon_user_id);

  if (passwords == NULL)
  {
    fprintf (stderr, "[FATAL] Could not find UNIX user <%s> into /etc/passwd! Make sure that this UNIX user exists\n",
                     configuration_globale.deamon_user_id);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not find UNIX user <%s> into /etc/passwd! Make sure that this UNIX user exists",
               __FILE__,
               __LINE__,
               configuration_globale.deamon_user_id);
    return 1;
  }

  groups = getgrnam (configuration_globale.deamon_group_id);

  if (groups == NULL)
  {
    fprintf (stderr, "[FATAL] Could not find group <%s> into /etc/group!",
                     configuration_globale.deamon_group_id);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not find group <%s> into /etc/group!",
               __FILE__,
               __LINE__,
               configuration_globale.deamon_group_id);
    return 1;
  }

  grp_id   = groups->gr_gid;
  user_id  = passwords->pw_uid;

  my_syslog (configuration_globale.log_file,
             "[INFO] [%s:%d] User %s -> %d and Group %s -> %d",
             __FILE__,
             __LINE__,
             configuration_globale.deamon_user_id,
             (int)user_id,
             configuration_globale.deamon_group_id,
             (int)grp_id);

  /* ------------------------------------------------ */
  /* Some security tests                              */
  /* ------------------------------------------------ */

  if (configuration_globale.dumper_mode == 2)
  {
    fprintf (stdout, "WARNING: You selected 'dumper-mode = total' in configuration file '%s'.\n", argv[1]);
    fprintf (stdout, "The server will __NOT__ respond to any incoming request.\n");
    fprintf (stdout, "Is it realy what you want ?\n\n");

    fprintf (stdout, "ALERTE: Vous avez selectionne 'dumper-mode = total' dans le fichier de configuration '%s'",
                     argv[1]);
    fprintf (stdout, "Le server ne repondra __PAS__ aux requetes en provenances des clients.\n");
    fprintf (stdout, "Est-ce vraiment ce que vous voulez?\n\n");
  }

  /* ------------------------------------------------ */
  /* Create socket                                    */
  /* ------------------------------------------------ */

  sck = create_socket (
                        SERVER_PORT,
                        &addr_server,
                        configuration_globale.dhcp_bind_ip,
                        interface,
                        IFNAMSIZ,
                        &broadcast,
                        &netmask,
                        &server_ip,
                        my_syslog,
                        configuration_globale.log_file);

  if (sck == -1)
  {
    fprintf (stderr, "[FATAL] %s\n", get_last_socket_error());
    my_syslog (configuration_globale.log_file, "[FATAL] [%s:%d] %s",
               __FILE__,
               __LINE__,
               get_last_socket_error());
    return 1;
  }

  /* ------------------------------------------------ */
  /* Load configuration for the connection to the     */
  /* local DHCP database (READ only).                 */
  /* ------------------------------------------------ */

  rc = load_mysql_configuration_from_file (argv[1], &conf_mysql_dhcp_read_only, tags_read, my_syslog);

  if (rc)
  {
    fprintf (stderr, "[FATAL] Error while loading configuration for local DHCP database connection - %s",
                     conf_mysql_dhcp_read_only.last_error_str);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not load configuration for local DHCP database connection - %s",
               __FILE__,
               __LINE__,
               conf_mysql_dhcp_read_only.last_error_str);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Load configuration for the connection to the     */
  /* POOL database (READ/WRITE).                      */
  /* ------------------------------------------------ */

  rc = load_mysql_configuration_from_file (argv[1], &conf_mysql_dhcp_read_write, tags_read_write, my_syslog);

  if (rc)
  {
    fprintf (stderr, "[FATAL] Error while loading configuration for POOL DHCP database connection - %s",
                     conf_mysql_dhcp_read_write.last_error_str);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not load configuration for POOL DHCP database connection - %s",
               __FILE__,
               __LINE__,
               conf_mysql_dhcp_read_write.last_error_str);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Load configuration for the connection to the     */
  /* radonline database.                              */
  /* ------------------------------------------------ */

  rc = load_mysql_configuration_from_file (argv[1], &conf_mysql_radonline, tags_radonline, my_syslog);

  if (rc)
  {
    fprintf (stderr, "[FATAL] Error while loading configuration for connection to Radonline - %s",
                     conf_mysql_radonline.last_error_str);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not load configuration for connection to Radonline - %s",
               __FILE__,
               __LINE__,
               conf_mysql_radonline.last_error_str);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Load configuration for the connection to the     */
  /* mydns database.                                  */
  /* ------------------------------------------------ */

  rc = load_mysql_configuration_from_file (argv[1], &conf_mysql_mydns, tags_mydns, my_syslog);

  if (rc)
  {
    fprintf (stderr, "[FATAL] Error while loading configuration for connection to Mydns - %s",
                     conf_mysql_mydns.last_error_str);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not load configuration for connection to Mydns - %s",
               __FILE__,
               __LINE__,
               conf_mysql_mydns.last_error_str);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Load configuration for the Logistic database.    */
  /* ------------------------------------------------ */

  rc = load_mysql_configuration_from_file (argv[1], &conf_mysql_logistic, tags_logistic, my_syslog);

  if (rc)
  {
    fprintf (stderr, "[FATAL] Error while loading configuration for connection to Logistic - %s",
                     conf_mysql_logistic.last_error_str);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not load configuration for connection to Mydns - %s",
               __FILE__,
               __LINE__,
               conf_mysql_logistic.last_error_str);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Connect to local DHCP database                   */
  /* ------------------------------------------------ */

  init_mysql_structure (&conf_mysql_dhcp_read_only);

  rc = connect_to_mysql (&conf_mysql_dhcp_read_only);

  if (rc != 0)
  {
    fprintf (stderr, "[FATAL] Could not connect to local DHCP database - %s (%d)\n",
             conf_mysql_dhcp_read_only.last_error_str,
             conf_mysql_dhcp_read_only.last_error_int);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not connect to local DHCP database - %s (%d)",
               __FILE__,
               __LINE__,
               conf_mysql_dhcp_read_only.last_error_str,
               conf_mysql_dhcp_read_only.last_error_int);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Connect to POOL DHCP database                    */
  /* ------------------------------------------------ */

  init_mysql_structure (&conf_mysql_dhcp_read_write);

  rc = connect_to_mysql (&conf_mysql_dhcp_read_write);

  if (rc != 0)
  {
    fprintf (stderr, "[FATAL] Could not connect to POOL DHCP database - %s (%d)\n",
             conf_mysql_dhcp_read_write.last_error_str,
             conf_mysql_dhcp_read_write.last_error_int);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not connect to POOL DHCP database - %s (%d)",
               __FILE__,
               __LINE__,
               conf_mysql_dhcp_read_write.last_error_str,
               conf_mysql_dhcp_read_write.last_error_int);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Connect to Radonline database                    */
  /* ------------------------------------------------ */

  init_mysql_structure (&conf_mysql_radonline);

  rc = connect_to_mysql (&conf_mysql_radonline);

  if (rc != 0)
  {
    fprintf (stderr, "[FATAL] Could not connect to Radonline database - %s (%d)\n",
             conf_mysql_radonline.last_error_str,
             conf_mysql_radonline.last_error_int);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not connect to Radonline database - %s (%d)",
               __FILE__,
               __LINE__,
               conf_mysql_radonline.last_error_str,
               conf_mysql_radonline.last_error_int);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Connect to MyDns database                        */
  /* ------------------------------------------------ */

  init_mysql_structure (&conf_mysql_mydns);

  rc = connect_to_mysql (&conf_mysql_mydns);

  if (rc != 0)
  {
    fprintf (stderr, "[FATAL] Could not connect to Mydns database - %s (%d)\n",
             conf_mysql_mydns.last_error_str,
             conf_mysql_mydns.last_error_int);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not connect to Mydns database - %s (%d)",
               __FILE__,
               __LINE__,
               conf_mysql_mydns.last_error_str,
               conf_mysql_mydns.last_error_int);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Connect to Logistic database                     */
  /* ------------------------------------------------ */

  init_mysql_structure (&conf_mysql_logistic);

  rc = connect_to_mysql (&conf_mysql_logistic);

  if (rc != 0)
  {
    fprintf (stderr, "[FATAL] Could not connect to Logistic database - %s (%d)\n",
             conf_mysql_logistic.last_error_str,
             conf_mysql_logistic.last_error_int);
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not connect to Logistic database - %s (%d)",
               __FILE__,
               __LINE__,
               conf_mysql_logistic.last_error_str,
               conf_mysql_logistic.last_error_int);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Initialize all services that need logging        */
  /* service.                                         */
  /* ------------------------------------------------ */

  conversion_logging_service (configuration_globale.debug,
                              configuration_globale.log_file,
                              my_syslog);

  if (configuration_globale.debug > 0)
  { init_modem_syslog (my_syslog, configuration_globale.log_file, configuration_globale.debug); }
  else { init_modem_syslog (NULL, NULL, 0); }

  /* ------------------------------------------------ */
  /* Turn into deamon now                             */
  /* ------------------------------------------------ */

  rc = deamonizer (&pid, configuration_globale.working_dir);

  if (pid < 0)
  {
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not fork! The system may run out of resources!",
               __FILE__, __LINE__);
    return 1;
  }

  if (pid > 0)
  {
    if (configuration_globale.debug > 0)
    { my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Father: PID of my child is %d",
                 __FILE__,
                 __LINE__,
                (int)pid); }
    return 0;
  }

  if (rc == 1)
  {
    my_syslog (configuration_globale.log_file, "[FATAL] [%s:%d] Can not become a deamon (should never happen)",
               __FILE__, __LINE__);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Change user into deamon user                     */
  /* ------------------------------------------------ */

  my_syslog (configuration_globale.log_file,
             "[INFO] [%s:%d] Change group ID to %s (%d) (Make sure the server is started as 'root' user)",
             __FILE__,
             __LINE__,
             configuration_globale.deamon_group_id,
             (int)grp_id);

  if (setgid(grp_id) == -1)
  {
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not change GID to %d (%s) (Make sure the server is started as 'root' user)",
               __FILE__,
               __LINE__,
               (int)grp_id,
               configuration_globale.deamon_group_id);

    return 1;
  }

  my_syslog (configuration_globale.log_file,
             "[INFO] [%s:%d] Change user ID to %s (%d) (Make sure the server is started as 'root' user)",
             __FILE__,
             __LINE__,
             configuration_globale.deamon_user_id,
             (int)user_id);

  if (setuid(user_id) == -1)
  {
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not change UID to %d (%s) (Make sure the server is started as 'root' user)",
               __FILE__,
               __LINE__,
               (int)user_id,
               configuration_globale.deamon_user_id);

    return 1;
  }

  /* ------------------------------------------------ */
  /* Create PID file                                  */
  /* ------------------------------------------------ */

  if (access (configuration_globale.pid_file, F_OK) == 0)
  {
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] PID file <%s> already exists, abort. The server should be running. Please check.",
               __FILE__,
               __LINE__,
               configuration_globale.pid_file);
    return 1;
  }

  pid_file = fopen (configuration_globale.pid_file, "w");

  if (pid_file == NULL)
  {
    int e = errno;
    my_syslog (configuration_globale.log_file,
               "[FATAL] [%s:%d] Could not create my PID file '%s' - %s (check file permissions)",
               __FILE__, __LINE__,
               configuration_globale.pid_file, strerror(e));
    return 1;
  }

  fprintf (pid_file, "%d", getpid());

  fclose (pid_file);

  /* ------------------------------------------------ */
  /* Security                                         */
  /* ------------------------------------------------ */

  #ifdef XID_FILTERING

    my_syslog (configuration_globale.log_file,
    "[WARNING] [%s:%d] This server is compiled with XID filtering !!! Don't use it for production !!!",
    __FILE__, __LINE__);

  #endif

  /* ------------------------------------------------ */
  /* Initialize the MyDns interface                   */
  /* ------------------------------------------------ */

  if (mydns_init (&conf_mysql_mydns))
  {
    my_syslog (configuration_globale.log_file,
    "[FATAL] [%s:%d] mydns_init() - Could not get id from 'soa' where origin='user.' (What's wrong with MyDns?)",
    __FILE__, __LINE__);
    unlink (configuration_globale.pid_file);
    return 1;
  }

  /* ------------------------------------------------ */
  /* Initialize the dump service for packets          */
  /* ------------------------------------------------ */
 
  packet_init_dump_service();
  packet_logging_service (configuration_globale.debug, 
                          configuration_globale.log_file,
                          my_syslog);





  /* ------------------------------------------------ */
  /* Listen for packets                               */
  /* ------------------------------------------------ */

  while (1)
  {
    logging_new_tag();
    my_syslog_skip_line (configuration_globale.log_file);

    if (configuration_globale.debug > 1)
    {
       my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Waiting for DHCP request",
                  __FILE__, __LINE__);
    }

    /* ---------------------------------------------- */
    /* Get the packet                                 */
    /* o If READ_PACKET_FROM_FILE is defined, the the */
    /*   server reads packets from the directory      */
    /*   defined by INPUT_PACKET_DIRECTORY.           */
    /*   Packets are stored in the files packetXXX.   */
    /* o Otherwize, the server reads packets from the */
    /*   socket.                                      */
    /* ---------------------------------------------- */

    packets_clear (&packet_in);
    adress_size = sizeof (struct sockaddr);

    #ifndef READ_PACKET_FROM_FILE

      mess_size = recvfrom (
                             sck,
                             (char*)&packet_in,
                             PACKET_SIZE,
                             0,
                             (struct sockaddr*)&addr_original,
                             (size_t*)&adress_size
                           );
  
      if (mess_size == -1)
      {
        my_syslog (configuration_globale.log_file,
                   "[WARNING] [%s:%d] Recvfrom() failed - %s (continue)",
                   __FILE__, __LINE__,
                   strerror(errno));
        continue;
      }

    #else

      input_directory = opendir (INPUT_PACKET_DIRECTORY);
      if (input_directory == NULL)
      {
        my_syslog (configuration_globale.log_file, "[FATAL] [%s:%d] Could not open directory <%s>",
                   __FILE__, __LINE__, INPUT_PACKET_DIRECTORY);
        unlink (configuration_globale.pid_file);
        return 1;
      }
  
      while (1)
      {
        input_packet_from_dir = readdir (input_directory);
        if (input_packet_from_dir == NULL) { break; }
  
        memset (input_packet_file_name, 0, INPUT_PACKET_FILE_NAME_SIZE);
        snprintf (input_packet_file_name, INPUT_PACKET_FILE_NAME_SIZE, "%s/%s",
                  INPUT_PACKET_DIRECTORY, input_packet_from_dir->d_name);
  
        my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Found <%s>",
                   __FILE__, __LINE__, input_packet_file_name);
  
        if (strncmp ("packet", input_packet_from_dir->d_name, 6) == 0) { break; }
      }
  
      closedir (input_directory);
  
      if (input_packet_from_dir == NULL)
      {
        my_syslog (configuration_globale.log_file,
                   "[DEBUG] [%s:%d] No more packet found in <%s>, exit",
                   __FILE__, __LINE__, INPUT_PACKET_DIRECTORY);
        unlink (configuration_globale.pid_file);
        return 0;
      }
  
      my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Loading packet from <%s>",
                 __FILE__, __LINE__, input_packet_file_name);
  
      packet_file = open(input_packet_file_name, O_RDONLY);
  
      if (packet_file == -1)
      {
        my_syslog (configuration_globale.log_file, "[FATAL] [%s:%d] Could not open file <%s>",
                   __FILE__, __LINE__, input_packet_file_name);
        unlink (configuration_globale.pid_file);
        return 1;
      }
  
      mess_size = read (packet_file, (void*)&packet_in, PACKET_SIZE);
  
      my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Read %d bytes from <%s>",
                 __FILE__, __LINE__, mess_size, input_packet_file_name);
  
      if (mess_size == -1)
      {
        my_syslog (configuration_globale.log_file, "[FATAL] [%s:%d] Error while loading <%s>",
                   __FILE__, __LINE__, input_packet_file_name);
        unlink (configuration_globale.pid_file);
        return 1;
      }
  
      close (packet_file);
  
      my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Unlink <%s>",
                 __FILE__, __LINE__, input_packet_file_name);
  
      if (unlink (input_packet_file_name) == -1)
      {
        my_syslog (configuration_globale.log_file, "[FATAL] Can not delete file <%s>",
                   __FILE__, __LINE__, input_packet_file_name);
        unlink (configuration_globale.pid_file);
        return 1;
      }

    #endif


    if (configuration_globale.debug > 1)
    { my_syslog (configuration_globale.log_file, "[DEBUG] [%s:%d] Got a request (%d bytes)",
                 __FILE__, __LINE__, mess_size); }


    #ifdef DUMP_PACKETS

      dumpfd = open("/tmp/packets_dhcp", O_WRONLY);
      if (dumpfd == -1)
      {
        my_syslog (configuration_globale.log_file,
                   "[WARNING] [%s:%d] Could not open file '/tmp/packets_dhcp' - %s",
                   __FILE__, __LINE__, strerror(errno));
      }
      else
      {
        write(dumpfd, (void*)&packet_in, mess_size);
        my_syslog (configuration_globale.log_file,
                   "[INFO] [%s:%d] One packet dumped into '/tmp/packets_dhcp'", __FILE__, __LINE__);
        close(dumpfd);
      }

    #endif

    /* ---------------------------------------------- */
    /* Set the size of the packet                     */
    /* ---------------------------------------------- */

    packet_set_taille (&packet_in, mess_size);

    /* ---------------------------------------------- */
    /* Sanity check                                   */
    /* ---------------------------------------------- */

    if (check_packet_size(mess_size) == 0)
    {
      my_syslog (configuration_globale.log_file,
                 "[WARNING] [%s:%d] Invalid DHCP packet (only %d bytes!). Drop this packet",
                 __FILE__, __LINE__, mess_size);
      dump_packet_hexa ((void*)&packet_in, mess_size, configuration_globale.log_file);
      packets_send_dummy_nak (
                               &packet_in,
                               &mysql_tables,
                               configuration_globale.dummy_ip,
                               broadcast,
                               server_ip,
                               sck,
                               &addr_original
                             );
      continue;
    }

    /* ---------------------------------------------- */
    /* Parse the packet's options                     */
    /* ---------------------------------------------- */

    if (packets_parse_options(&packet_in) == 1)
    {
      my_syslog (configuration_globale.log_file,
                 "[WARNING] [%s:%d] Invalid DHCP packet: option's part is not well formatted. Drop this packet",
                 __FILE__, __LINE__);
      dump_packet_hexa ((void*)&packet_in, mess_size, configuration_globale.log_file);
      packets_send_dummy_nak (
                               &packet_in,
                               &mysql_tables,
                               configuration_globale.dummy_ip,
                               broadcast,
                               server_ip,
                               sck,
                               &addr_original
                             );
      continue;
    }

    /* ---------------------------------------------- */
    /* At this point, the packet's data should be OK. */
    /* Get MAC address and DSLAM's ID.                */
    /* ---------------------------------------------- */

    init_client_ids (packets_get_chaddr(&packet_in),
                     packets_get_node_id(&packet_in),
                     packets_get_shelf(&packet_in),
                     packets_get_numero_slot(&packet_in),
                     packets_get_numero_port(&packet_in),
                     packets_get_vci(&packet_in),
                     packets_get_vlan_id(&packet_in));

    /* ---------------------------------------------- */
    /* If dumper mode selected, then dump the packet  */
    /* but do not reply.                              */
    /* dumper_mode = 0 => No dump at all.             */
    /* dumper_mode = 1 => Dump all packets.           */
    /* dumper_mode = 3 => Dump only (no response)     */
    /* ---------------------------------------------- */

    if (configuration_globale.dumper_mode > 0)
    { packet_dump (&packet_in, configuration_globale.debug_file,
                   configuration_globale.csv_file, &addr_original, NULL); }

    if (configuration_globale.dumper_mode > 1)
    {
      if (configuration_globale.debug > 0)
      { my_syslog (configuration_globale.log_file,
                   "[DEBUG] [%s:%d] WARNING: Dumper mode value is 'total' - Do not reply",
                   __FILE__, __LINE__); }

      continue;
    }

    /* ---------------------------------------------- */
    /* Process TEST mode                              */
    /* ---------------------------------------------- */

    #ifdef XID_FILTERING

    if (! packet_testing (packets_get_xid(&packet_in)))
    {
      my_syslog (configuration_globale.log_file,
                 "[INFO] [%s:%d] XID_FILTERING activated, this packet is rejected",
                 __FILE__, __LINE__);
      continue;
    }

    #endif

    /* ---------------------------------------------- */
    /* If DHCP DECLINE write WARNING and process next */
    /* packet.                                        */
    /* ---------------------------------------------- */

    if (packets_get_message_type(&packet_in) == DHCPDECLINE)
    {
      my_syslog (configuration_globale.log_file,
                 "[WARNING] [%s:%d] Got DECLINE",
                 __FILE__, __LINE__);

      packets_send_dummy_nak (
                               &packet_in,
                               &mysql_tables,
                               configuration_globale.dummy_ip,
                               broadcast,
                               server_ip,
                               sck,
                               &addr_original
                             );
      continue;
    }

    /* ---------------------------------------------- */
    /* Load user's context                            */
    /* The client may not broadcasts. In this case,   */
    /* the gateway does not touch the packets. This   */
    /* means that :                                   */
    /*    o The field "giaddr" is set to "0.0.0.0".   */
    /*    o We ignore the "vlan" data.                */
    /* ---------------------------------------------- */

    clear_tables(&mysql_tables);

    strncpy (mysql_tables.abonnes.node_id, packets_get_node_id(&packet_in), NODE_BUFFER_SIZE-1);
    mysql_tables.abonnes.shelf       = packets_get_shelf(&packet_in);
    mysql_tables.abonnes.numero_port = packets_get_numero_port(&packet_in);
    mysql_tables.abonnes.numero_slot = packets_get_numero_slot(&packet_in);

    strncpy (mysql_tables.vlan.vlan_gateway, packets_get_giaddr(&packet_in), IP_ADDRESS_STR_SIZE);

    if (strcmp(mysql_tables.vlan.vlan_gateway, "0.0.0.0") != 0)
    {
      /* -------------------------------------------- */
      /* Broadcast                                    */
      /* -------------------------------------------- */

      if (configuration_globale.debug > 1)
      {
        my_syslog (configuration_globale.log_file,
                   "[DEBUG] [%s:%d] 'giaddr' not '0.0.0.0' => Should be BROADCAST from client",
                   __FILE__, __LINE__);
      }

      mysql_tables.vlan.vlan_tag = packets_get_vlan_id(&packet_in);
    }
    else
    {
      /* -------------------------------------------- */
      /* Unicast                                      */
      /* Copy the sender's address as vlan_gateway    */
      /* -------------------------------------------- */

      int    i;
      char   addresse_from[16], *a;

      memset ((void*)addresse_from, 0, 16);
      a = inet_ntoa(addr_original.sin_addr);
      for (i=0; i<15; i++) { addresse_from[i] = *(a+i); };
      addresse_from[15] = 0;

      if (configuration_globale.debug > 0)
      {
        my_syslog (configuration_globale.log_file,
                   "[DEBUG] [%s:%d] 'giaddr' is '0.0.0.0' => It should be a UNICAST client (%s)",
                   __FILE__, __LINE__, addresse_from);
      }

      mysql_tables.vlan.vlan_tag = 0;
      strncpy (mysql_tables.vlan.vlan_gateway, addresse_from, IP_ADDRESS_STR_SIZE);
    }

    /* ---------------------------------------------- */
    /* Update logger sub-system and load context      */
    /* ---------------------------------------------- */

    if (configuration_globale.debug > 1)
    {
      my_syslog (configuration_globale.log_file,
      "[DEBUG] [%s:%d] Load context for vlan_id=%lu, vlan_gateway='%s'",
      __FILE__, __LINE__,
      mysql_tables.vlan.vlan_id,
      mysql_tables.vlan.vlan_gateway);
    }

    logger_set_gateway (mysql_tables.vlan.vlan_gateway);

    rc = load_context (&conf_mysql_dhcp_read_only,
                       &conf_mysql_dhcp_read_write,
                       &mysql_tables,
                       &configuration_globale);

    switch (rc)
    {
      case MYSQL_INTERFACE_REQUEST_SKIPED:
           my_syslog (configuration_globale.log_file,
           "[WARNING] [%s:%d] Load context, request skiped",
           __FILE__, __LINE__);
           packets_send_dummy_nak (
                                     &packet_in,
                                     &mysql_tables,
                                     configuration_globale.dummy_ip,
                                     broadcast,
                                     server_ip,
                                     sck,
                                     &addr_original
                                  );
           continue;

      case MYSQL_INTERFACE_CONNECTION_LOST:
           my_syslog (configuration_globale.log_file,
           "[WARNING] [%s:%d] Load context, connection loast",
           __FILE__, __LINE__);
           packets_send_dummy_nak (
                                     &packet_in,
                                     &mysql_tables,
                                     configuration_globale.dummy_ip,
                                     broadcast,
                                     server_ip,
                                     sck,
                                     &addr_original
                                  );
           continue;

      case MYSQL_INTERFACE_RECONNECTION_FAILED:
           my_syslog (configuration_globale.log_file,
           "[WARNING] [%s:%d] Load context, could not reconnect",
           __FILE__, __LINE__);
           packets_send_dummy_nak (
                                     &packet_in,
                                     &mysql_tables,
                                     configuration_globale.dummy_ip,
                                     broadcast,
                                     server_ip,
                                     sck,
                                     &addr_original
                                  );
           continue;

      case MYSQL_INTERFACE_SQL_PROBLEM:
           my_syslog (configuration_globale.log_file,
           "[FATAL] [%s:%d] Load context, unexpected SQL error. %s (%d).",
           __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
           unlink (configuration_globale.pid_file);
           return 1;

      case MYSQL_INTERFACE_NOT_FOUND:
           my_syslog (configuration_globale.log_file,
           "[WARNING] [%s:%d] Load context, could not find vlan_id=%lu, vlan_gateway='%s' - Skip this request.",
           __FILE__, __LINE__,
           mysql_tables.vlan.vlan_id,
           mysql_tables.vlan.vlan_gateway);
           packets_send_dummy_nak (
                                     &packet_in,
                                     &mysql_tables,
                                     configuration_globale.dummy_ip,
                                     broadcast,
                                     server_ip,
                                     sck,
                                     &addr_original
                                  );
           continue;

      case MYSQL_INTERFACE_MORE_THAN_ONE:
           my_syslog (configuration_globale.log_file,
           "[WARNING] [%s:%d] Load context, more than one data for vlan_id=%lu, vlan_gateway='%s' - This should never happen because of database constraints - Abort server's execution now.",
           __FILE__, __LINE__,
           mysql_tables.vlan.vlan_id,
           mysql_tables.vlan.vlan_gateway);
           packets_send_dummy_nak (
                                     &packet_in,
                                     &mysql_tables,
                                     configuration_globale.dummy_ip,
                                     broadcast,
                                     server_ip,
                                     sck,
                                     &addr_original
                                  );
           continue;

      case MYSQL_INTERFACE_UNEXPECTED_ERROR:
           my_syslog (configuration_globale.log_file,
           "[WARNING] [%s:%d] Load context, unexpected error - Skip this request - %s (%d)",
           __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
           packets_send_dummy_nak (
                                     &packet_in,
                                     &mysql_tables,
                                     configuration_globale.dummy_ip,
                                     broadcast,
                                     server_ip,
                                     sck,
                                     &addr_original
                                  );
           continue;

      case MYSQL_INTERFACE_TOO_MANY_ITEMS:
           my_syslog (configuration_globale.log_file,
           "[FATAL] [%s:%d] Load context, too many profile's option loaded. This should never happen since the buffer is really oversized. Abort server's execution now.",
           __FILE__, __LINE__);
           unlink (configuration_globale.pid_file);
           return 1;
    }

    if (configuration_globale.debug > 0)
    {
      my_syslog (configuration_globale.log_file,
      "[DEBUG] [%s:%d] Context successfully loaded", __FILE__, __LINE__);
    }

    /* ---------------------------------------------- */
    /* Find out the modem's manufacturor... If the    */
    /* modem supports "autoconf", then look up the    */
    /* logistic database.                             */ 
    /* ---------------------------------------------- */

    modem_manufacturor = get_modem_manufacturor (&packet_in);

    if (configuration_globale.debug > 0)
    {
      my_syslog (configuration_globale.log_file,
      "[DEBUG] [%s:%d] Modem's manufacturor is %s",
      __FILE__, __LINE__, id_manufacturor_to_string(modem_manufacturor));
    }

    mysql_tables.logistic.modem_manufacturor = modem_manufacturor;

    /* ---------------------------------------------- */
    /* If the modem supports "autoconf", then lookup  */
    /* the table LOGISTIC_RADIUS.                     */
    /* If not, then make sure that the user's profile */
    /* is not "autoconfblackhole". If so, remove the  */
    /* autoconf blackhole.                            */
    /* ---------------------------------------------- */

    #ifndef USE_PLUGINS
        if (
             (modem_manufacturor == MODEM_HITACHI)
             ||
             (modem_manufacturor == MODEM_SAGEM)
           )
    #else
        if (modem_conf_is_autoconf(modem_manufacturor))
    #endif

    {
      if (configuration_globale.debug > 0)
      {
        my_syslog (configuration_globale.log_file,
        "[DEBUG] [%s:%d] This modem supports auto-configuration - search LOGISTIC_RADIUS",
        __FILE__, __LINE__);
      }

      rc = look_up_logistic (&conf_mysql_logistic,
                             &conf_mysql_dhcp_read_only,
                             &mysql_tables,
                             &configuration_globale,
                             &packet_in);

      switch (rc)
      {
        case MYSQL_INTERFACE_CONNECTION_LOST:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s:%d] look_up_logistic: connection lost", __FILE__, __LINE__);
             packets_send_dummy_nak (
                                      &packet_in,
                                      &mysql_tables,
                                      configuration_globale.dummy_ip,
                                      broadcast,
                                      server_ip,
                                      sck,
                                      &addr_original
                                   );
             continue;

        case MYSQL_INTERFACE_NOT_FOUND:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s:%d] look_up_logistic: data not found", __FILE__, __LINE__);
             packets_send_dummy_nak (
                                       &packet_in,
                                       &mysql_tables,
                                       configuration_globale.dummy_ip,
                                       broadcast,
                                       server_ip,
                                       sck,
                                       &addr_original
                                    );
             continue;

        case MYSQL_INTERFACE_RECONNECTION_FAILED:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s:%d] look_up_logistic: could not reconnect to Mysql server", __FILE__, __LINE__);
             packets_send_dummy_nak (
                                       &packet_in,
                                       &mysql_tables,
                                       configuration_globale.dummy_ip,
                                       broadcast,
                                       server_ip,
                                       sck,
                                       &addr_original
                                    );
             continue;

        case MYSQL_INTERFACE_REQUEST_SKIPED:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s:%d] look_up_logistic: skip few packets before reconnection atempt.",
             __FILE__, __LINE__);
             packets_send_dummy_nak (
                                       &packet_in,
                                       &mysql_tables,
                                       configuration_globale.dummy_ip,
                                       broadcast,
                                       server_ip,
                                       sck,
                                       &addr_original
                                    );
             continue;

        case MYSQL_INTERFACE_MORE_THAN_ONE:
             my_syslog (configuration_globale.log_file,
             "[FATAL] [%s:%d] look_up_logistic: a request returned more than one result, which should never happen.", __FILE__, __LINE__);
             unlink (configuration_globale.pid_file);
             return 1;

        case MYSQL_INTERFACE_SQL_PROBLEM:
             my_syslog (configuration_globale.log_file,
             "[FATAL] [%s:%d] look_up_logistic: SQL error, abort", __FILE__, __LINE__);
             unlink (configuration_globale.pid_file);
             return 1;

        case MYSQL_INTERFACE_UNEXPECTED_ERROR:
             my_syslog (configuration_globale.log_file,
             "[FATAL] [%s:%d] look_up_logistic: Unexpected error, abort", __FILE__, __LINE__);
             unlink (configuration_globale.pid_file);
             return 1;
      }

      if (configuration_globale.debug > 0)
      {
        my_syslog (configuration_globale.log_file,
        "[DEBUG] [%s:%d] LOGISTIC_RADIUS successfully searched", __FILE__, __LINE__);
      }

      /* -------------------------------------------- */
      /* Reload options (if blackholed)               */
      /* -------------------------------------------- */

      if (configuration_globale.debug > 0)
      {
        my_syslog (configuration_globale.log_file,
        "[DEBUG] [%s:%d] Reload (overwrite) profile's options (client may have been blackholed)",
        __FILE__, __LINE__);
      }

      rc = load_options (&conf_mysql_dhcp_read_only, &mysql_tables, &configuration_globale);
    
      if (rc != 0)
      {
        switch (rc)
        {
          case MYSQL_INTERFACE_REQUEST_SKIPED:
               my_syslog (configuration_globale.log_file,
               "[WARNING] [%s,%d] Could not reload 'options' - Request skiped",
               __FILE__, __LINE__);
               packets_send_dummy_nak (
                                         &packet_in,
                                         &mysql_tables,
                                         configuration_globale.dummy_ip,
                                         broadcast,
                                         server_ip,
                                         sck,
                                         &addr_original
                                      );
               continue;

          case MYSQL_INTERFACE_CONNECTION_LOST:
               my_syslog (configuration_globale.log_file,
               "[WARNING] [%s,%d] Could not reload 'options' - Connection lost (skip this packet)",
               __FILE__, __LINE__);
               packets_send_dummy_nak (
                                         &packet_in,
                                         &mysql_tables,
                                         configuration_globale.dummy_ip,
                                         broadcast,
                                         server_ip,
                                         sck,
                                         &addr_original
                                      );
               continue;

          case MYSQL_INTERFACE_RECONNECTION_FAILED:
               my_syslog (configuration_globale.log_file,
               "[WARNING] [%s,%d] Could not reload 'options' - Could not reconnect (skip this packet)",
               __FILE__, __LINE__);
               packets_send_dummy_nak (
                                         &packet_in,
                                         &mysql_tables,
                                         configuration_globale.dummy_ip,
                                         broadcast,
                                         server_ip,
                                         sck,
                                         &addr_original
                                      );
               continue;

          case MYSQL_INTERFACE_SQL_PROBLEM:
               my_syslog (configuration_globale.log_file,
               "[FATAL] [%s,%d] Could not reload 'options' - Some SQL problem",
               __FILE__, __LINE__);
               unlink (configuration_globale.pid_file);
               return 1;

          case MYSQL_INTERFACE_UNEXPECTED_ERROR:
               my_syslog (configuration_globale.log_file,
               "[FATAL] [%s,%d] Could not reload 'options' - Unexpected error",
               __FILE__, __LINE__);
               unlink (configuration_globale.pid_file);
               return 1;

          case MYSQL_INTERFACE_NOT_FOUND:
               my_syslog (configuration_globale.log_file,
               "[FATAL] [%s,%d] Could not reload 'options' - Data not found",
               __FILE__, __LINE__);
               unlink (configuration_globale.pid_file);
               return 1;

          case MYSQL_INTERFACE_TOO_MANY_ITEMS:
               my_syslog (configuration_globale.log_file,
               "[FATAL] [%s,%d] Could not reload 'options' - Too many options",
               __FILE__, __LINE__);
               unlink (configuration_globale.pid_file);
               return 1;
        }
      }
    }
    else
    {
      /* -------------------------------------------- */
      /* This is not an autoconf modem, make sure     */
      /* that the user's profile is not set to        */
      /* "autoconfblackhole".                         */ 
      /* -------------------------------------------- */

      rc = remove_autoconf_bh (&conf_mysql_dhcp_read_only,
                               &mysql_tables,
                               &configuration_globale);

      switch (rc)
      {
        case MYSQL_INTERFACE_REQUEST_SKIPED:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s,%d] Could not remove autoconf blackhole - Request skiped",
             __FILE__, __LINE__);
             packets_send_dummy_nak (
                                       &packet_in,
                                       &mysql_tables,
                                       configuration_globale.dummy_ip,
                                       broadcast,
                                       server_ip,
                                       sck,
                                       &addr_original
                                    );
             continue;

        case MYSQL_INTERFACE_CONNECTION_LOST:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s,%d] Could not remove autoconf blackhole - Connection lost (skip this packet)",
             __FILE__, __LINE__);
             packets_send_dummy_nak (
                                       &packet_in,
                                       &mysql_tables,
                                       configuration_globale.dummy_ip,
                                       broadcast,
                                       server_ip,
                                       sck,
                                       &addr_original
                                    );
             continue;

        case MYSQL_INTERFACE_RECONNECTION_FAILED:
             my_syslog (configuration_globale.log_file,
             "[WARNING] [%s,%d] Could not remove autoconf blackhole - Could not reconnect (skip this packet)",
             __FILE__, __LINE__);
             packets_send_dummy_nak (
                                       &packet_in,
                                       &mysql_tables,
                                       configuration_globale.dummy_ip,
                                       broadcast,
                                       server_ip,
                                       sck,
                                       &addr_original
                                    );
             continue;

        case MYSQL_INTERFACE_SQL_PROBLEM:
             my_syslog (configuration_globale.log_file,
             "[FATAL] [%s,%d] Could not remove autoconf blackhole - Some SQL problem",
             __FILE__, __LINE__);
             unlink (configuration_globale.pid_file);
             return 1;

        case MYSQL_INTERFACE_UNEXPECTED_ERROR:
             my_syslog (configuration_globale.log_file,
             "[FATAL] [%s,%d] Could not remove autoconf blackhole - Unexpected error",
             __FILE__, __LINE__);
             unlink (configuration_globale.pid_file);
             return 1;

        case MYSQL_INTERFACE_MORE_THAN_ONE:
             my_syslog (configuration_globale.log_file,
             "[FATAL] [%s,%d] Could not remove autoconf blackhole - More than one record found (impossible)",
             __FILE__, __LINE__);
             unlink (configuration_globale.pid_file);
             return 1;
      }
      
    } 

    /* ---------------------------------------------- */
    /* The context is loaded, find the IP address and */
    /* send the response to the client.               */
    /* ---------------------------------------------- */

    rc = find_ip_and_reply (&conf_mysql_dhcp_read_only,
                            &conf_mysql_dhcp_read_write,
                            &conf_mysql_radonline,
                            &conf_mysql_mydns,
                            &mysql_tables,
                            &packet_in,
                            &configuration_globale,
                            sck,
                            broadcast,
                            server_ip,
                            &addr_original);

    switch (rc)
    {
     case MYSQL_INTERFACE_REQUEST_SKIPED:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: request skiped (this is normal, skip few packet before reconnect)",
          __FILE__, __LINE__);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case MYSQL_INTERFACE_CONNECTION_LOST:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: connection lost",
          __FILE__, __LINE__);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case MYSQL_INTERFACE_RECONNECTION_FAILED:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: could not reconnect to MySql server",
          __FILE__, __LINE__);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case MYSQL_INTERFACE_SQL_PROBLEM:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: some unexpected SQL error occured. Abort server's execution now - %d (%d).",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          unlink (configuration_globale.pid_file);
          return 1;

     case MYSQL_INTERFACE_MORE_THAN_ONE:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: more than one result for SQL query. This should never happen because of database constraints. Abort server's execution now.",
          __FILE__, __LINE__);
          unlink (configuration_globale.pid_file);
          return 1;

     case MYSQL_INTERFACE_NOT_FOUND:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: a record specified by a given abonnes_id not found in the database. This should not happen (never). Did somebody delete data into the database? Abort server's execution now.",
          __FILE__, __LINE__);
          unlink (configuration_globale.pid_file);
          return 1;

     case MYSQL_INTERFACE_UNEXPECTED_ERROR:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: unexpected error. Abort server's execution now - %s (%d)",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          unlink (configuration_globale.pid_file);
          return 1;

     case MYSQL_INTERFACE_NO_TIMESTAMP:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: could not get MySql server's timestamp. %s (%d) Skip",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case MYSQL_INTERFACE_NO_LEASE_ID:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: could not find lease ID for vlan_id=%lu, vlan_gateway='%s' in database. Skip this packet",
          __FILE__, __LINE__,
          mysql_tables.vlan.vlan_id,
          mysql_tables.vlan.vlan_gateway);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case DHCP_NO_DYNAMIC_IP_FOUND:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: could not find free dynamic IP address for vlan_id=%lu, vlan_gateway='%s' in database. Skip this packet",
          __FILE__, __LINE__,
          mysql_tables.vlan.vlan_id,
          mysql_tables.vlan.vlan_gateway);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case DHCP_INVALID_MESSAGE_TYPE:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: invalid DHCP message type from vlan_id=%lu, vlan_gateway='%s' in database. Skip this packet",
          __FILE__, __LINE__,
          mysql_tables.vlan.vlan_id,
          mysql_tables.vlan.vlan_gateway);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case DHCP_LEASE_INCONSTANCY:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: internal error. Could not get lease. Abort server's execution now.",
          __FILE__, __LINE__);
          unlink (configuration_globale.pid_file);
          return 1;

     case DHCP_NO_DYNAMIC_IP_FOUND_RELEASE:
          my_syslog (configuration_globale.log_file,
          "[WARNING] [%s:%d] find_ip_and_reply: vlan_id=%lu, vlan_gateway='%s' released its IP, but I could not find it (this might happen rarely)",
          __FILE__, __LINE__,
          mysql_tables.vlan.vlan_id,
          mysql_tables.vlan.vlan_gateway);
          packets_send_dummy_nak (
                                    &packet_in,
                                    &mysql_tables,
                                    configuration_globale.dummy_ip,
                                    broadcast,
                                    server_ip,
                                    sck,
                                    &addr_original
                                 );
          continue;

     case DHCP_RADONLINE_MYSQL_SQL_PROBLEM:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: an SQL error occured while sending ticket to Radonline - %s (%d)",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          unlink (configuration_globale.pid_file);
          return 1;

     case DHCP_RADONLINE_MYSQL_UNEXPECTED_ERROR:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: unexpected SQL error occured while sending ticket to Radonline - %s (%d)",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          unlink (configuration_globale.pid_file);
          return 1;

     case DHCP_MYDNS_MYSQL_SQL_PROBLEM:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: an SQL error occured while sending ticket to MyDns - %s (%d)",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          unlink (configuration_globale.pid_file);
          return 1;

     case DHCP_MYDNS_MYSQL_UNEXPECTED_ERROR:
          my_syslog (configuration_globale.log_file,
          "[FATAL] [%s:%d] find_ip_and_reply: unexpected SQL error occured while sending ticket to MyDns - %s (%d)",
          __FILE__, __LINE__, mysql_error_str, mysql_error_errno);
          unlink (configuration_globale.pid_file);
          return 1;
    }


    if (configuration_globale.debug > 0)
    {
      my_syslog (configuration_globale.log_file,
      "[DEBUG] [%s:%d] Packet successfully processed", __FILE__, __LINE__);
    }


  }

  unlink (configuration_globale.pid_file);
  return 0;
}

















#ifdef XID_FILTERING

int packet_testing (unsigned long int xid)
{
   static char buffer[BUFFSIZE];

   memset ((void*)buffer, 0, BUFFSIZE);
   snprintf (buffer, BUFFSIZE, "%lu", xid);

   if (strlen (buffer) != 6) { return 0; }

   if (buffer[5] != buffer[2]) { return 0; }
   if (buffer[4] != buffer[1]) { return 0; }
   if (buffer[3] != buffer[0]) { return 0; }

   return 1;
}

#endif

/*! \brief Dump a packet into hexa. This function is called when it is not possible to 
           parse the packet (invalid size ot invalid organisation).
    \param packet Pointer to the packet as received by the server.
    \param size Size, in bytes of the packet.
    \param file Path to the log file.
 */

static void dump_packet_hexa (void* packet, int size, char* file)
{
   char *buffer;
   int  bsize;

   bsize  = (2*size) + 1;
   buffer = (char*) malloc (bsize * sizeof(char));

   if (buffer == NULL)
   {
     my_syslog (file, "[ERROR] [%s:%d] Could allocate memory (bin2hex_binary() failed)",
                __FILE__, __LINE__);
     return;
   }
 
   if (bin2hex_binary ((unsigned char*)packet, (unsigned char*)buffer, size, bsize) == 0)
   {
     my_syslog (file, "[ERROR] [%s:%d] Could not convert packet into hexa (bin2hex_binary() failed)",
                __FILE__, __LINE__);
     free (buffer); 
     return;
   }

   my_syslog (file, "[INFO] [%s:%d] Packet is (in hexa) [%s]", __FILE__, __LINE__, buffer);

   free (buffer);
   return;
}





/*! \mainpage Documentation for the DHCP server
 *
 *  \section code_sec Auto-generated documentation
 *
 *  To consult the auto-generated documentation, use the links at the top of the page.
 *  <ul>
 *    <li>Globals : Alphabetical list of all functions, variables and constants. This is the main index.
 *    <li>Data Fields : All data structure fields.
 *    <li>File List : All source's files.
 *    <li>Data Structures : All data structures.
 *  </ul>
 *
 */

---