root/trunk/src/get_conf.c @ 59

/*
 * File: get_conf.c
 * 
 * Authors: ANDREU Francois-Xavier 
 *
 * Copyright (C) 2005 2006 2007 GIP RENATER 
 */

/*  This file is part of renetcol. 
 *
 *  renetcol 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.
 *
 *  renetcol is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with renetcol; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */

#include <stdio.h>
#include <string.h>
#include <stdlib.h>

#include "get_conf.h"

/*
 * initConf()
 */
void initConf(char *routersfile)
{  
  /* getRegisteredRouters(routersfile); */
}

/*
 * longCmp()
 */
int
longCmp(const void *elem1, const void *elem2){
  return (*((unsigned long*)elem1) - *((unsigned long*)elem2));
}

/*
 * getRegisteredRouters
 */
int
getRegisteredRouters(char *filename, unsigned long *sortedRLPtr,
                          unsigned long *indexedRLPtr)
{
  FILE *routerFile;
  char line[200];
  int cptLine;
  int nbR = 0;
  char tindex[5];
  char tname[40];
  char tad[16];
  char tad2[16];
  int ind=0;
  unsigned short n0, n1, n2, n3;
  unsigned char buffer4[4];

  if (!(routerFile = fopen(filename, "r"))) {
    fprintf (stderr, "error during %s opening\n", filename);
    exit(1);
  }
  cptLine=0;
  while ( fgets(line, 200, routerFile) != 0) {    
    if ( strspn(line, "#") == 0 ) {
      if (sscanf(line, "%s %s %s %s\n",
                 tindex,        
                 tname,
                 tad, 
                 tad2) == 0) {
        fprintf(stderr, "Error in file %s, line %d\n", 
                filename, cptLine);
        exit(1);
      }
      cptLine++;
      ind = atoi(tindex);
      if (sscanf(tad,"%hu.%hu.%hu.%hu\n",&n0,&n1,&n2,&n3) == 0){
        fprintf(stderr, "Address error in file %s, line %d\n", 
                filename, cptLine);
        exit(1);
      }
      buffer4[3] = (unsigned char)n0;
      buffer4[2] = (unsigned char)n1;
      buffer4[1] = (unsigned char)n2;
      buffer4[0] = (unsigned char)n3;   
      sortedRLPtr[ind] = *((unsigned long*)(&buffer4));
      if (sortedRLPtr[ind] != 0){
        nbR++;
      }
      indexedRLPtr[ind] = *((unsigned long*)(&buffer4));
    }
  }
  qsort(sortedRLPtr, cptLine, sizeof(unsigned long), longCmp);
  if( fclose(routerFile) != 0) {
    return (-1);
  } else {
    return nbR;
  }
}


/* 
 * 
 */
int compStr(a,b)
{
  static unsigned short a0,a1,a2,a3,a4,a5;
  static unsigned short b0,b1,b2,b3,b4,b5;
  sscanf((char *)a,"%hu.%hu.%hu.%hu/%hu-%hu\n",&a0,&a1,&a2,&a3,&a4,&a5);
  sscanf((char *)b,"%hu.%hu.%hu.%hu/%hu-%hu\n",&b0,&b1,&b2,&b3,&b4,&b5);
  if (a0 > b0) return(1);
  if (a0 < b0) return(-1);
  if (a1 > b1) return(1);
  if (a1 < b1) return(-1);
  if (a2 > b2) return(1);
  if (a2 < b2) return(-1);
  if (a3 > b3) return(1);
  if (a3 < b3) return(-1);
  return(0);
}

/* 
 * getPrefixV4()
 *
 * read IPv4 prefix file and sort the list
 */
