root/trunk/src/get_conf.c @ 63

Revision 61, 11.5 KB (checked in by andreu, 15 years ago)

tickets 12,19 & 20 closed
  • Property svn:eol-style set to native
Line 
1/*
2 * File: get_conf.c
3 *
4 * Authors: ANDREU Francois-Xavier
5 *
6 * Copyright (C) 2005 2006 2007 GIP RENATER
7 */
8
9/*  This file is part of renetcol.
10 *
11 *  renetcol is free software; you can redistribute it and/or modify
12 *  it under the terms of the GNU General Public License as published by
13 *  the Free Software Foundation; either version 2 of the License, or
14 *  (at your option) any later version.
15 *
16 *  renetcol is distributed in the hope that it will be useful,
17 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
18 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
19 *  GNU General Public License for more details.
20 *
21 *  You should have received a copy of the GNU General Public License
22 *  along with renetcol; if not, write to the Free Software
23 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
24 */
25
26#include <stdio.h>
27#include <string.h>
28#include <stdlib.h>
29
30#include "get_conf.h"
31
32/*
33 * initConf()
34 */
35void initConf(char *routersfile)
36{ 
37  /* getRegisteredRouters(routersfile); */
38}
39
40/*
41 * longCmp()
42 */
43int
44longCmp(const void *elem1, const void *elem2){
45  return (*((unsigned long*)elem1) - *((unsigned long*)elem2));
46}
47
48/*
49 * getRegisteredRouters
50 */
51int
52getRegisteredRouters(char *filename, unsigned long *sortedRLPtr,
53                          unsigned long *indexedRLPtr)
54{
55  FILE *routerFile;
56  char line[200];
57  int cptLine;
58  int nbR = 0;
59  char tindex[5];
60  char tname[40];
61  char tad[16];
62  char tad2[16];
63  int ind=0;
64  unsigned short n0, n1, n2, n3;
65  unsigned char buffer4[4];
66
67  if (!(routerFile = fopen(filename, "r"))) {
68    fprintf (stderr, "error during file \"%s\" opening\n", filename);
69    exit(1);
70  }
71  cptLine=0;
72  while ( fgets(line, 200, routerFile) != 0) {   
73    if ( strspn(line, "#") == 0 ) {
74      if (sscanf(line, "%s %s %s %s\n",
75                 tindex,       
76                 tname,
77                 tad,
78                 tad2) == 0) {
79        fprintf(stderr, "Error in file %s, line %d\n",
80                filename, cptLine);
81        exit(1);
82      }
83      cptLine++;
84      ind = atoi(tindex);
85      if (sscanf(tad,"%hu.%hu.%hu.%hu\n",&n0,&n1,&n2,&n3) == 0){
86        fprintf(stderr, "Address error in file %s, line %d\n",
87                filename, cptLine);
88        exit(1);
89      }
90      buffer4[3] = (unsigned char)n0;
91      buffer4[2] = (unsigned char)n1;
92      buffer4[1] = (unsigned char)n2;
93      buffer4[0] = (unsigned char)n3;   
94      sortedRLPtr[ind] = *((unsigned long*)(&buffer4));
95      if (sortedRLPtr[ind] != 0){
96        nbR++;
97      }
98      indexedRLPtr[ind] = *((unsigned long*)(&buffer4));
99    }
100  }
101  qsort(sortedRLPtr, cptLine, sizeof(unsigned long), longCmp);
102  if( fclose(routerFile) != 0) {
103    return (-1);
104  } else {
105    return nbR;
106  }
107}
108
109
110/*
111 *
112 */
113int compStr(a,b)
114{
115  static unsigned short a0,a1,a2,a3,a4,a5;
116  static unsigned short b0,b1,b2,b3,b4,b5;
117  sscanf((char *)a,"%hu.%hu.%hu.%hu/%hu-%hu\n",&a0,&a1,&a2,&a3,&a4,&a5);
118  sscanf((char *)b,"%hu.%hu.%hu.%hu/%hu-%hu\n",&b0,&b1,&b2,&b3,&b4,&b5);
119  if (a0 > b0) return(1);
120  if (a0 < b0) return(-1);
121  if (a1 > b1) return(1);
122  if (a1 < b1) return(-1);
123  if (a2 > b2) return(1);
124  if (a2 < b2) return(-1);
125  if (a3 > b3) return(1);
126  if (a3 < b3) return(-1);
127  return(0);
128}
129
130/*
131 * getPrefixV4()
132 *
133 * read IPv4 prefix file and sort the list
134 */
135unsigned short getPrefixV4(char *filename,
136                           struct PrefixV4 *pV4TabPtr,
137                           struct PrefixV4 *pV4SubTabPtr,
138                           unsigned short *subnetNb)
139{
140  FILE *prefixFile;
141  char line[200];
142  unsigned short counter = 0;
143  unsigned short n0, n1, n2, n3, n4;
144#if defined(IPV4AGGIDR)
145  unsigned short n5;
146#endif
147  unsigned char buffer4[4];
148  int i = 0;
149  char prefixStrTab[MAX_IPV4_PREFIX+MAX_IPV4_SUBNET][50];
150  struct PrefixV4 lastSuperNet;
151  unsigned short lastSuperNetIndex = 0;
152  unsigned short superNetIndex = 0;
153  unsigned short subNetIndex = 0;
154
155  if (!(prefixFile = fopen(filename, "r"))) {
156    fprintf (stderr, "error during file \"%s\" opening\n", filename);
157    exit(1);
158  }
159 
160  *subnetNb = 0;
161
162  lastSuperNet.beginning = 0;
163  lastSuperNet.end = 0;
164  lastSuperNet.mask = 0;
165  lastSuperNet.sampling = 0;
166#ifdef IPV4AGGIDR     
167  lastSuperNet.routerNb = 0;
168#endif
169  lastSuperNet.flowNbIN = 0;
170  lastSuperNet.bytesNbIN = 0;
171  lastSuperNet.pktsNbIN = 0;
172  lastSuperNet.flowNbOUT = 0;
173  lastSuperNet.bytesNbOUT = 0;
174  lastSuperNet.pktsNbOUT = 0;
175  lastSuperNet.firstCoSIN = 0;
176  lastSuperNet.secondCoSIN = 0;
177  lastSuperNet.thirdCoSIN = 0;
178  lastSuperNet.fourthCoSIN = 0;
179  lastSuperNet.firstCoSOUT = 0;
180  lastSuperNet.secondCoSOUT = 0;
181  lastSuperNet.thirdCoSOUT = 0;
182  lastSuperNet.fourthCoSOUT = 0;
183
184  for(i=0;i<MAX_IPV4_PREFIX;i++){
185    pV4TabPtr[i].beginning = 0;
186    pV4TabPtr[i].end = 0;
187    pV4TabPtr[i].mask = 0;
188    pV4TabPtr[i].sampling = 0;
189#ifdef IPV4AGGIDR     
190    pV4TabPtr[i].routerNb = 0;
191#endif
192    pV4TabPtr[i].flowNbIN = 0;
193    pV4TabPtr[i].bytesNbIN = 0;
194    pV4TabPtr[i].pktsNbIN = 0;
195    pV4TabPtr[i].flowNbOUT = 0;
196    pV4TabPtr[i].bytesNbOUT = 0;
197    pV4TabPtr[i].pktsNbOUT = 0;
198    pV4TabPtr[i].firstCoSIN = 0;
199    pV4TabPtr[i].secondCoSIN = 0;
200    pV4TabPtr[i].thirdCoSIN = 0;
201    pV4TabPtr[i].fourthCoSIN = 0;
202    pV4TabPtr[i].firstCoSOUT = 0;
203    pV4TabPtr[i].secondCoSOUT = 0;
204    pV4TabPtr[i].thirdCoSOUT = 0;
205    pV4TabPtr[i].fourthCoSOUT = 0;
206  }
207  for(i=0;i<MAX_IPV4_SUBNET;i++){
208    pV4SubTabPtr[i].beginning = 0;
209    pV4SubTabPtr[i].end = 0;
210    pV4SubTabPtr[i].mask = 0;
211    pV4SubTabPtr[i].sampling = 0;
212#ifdef IPV4AGGIDR     
213    pV4SubTabPtr[i].routerNb = 0;
214#endif
215    pV4SubTabPtr[i].flowNbIN = 0;
216    pV4SubTabPtr[i].bytesNbIN = 0;
217    pV4SubTabPtr[i].pktsNbIN = 0;
218    pV4SubTabPtr[i].flowNbOUT = 0;
219    pV4SubTabPtr[i].bytesNbOUT = 0;
220    pV4SubTabPtr[i].pktsNbOUT = 0;
221    pV4SubTabPtr[i].firstCoSIN = 0;
222    pV4SubTabPtr[i].secondCoSIN = 0;
223    pV4SubTabPtr[i].thirdCoSIN = 0;
224    pV4SubTabPtr[i].fourthCoSIN = 0;
225    pV4SubTabPtr[i].firstCoSOUT = 0;
226    pV4SubTabPtr[i].secondCoSOUT = 0;
227    pV4SubTabPtr[i].thirdCoSOUT = 0;
228    pV4SubTabPtr[i].fourthCoSOUT = 0;
229  }
230  while (fgets(line, 50, prefixFile) != 0)
231    {
232      strcpy(prefixStrTab[counter], line);
233      counter++;
234      if (counter == MAX_IPV4_PREFIX+MAX_IPV4_SUBNET) {
235        fprintf(stderr, "bufferoverflow in getPrefixV4 function (get_conf.c)\
236change the value of MAX_IPV4_PREFIX  declaration and recompile \n");
237        exit(1);
238      }
239    }
240  qsort(prefixStrTab, counter, 50, compStr);
241  for(i=0;i<counter;i++)
242    {
243#if defined(IPV4AGGIDR)
244      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu/%hu-%hu\n",
245             &n0,&n1,&n2,&n3,&n4,&n5);
246#else
247      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu %hu\n",
248             &n0,&n1,&n2,&n3,&n4);
249#endif
250      buffer4[0] = (unsigned char)n3;
251      buffer4[1] = (unsigned char)n2;
252      buffer4[2] = (unsigned char)n1;
253      buffer4[3] = (unsigned char)n0;
254      /* we sort supernet and subnet */
255      if (lastSuperNet.beginning == 0) {
256        /* case of first supernet */
257        lastSuperNet.beginning = *((unsigned long*)&buffer4[0]);
258        lastSuperNet.end = *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
259        lastSuperNet.mask = n4;
260        lastSuperNetIndex = i;
261        superNetIndex++;
262        pV4TabPtr[i].beginning =
263          *((unsigned long*)&buffer4[0]);
264        pV4TabPtr[i].end =
265          *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
266        pV4TabPtr[i].mask = n4;
267        pV4TabPtr[i].sampling = 0;
268#ifdef IPV4AGGIDR     
269        pV4TabPtr[i].routerNb = n5;
270#endif
271        pV4TabPtr[i].flowNbIN = 0;
272        pV4TabPtr[i].bytesNbIN = 0;
273        pV4TabPtr[i].pktsNbIN = 0;
274        pV4TabPtr[i].flowNbOUT = 0;
275        pV4TabPtr[i].bytesNbOUT = 0;
276        pV4TabPtr[i].pktsNbOUT = 0;
277        pV4TabPtr[i].firstCoSIN = 0;
278        pV4TabPtr[i].secondCoSIN = 0;
279        pV4TabPtr[i].thirdCoSIN = 0;
280        pV4TabPtr[i].fourthCoSIN = 0;
281        pV4TabPtr[i].firstCoSOUT = 0;
282        pV4TabPtr[i].secondCoSOUT = 0;
283        pV4TabPtr[i].thirdCoSOUT = 0;
284        pV4TabPtr[i].fourthCoSOUT = 0;
285       
286      } else if ( (lastSuperNet.beginning <= *((unsigned long*)&buffer4[0]))
287                  && (lastSuperNet.end>=*((unsigned long*)&buffer4[0]) +~(~0<<(32-n4))) ) {
288        /* we are in the case of subnet */
289        *subnetNb += 1;
290        fprintf(stderr,"SUBNET %lu SUPERNET %lu %lu, subnetnb : %hu\n",
291                *((unsigned long*)&buffer4[0]),
292                pV4TabPtr[lastSuperNetIndex].beginning,
293                pV4TabPtr[lastSuperNetIndex].end,
294                *subnetNb);
295       
296        pV4TabPtr[lastSuperNetIndex].hasSubnet = 1;
297        pV4SubTabPtr[subNetIndex].beginning =
298          *((unsigned long*)&buffer4[0]);
299        pV4SubTabPtr[subNetIndex].end =
300          *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
301        pV4SubTabPtr[subNetIndex].mask = n4;
302        pV4SubTabPtr[subNetIndex].sampling = 0;
303#ifdef IPV4AGGIDR     
304        pV4SubTabPtr[subNetIndex].routerNb = n5;
305#endif
306        pV4SubTabPtr[subNetIndex].flowNbIN = 0;
307        pV4SubTabPtr[subNetIndex].bytesNbIN = 0;
308        pV4SubTabPtr[subNetIndex].pktsNbIN = 0;
309        pV4SubTabPtr[subNetIndex].flowNbOUT = 0;
310        pV4SubTabPtr[subNetIndex].bytesNbOUT = 0;
311        pV4SubTabPtr[subNetIndex].pktsNbOUT = 0;
312        pV4SubTabPtr[subNetIndex].firstCoSIN = 0;
313        pV4SubTabPtr[subNetIndex].secondCoSIN = 0;
314        pV4SubTabPtr[subNetIndex].thirdCoSIN = 0;
315        pV4SubTabPtr[subNetIndex].fourthCoSIN = 0;
316        pV4SubTabPtr[subNetIndex].firstCoSOUT = 0;
317        pV4SubTabPtr[subNetIndex].secondCoSOUT = 0;
318        pV4SubTabPtr[subNetIndex].thirdCoSOUT = 0;
319        pV4SubTabPtr[subNetIndex].fourthCoSOUT = 0;
320        subNetIndex++;
321      } else {
322        /* we are in the supernet case */
323        lastSuperNet.beginning = *((unsigned long*)&buffer4[0]);
324        lastSuperNet.end = *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
325        lastSuperNet.mask = n4;
326        lastSuperNetIndex = i;
327        pV4TabPtr[superNetIndex].beginning =
328          *((unsigned long*)&buffer4[0]);
329        pV4TabPtr[superNetIndex].end =
330          *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
331        pV4TabPtr[superNetIndex].mask = n4;
332        pV4TabPtr[superNetIndex].sampling = 0;
333#ifdef IPV4AGGIDR     
334        pV4TabPtr[superNetIndex].routerNb = n5;
335#endif
336        pV4TabPtr[superNetIndex].flowNbIN = 0;
337        pV4TabPtr[superNetIndex].bytesNbIN = 0;
338        pV4TabPtr[superNetIndex].pktsNbIN = 0;
339        pV4TabPtr[superNetIndex].flowNbOUT = 0;
340        pV4TabPtr[superNetIndex].bytesNbOUT = 0;
341        pV4TabPtr[superNetIndex].pktsNbOUT = 0;
342        pV4TabPtr[superNetIndex].firstCoSIN = 0;
343        pV4TabPtr[superNetIndex].secondCoSIN = 0;
344        pV4TabPtr[superNetIndex].thirdCoSIN = 0;
345        pV4TabPtr[superNetIndex].fourthCoSIN = 0;
346        pV4TabPtr[superNetIndex].firstCoSOUT = 0;
347        pV4TabPtr[superNetIndex].secondCoSOUT = 0;
348        pV4TabPtr[superNetIndex].thirdCoSOUT = 0;
349        pV4TabPtr[superNetIndex].fourthCoSOUT = 0;
350        superNetIndex++;
351      }
352    }
353  if( fclose(prefixFile) == 0) {
354    return (superNetIndex);
355  } else {
356    fprintf(stderr,"%s not closed, \n", filename);
357    exit(1);
358    return(superNetIndex);
359  }
360}
361
362/*
363 *
364 */
365int compASStr(a,b)
366{
367  static unsigned short a0;
368  static unsigned short b0;
369  sscanf((char *)a,"%hu\n",&a0);
370  sscanf((char *)b,"%hu\n",&b0);
371  if (a0 > b0) return(1);
372  if (a0 < b0) return(-1);
373  return(0);
374}
375
376/*
377 * getAS()
378 *
379 * read AS file and sort the list
380 */
381unsigned short getAS(char *filename, struct AS *ASTabPtr)
382{
383  FILE *asFile;
384  char line[200];
385  unsigned short counter = 0;
386  unsigned short n0;
387  unsigned short buffer;
388  int i = 0;
389  char ASStrTab[MAX_AS][7];
390
391  if (!(asFile = fopen(filename, "r"))) {
392    fprintf (stderr, "error during file \"%s\" opening\n", filename);
393    exit(1);
394  }
395  for(i=0;i<MAX_AS;i++){
396    ASTabPtr[i].as = 0;
397    ASTabPtr[i].sampling = 0;
398  }
399  while (fgets(line, 7, asFile) != 0)
400    {
401      strcpy(ASStrTab[counter], line);
402      counter++;
403      if (counter > MAX_AS) {
404        fprintf(stderr, "bufferoverflow in getAS function (get_conf.c)\
405change the value of MAX_AS declaration and recompile, counter: %hu \n",
406                        counter);
407        exit(1);
408      }
409    }
410  qsort(ASStrTab, counter, 7, compASStr);
411  for(i=0;i<counter;i++)
412    {
413      sscanf(ASStrTab[i],"%hu\n",
414             &n0);
415      buffer = (unsigned short)n0;
416      ASTabPtr[i].as = *((unsigned short*)&buffer);
417      ASTabPtr[i].sampling = 0;
418    }
419  if( fclose(asFile) == 0) {
420    return (counter);
421  } else {
422    fprintf(stderr,"%s not closed, \n", filename);
423    exit(1);
424    return(counter);
425  }
426}
Note: See TracBrowser for help on using the browser.