unsigned short getPrefixV4(char *filename, struct PrefixV4 *pV4TabPtr)
{
  FILE *prefixFile;
  char line[200];
  unsigned short counter = 0;
  unsigned short n0, n1, n2, n3, n4;
#if defined(IPV4AGGIDR)
  unsigned short n5;
#endif
  unsigned char buffer4[4];
  int i = 0;
  char prefixStrTab[MAX_IPV4_PREFIX][50];

  if (!(prefixFile = fopen(filename, "r"))) {
    fprintf (stderr, "error during %s opening\n", filename);
    exit(1);
  }
  for(i=0;i<MAX_IPV4_PREFIX;i++){
    pV4TabPtr[i].beginning = 0;
    pV4TabPtr[i].end = 0;
    pV4TabPtr[i].mask = 0;
    pV4TabPtr[i].sampling = 0;
#ifdef IPV4AGGIDR      
    pV4TabPtr[i].routerNb = 0;
#endif
    pV4TabPtr[i].flowNbIN = 0;
    pV4TabPtr[i].bytesNbIN = 0;
    pV4TabPtr[i].pktsNbIN = 0;
    pV4TabPtr[i].flowNbOUT = 0;
    pV4TabPtr[i].bytesNbOUT = 0;
    pV4TabPtr[i].pktsNbOUT = 0;
    pV4TabPtr[i].firstCoSIN = 0;
    pV4TabPtr[i].secondCoSIN = 0;
    pV4TabPtr[i].thirdCoSIN = 0;
    pV4TabPtr[i].fourthCoSIN = 0;
    pV4TabPtr[i].firstCoSOUT = 0;
    pV4TabPtr[i].secondCoSOUT = 0;
    pV4TabPtr[i].thirdCoSOUT = 0;
    pV4TabPtr[i].fourthCoSOUT = 0;
  }
  while (fgets(line, 50, prefixFile) != 0)
    {
      strcpy(prefixStrTab[counter], line);
      counter++;
      if (counter == MAX_IPV4_PREFIX) {
        fprintf(stderr, "bufferoverflow in getPrefixV4 function (get_conf.c)\
change the value of MAX_IPV4_PREFIX  declaration and recompile \n");
        exit(1);
      }
    }
  qsort(prefixStrTab, counter, 50, compStr);
  for(i=0;i<counter;i++)
    {
#if defined(IPV4AGGIDR)
      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu/%hu-%hu\n",
             &n0,&n1,&n2,&n3,&n4,&n5);
#else
      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu %hu\n",
             &n0,&n1,&n2,&n3,&n4);
#endif
      buffer4[0] = (unsigned char)n3;
      buffer4[1] = (unsigned char)n2;
      buffer4[2] = (unsigned char)n1;
      buffer4[3] = (unsigned char)n0;
      pV4TabPtr[i].beginning = 
        *((unsigned long*)&buffer4[0]);
      pV4TabPtr[i].end = 
        *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
      pV4TabPtr[i].mask = n4;
      pV4TabPtr[i].sampling = 0;
#ifdef IPV4AGGIDR      
      pV4TabPtr[i].routerNb = n5;
#endif
      pV4TabPtr[i].flowNbIN = 0;
      pV4TabPtr[i].bytesNbIN = 0;
      pV4TabPtr[i].pktsNbIN = 0;
      pV4TabPtr[i].flowNbOUT = 0;
      pV4TabPtr[i].bytesNbOUT = 0;
      pV4TabPtr[i].pktsNbOUT = 0;
      pV4TabPtr[i].firstCoSIN = 0;
      pV4TabPtr[i].secondCoSIN = 0;
      pV4TabPtr[i].thirdCoSIN = 0;
      pV4TabPtr[i].fourthCoSIN = 0;
      pV4TabPtr[i].firstCoSOUT = 0;
      pV4TabPtr[i].secondCoSOUT = 0;
      pV4TabPtr[i].thirdCoSOUT = 0;
      pV4TabPtr[i].fourthCoSOUT = 0;
    }
  if( fclose(prefixFile) == 0) {
    return (counter);
  } else {
    fprintf(stderr,"%s not closed, \n", filename);
    exit(1);
    return(counter);
  }
}