root/trunk/src/get_conf.c @ 118

Revision 95, 21.1 KB (checked in by andreu, 14 years ago)

IPv6 link aggregation mode (first step : identify flows)
  • 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#include <arpa/inet.h>
30
31#include "get_conf.h"
32
33/*
34 * initConf()
35 */
36void initConf(char *routersfile)
37{ 
38  /* getRegisteredRouters(routersfile); */
39}
40
41/*
42 * longCmp()
43 */
44int
45longCmp(const void *elem1, const void *elem2){
46  return (*((unsigned long*)elem1) - *((unsigned long*)elem2));
47}
48
49/*
50 * getRegisteredRouters
51 */
52int
53getRegisteredRouters(char *filename, unsigned long *sortedRLPtr,
54                          unsigned long *indexedRLPtr)
55{
56  FILE *routerFile;
57  char line[200];
58  int cptLine;
59  int nbR = 0;
60  char tindex[5];
61  char tname[40];
62  char tad[16];
63  char tad2[16];
64  int ind=0;
65  unsigned short n0, n1, n2, n3;
66  unsigned char buffer4[4];
67
68  if (!(routerFile = fopen(filename, "r"))) {
69    fprintf (stderr, "error during file \"%s\" opening\n", filename);
70    exit(1);
71  }
72  cptLine=0;
73  while ( fgets(line, 200, routerFile) != 0) {   
74    if ( strspn(line, "#") == 0 ) {
75      if (sscanf(line, "%s %s %s %s\n",
76                 tindex,       
77                 tname,
78                 tad,
79                 tad2) == 0) {
80        fprintf(stderr, "Error in file %s, line %d\n",
81                filename, cptLine);
82        exit(1);
83      }
84      cptLine++;
85      ind = atoi(tindex);
86      if (sscanf(tad,"%hu.%hu.%hu.%hu\n",&n0,&n1,&n2,&n3) == 0){
87        fprintf(stderr, "Address error in file %s, line %d\n",
88                filename, cptLine);
89        exit(1);
90      }
91      buffer4[3] = (unsigned char)n0;
92      buffer4[2] = (unsigned char)n1;
93      buffer4[1] = (unsigned char)n2;
94      buffer4[0] = (unsigned char)n3;   
95      sortedRLPtr[ind] = *((unsigned long*)(&buffer4));
96      if (sortedRLPtr[ind] != 0){
97        nbR++;
98      }
99      indexedRLPtr[ind] = *((unsigned long*)(&buffer4));
100    }
101  }
102  qsort(sortedRLPtr, cptLine, sizeof(unsigned long), longCmp);
103  if( fclose(routerFile) != 0) {
104    return (-1);
105  } else {
106    return nbR;
107  }
108}
109
110
111/*
112 *
113 */
114int compStr(a,b)
115{
116  static unsigned short a0,a1,a2,a3,a4,a5;
117  static unsigned short b0,b1,b2,b3,b4,b5;
118  sscanf((char *)a,"%hu.%hu.%hu.%hu/%hu-%hu\n",&a0,&a1,&a2,&a3,&a4,&a5);
119  sscanf((char *)b,"%hu.%hu.%hu.%hu/%hu-%hu\n",&b0,&b1,&b2,&b3,&b4,&b5);
120  if (a0 > b0) return(1);
121  if (a0 < b0) return(-1);
122  if (a1 > b1) return(1);
123  if (a1 < b1) return(-1);
124  if (a2 > b2) return(1);
125  if (a2 < b2) return(-1);
126  if (a3 > b3) return(1);
127  if (a3 < b3) return(-1);
128  return(0);
129}
130
131/*
132 * getPrefixV4()
133 *
134 * read IPv4 prefix file and sort the list
135 */
136unsigned short getPrefixV4(char *filename,
137                           struct PrefixV4 *pV4TabPtr,
138                           struct PrefixV4 *pV4SubTabPtr,
139                           unsigned short *subnetNb)
140{
141  FILE *prefixFile;
142  char line[200];
143  unsigned short counter = 0;
144  unsigned short n0, n1, n2, n3, n4;
145#if defined(MULTISAMPLING)
146  unsigned short n6;
147#endif
148#if defined(IPV4AGGIDR)
149  unsigned short n5;
150#endif
151  unsigned char buffer4[4];
152  int i = 0;
153  char prefixStrTab[MAX_IPV4_PREFIX+MAX_IPV4_SUBNET][50];
154  struct PrefixV4 lastSuperNet;
155  unsigned short lastSuperNetIndex = 0;
156  unsigned short superNetIndex = 0;
157  unsigned short subNetIndex = 0;
158
159  if (!(prefixFile = fopen(filename, "r"))) {
160    fprintf (stderr, "error during file \"%s\" opening\n", filename);
161    exit(1);
162  }
163 
164  *subnetNb = 0;
165
166  lastSuperNet.beginning = 0;
167  lastSuperNet.end = 0;
168  lastSuperNet.mask = 0;
169  lastSuperNet.sampling = 0;
170#ifdef IPV4AGGIDR     
171  lastSuperNet.routerNb = 0;
172#endif
173  lastSuperNet.flowNbIN = 0;
174  lastSuperNet.bytesNbIN = 0;
175  lastSuperNet.pktsNbIN = 0;
176  lastSuperNet.flowNbOUT = 0;
177  lastSuperNet.bytesNbOUT = 0;
178  lastSuperNet.pktsNbOUT = 0;
179  lastSuperNet.firstCoSIN = 0;
180  lastSuperNet.secondCoSIN = 0;
181  lastSuperNet.thirdCoSIN = 0;
182  lastSuperNet.fourthCoSIN = 0;
183  lastSuperNet.firstCoSOUT = 0;
184  lastSuperNet.secondCoSOUT = 0;
185  lastSuperNet.thirdCoSOUT = 0;
186  lastSuperNet.fourthCoSOUT = 0;
187
188  for(i=0;i<MAX_IPV4_PREFIX;i++){
189    pV4TabPtr[i].beginning = 0;
190    pV4TabPtr[i].end = 0;
191    pV4TabPtr[i].mask = 0;
192    pV4TabPtr[i].sampling = 0;
193#ifdef IPV4AGGIDR     
194    pV4TabPtr[i].routerNb = 0;
195#endif
196    pV4TabPtr[i].flowNbIN = 0;
197    pV4TabPtr[i].bytesNbIN = 0;
198    pV4TabPtr[i].pktsNbIN = 0;
199    pV4TabPtr[i].flowNbOUT = 0;
200    pV4TabPtr[i].bytesNbOUT = 0;
201    pV4TabPtr[i].pktsNbOUT = 0;
202    pV4TabPtr[i].firstCoSIN = 0;
203    pV4TabPtr[i].secondCoSIN = 0;
204    pV4TabPtr[i].thirdCoSIN = 0;
205    pV4TabPtr[i].fourthCoSIN = 0;
206    pV4TabPtr[i].firstCoSOUT = 0;
207    pV4TabPtr[i].secondCoSOUT = 0;
208    pV4TabPtr[i].thirdCoSOUT = 0;
209    pV4TabPtr[i].fourthCoSOUT = 0;
210  }
211  for(i=0;i<MAX_IPV4_SUBNET;i++){
212    pV4SubTabPtr[i].beginning = 0;
213    pV4SubTabPtr[i].end = 0;
214    pV4SubTabPtr[i].mask = 0;
215    pV4SubTabPtr[i].sampling = 0;
216#ifdef IPV4AGGIDR     
217    pV4SubTabPtr[i].routerNb = 0;
218#endif
219    pV4SubTabPtr[i].flowNbIN = 0;
220    pV4SubTabPtr[i].bytesNbIN = 0;
221    pV4SubTabPtr[i].pktsNbIN = 0;
222    pV4SubTabPtr[i].flowNbOUT = 0;
223    pV4SubTabPtr[i].bytesNbOUT = 0;
224    pV4SubTabPtr[i].pktsNbOUT = 0;
225    pV4SubTabPtr[i].firstCoSIN = 0;
226    pV4SubTabPtr[i].secondCoSIN = 0;
227    pV4SubTabPtr[i].thirdCoSIN = 0;
228    pV4SubTabPtr[i].fourthCoSIN = 0;
229    pV4SubTabPtr[i].firstCoSOUT = 0;
230    pV4SubTabPtr[i].secondCoSOUT = 0;
231    pV4SubTabPtr[i].thirdCoSOUT = 0;
232    pV4SubTabPtr[i].fourthCoSOUT = 0;
233  }
234  while (fgets(line, 50, prefixFile) != 0)
235    {
236      strcpy(prefixStrTab[counter], line);
237      counter++;
238      if (counter == MAX_IPV4_PREFIX+MAX_IPV4_SUBNET) {
239        fprintf(stderr, "bufferoverflow in getPrefixV4 function (get_conf.c)\
240change the value of MAX_IPV4_PREFIX  declaration and recompile \n");
241        exit(1);
242      }
243    }
244  qsort(prefixStrTab, counter, 50, compStr);
245#ifdef DEBUG
246  for(i=0;i<counter;i++) {
247    fprintf(stderr,"i : %hu - line : %s\n", i,prefixStrTab[i]);
248  }
249#endif
250  for(i=0;i<counter;i++)
251    {
252#if defined(IPV4AGGIDR)
253      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu/%hu-%hu\n",
254             &n0,&n1,&n2,&n3,&n4,&n5);
255#endif
256#if defined(IPV4AGGIDSNMP)
257#if defined(MULTISAMPLING)
258      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu %hu %hu\n",
259             &n0,&n1,&n2,&n3,&n4,&n6);
260#else
261      sscanf(prefixStrTab[i],"%hu.%hu.%hu.%hu %hu\n",
262             &n0,&n1,&n2,&n3,&n4);
263#endif
264#endif
265      buffer4[0] = (unsigned char)n3;
266      buffer4[1] = (unsigned char)n2;
267      buffer4[2] = (unsigned char)n1;
268      buffer4[3] = (unsigned char)n0;
269      /* we sort supernet and subnet */
270      if (lastSuperNet.beginning == 0) {
271        /* case of first supernet */
272        lastSuperNet.beginning = *((unsigned long*)&buffer4[0]);
273        lastSuperNet.end = *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
274#ifdef DEBUG
275        fprintf(stderr,"First SUPERNET : %lu.%lu.%lu.%lu",
276                (lastSuperNet.beginning>>24),
277                (lastSuperNet.beginning<<8>>24),
278                (lastSuperNet.beginning<<16>>24),
279                (lastSuperNet.beginning<<24>>24));
280#endif
281        lastSuperNet.mask = n4;
282        lastSuperNetIndex = i;
283        superNetIndex++;
284        pV4TabPtr[i].beginning =
285          *((unsigned long*)&buffer4[0]);
286        pV4TabPtr[i].end =
287          *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
288        pV4TabPtr[i].mask = n4;
289#if defined(MULTISAMPLING)
290        pV4TabPtr[i].sampling = n6;
291#else
292        pV4TabPtr[i].sampling = 0;
293#endif
294#ifdef IPV4AGGIDR     
295        pV4TabPtr[i].routerNb = n5;
296#endif
297        pV4TabPtr[i].flowNbIN = 0;
298        pV4TabPtr[i].bytesNbIN = 0;
299        pV4TabPtr[i].pktsNbIN = 0;
300        pV4TabPtr[i].flowNbOUT = 0;
301        pV4TabPtr[i].bytesNbOUT = 0;
302        pV4TabPtr[i].pktsNbOUT = 0;
303        pV4TabPtr[i].firstCoSIN = 0;
304        pV4TabPtr[i].secondCoSIN = 0;
305        pV4TabPtr[i].thirdCoSIN = 0;
306        pV4TabPtr[i].fourthCoSIN = 0;
307        pV4TabPtr[i].firstCoSOUT = 0;
308        pV4TabPtr[i].secondCoSOUT = 0;
309        pV4TabPtr[i].thirdCoSOUT = 0;
310        pV4TabPtr[i].fourthCoSOUT = 0; 
311      } else if ( (lastSuperNet.beginning <= *((unsigned long*)&buffer4[0]))
312                  && (lastSuperNet.end>=*((unsigned long*)&buffer4[0]) +~(~0<<(32-n4))) ) {
313        /* we are in the case of subnet */
314        *subnetNb += 1;
315#ifdef DEBUG
316        fprintf(stderr,"SUBNET %lu.%lu.%lu.%lu FROM SUPERNET %lu.%lu.%lu.%lu %lu.%lu.%lu.%lu , subnetnb : %hu\n",
317                (*((unsigned long*)&buffer4[0])>>24),
318                (*((unsigned long*)&buffer4[0])<<8>>24),
319                (*((unsigned long*)&buffer4[0])<<16>>24),
320                (*((unsigned long*)&buffer4[0])<<24>>24),
321                (pV4TabPtr[lastSuperNetIndex].beginning)>>24,
322                (pV4TabPtr[lastSuperNetIndex].beginning)<<8>>24,
323                (pV4TabPtr[lastSuperNetIndex].beginning)<<16>>24,
324                (pV4TabPtr[lastSuperNetIndex].beginning)<<24>>24,
325                (pV4TabPtr[lastSuperNetIndex].end)>>24,
326                (pV4TabPtr[lastSuperNetIndex].end)<<8>>24,
327                (pV4TabPtr[lastSuperNetIndex].end)<<16>>24,
328                (pV4TabPtr[lastSuperNetIndex].end)<<24>>24,
329                *subnetNb);
330#endif
331        pV4TabPtr[lastSuperNetIndex].hasSubnet = 1;
332        pV4SubTabPtr[subNetIndex].beginning =
333          *((unsigned long*)&buffer4[0]);
334        pV4SubTabPtr[subNetIndex].end =
335          *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
336        pV4SubTabPtr[subNetIndex].mask = n4;
337#if defined(MULTISAMPLING)
338        pV4SubTabPtr[subNetIndex].sampling = n6;
339#else
340        pV4SubTabPtr[subNetIndex].sampling = 0;
341#endif
342#ifdef IPV4AGGIDR     
343        pV4SubTabPtr[subNetIndex].routerNb = n5;
344#endif
345        pV4SubTabPtr[subNetIndex].flowNbIN = 0;
346        pV4SubTabPtr[subNetIndex].bytesNbIN = 0;
347        pV4SubTabPtr[subNetIndex].pktsNbIN = 0;
348        pV4SubTabPtr[subNetIndex].flowNbOUT = 0;
349        pV4SubTabPtr[subNetIndex].bytesNbOUT = 0;
350        pV4SubTabPtr[subNetIndex].pktsNbOUT = 0;
351        pV4SubTabPtr[subNetIndex].firstCoSIN = 0;
352        pV4SubTabPtr[subNetIndex].secondCoSIN = 0;
353        pV4SubTabPtr[subNetIndex].thirdCoSIN = 0;
354        pV4SubTabPtr[subNetIndex].fourthCoSIN = 0;
355        pV4SubTabPtr[subNetIndex].firstCoSOUT = 0;
356        pV4SubTabPtr[subNetIndex].secondCoSOUT = 0;
357        pV4SubTabPtr[subNetIndex].thirdCoSOUT = 0;
358        pV4SubTabPtr[subNetIndex].fourthCoSOUT = 0;
359        subNetIndex++;
360      } else {
361        /* we are in the supernet case */
362        lastSuperNet.beginning = *((unsigned long*)&buffer4[0]);
363        lastSuperNet.end = *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
364#ifdef DEBUG
365        fprintf(stderr,"SUPERNET %lu.%lu.%lu.%lu \n",
366                (*((unsigned long*)&buffer4[0])>>24),
367                (*((unsigned long*)&buffer4[0])<<8>>24),
368                (*((unsigned long*)&buffer4[0])<<16>>24),
369                (*((unsigned long*)&buffer4[0])<<24>>24));
370#endif
371        lastSuperNet.mask = n4;
372        lastSuperNetIndex = superNetIndex;
373        pV4TabPtr[superNetIndex].beginning =
374          *((unsigned long*)&buffer4[0]);
375        pV4TabPtr[superNetIndex].end =
376          *((unsigned long*)&buffer4[0]) +~(~0<<(32-n4));
377        pV4TabPtr[superNetIndex].mask = n4;
378#if defined(MULTISAMPLING)
379        pV4TabPtr[superNetIndex].sampling = n6;
380#else
381        pV4TabPtr[superNetIndex].sampling = 0;
382#endif
383#ifdef IPV4AGGIDR     
384        pV4TabPtr[superNetIndex].routerNb = n5;
385#endif
386        pV4TabPtr[superNetIndex].flowNbIN = 0;
387        pV4TabPtr[superNetIndex].bytesNbIN = 0;
388        pV4TabPtr[superNetIndex].pktsNbIN = 0;
389        pV4TabPtr[superNetIndex].flowNbOUT = 0;
390        pV4TabPtr[superNetIndex].bytesNbOUT = 0;
391        pV4TabPtr[superNetIndex].pktsNbOUT = 0;
392        pV4TabPtr[superNetIndex].firstCoSIN = 0;
393        pV4TabPtr[superNetIndex].secondCoSIN = 0;
394        pV4TabPtr[superNetIndex].thirdCoSIN = 0;
395        pV4TabPtr[superNetIndex].fourthCoSIN = 0;
396        pV4TabPtr[superNetIndex].firstCoSOUT = 0;
397        pV4TabPtr[superNetIndex].secondCoSOUT = 0;
398        pV4TabPtr[superNetIndex].thirdCoSOUT = 0;
399        pV4TabPtr[superNetIndex].fourthCoSOUT = 0;
400        superNetIndex++;
401      }
402    }
403  if( fclose(prefixFile) == 0) {
404    return (superNetIndex);
405  } else {
406    fprintf(stderr,"%s not closed, \n", filename);
407    exit(1);
408    return(superNetIndex);
409  }
410}
411
412/*
413 *
414 */
415int compASStr(a,b)
416{
417  static unsigned short a0;
418  static unsigned short b0;
419  sscanf((char *)a,"%hu\n",&a0);
420  sscanf((char *)b,"%hu\n",&b0);
421  if (a0 > b0) return(1);
422  if (a0 < b0) return(-1);
423  return(0);
424}
425
426/*
427 * getAS()
428 *
429 * read AS file and sort the list
430 */
431unsigned short getAS(char *filename, struct AS *ASTabPtr)
432{
433  FILE *asFile;
434  char line[200];
435  unsigned short counter = 0;
436  unsigned short n0;
437#if defined(MULTISAMPLING)
438  unsigned short n1;
439#endif
440  unsigned short buffer;
441  int i = 0;
442  char ASStrTab[MAX_AS][256];
443
444  if (!(asFile = fopen(filename, "r"))) {
445    fprintf (stderr, "error during file \"%s\" opening\n", filename);
446    exit(1);
447  }
448  for(i=0;i<MAX_AS;i++){
449    ASTabPtr[i].as = 0;
450    ASTabPtr[i].sampling = 0;
451  }
452  while (fgets(line, 256, asFile) != 0)
453    {
454      strcpy(ASStrTab[counter], line);
455      counter++;
456      if (counter > MAX_AS) {
457        fprintf(stderr, "bufferoverflow in getAS function (get_conf.c)\
458change the value of MAX_AS declaration and recompile, counter: %hu \n",
459                        counter);
460        exit(1);
461      }
462    }
463  qsort(ASStrTab, counter, 256, compASStr);
464  for(i=0;i<counter;i++)
465    {
466#if defined(MULTISAMPLING)
467      sscanf(ASStrTab[i],"%hu %hu\n",
468             &n0,
469             &n1);
470      buffer = (unsigned short)n0;
471      ASTabPtr[i].as = *((unsigned short*)&buffer);
472      buffer = (unsigned short)n1;
473      ASTabPtr[i].sampling = *((unsigned short*)&buffer);
474#else
475      sscanf(ASStrTab[i],"%hu\n",
476             &n0);
477      buffer = (unsigned short)n0;
478      ASTabPtr[i].as = *((unsigned short*)&buffer);
479      ASTabPtr[i].sampling = 0;
480#endif
481    }
482  if( fclose(asFile) == 0) {
483    return (counter);
484  } else {
485    fprintf(stderr,"%s not closed, \n", filename);
486    exit(1);
487    return(counter);
488  }
489}
490
491/*
492 * prefixV6Cmp
493 */
494int
495prefixV6Cmp(const void *elem1, const void *elem2){
496  struct PrefixV6 *el1 = (struct PrefixV6 *) elem1;
497  struct PrefixV6 *el2 = (struct PrefixV6 *) elem2;
498
499  if (ntohl(el1->start[0]) < ntohl(el2->start[0])) {
500    return (-1);
501  } else if (ntohl(el1->start[0]) > ntohl(el2->start[0])) {
502    return (1);
503  } else {
504    if (ntohl(el1->start[1]) < ntohl(el2->start[1])) {
505      return (-1);
506    } else if (ntohl(el1->start[1]) > ntohl(el2->start[1])) {
507      return (1);
508    } else {
509      if (ntohl(el1->start[2]) < ntohl(el2->start[2])) {
510        return (-1);
511      } else if (ntohl(el1->start[2]) > ntohl(el2->start[2])) {
512        return (1);
513      } else {
514        if (ntohl(el1->start[3]) < ntohl(el2->start[3])) {
515          return (-1);
516        } else if (ntohl(el1->start[3]) > ntohl(el2->start[3])) {
517          return (1);
518        } else {
519          if (ntohl(el1->start[4]) < ntohl(el2->start[4])) {
520            return (-1);
521          } else if (ntohl(el1->start[4]) > ntohl(el2->start[4])) {
522            return (1);
523          } else {
524            if (ntohl(el1->start[5]) < ntohl(el2->start[5])) {
525             return (-1);
526            } else if (ntohl(el1->start[5]) > ntohl(el2->start[5])) {
527              return (1);
528            } else {
529              if (ntohl(el1->start[6]) < ntohl(el2->start[6])) {
530               return (-1);
531              } else if (ntohl(el1->start[6]) > ntohl(el2->start[6])) {
532                return (1);
533              } else {
534                if (ntohl(el1->start[7]) < ntohl(el2->start[7])) {
535                 return (-1);
536                } else if (ntohl(el1->start[7]) > ntohl(el2->start[7])) {
537                  return (1);
538                } else {
539                  return 0;
540                } /* 7 */
541              } /* 6 */
542            } /* 5 */
543          } /* 4 */
544        } /* 3 */
545      } /* 2 */
546    } /* 1 */
547  } /* 0 */
548}
549
550/*
551 * getPrefixV6()
552 *
553 * read IPv6 prefix file and sort the list
554 */
555unsigned short getPrefixV6(char *filename,
556                           struct PrefixV6 *pV6TabPtr)
557{
558  FILE *prefixFile;
559  char line[200];
560  unsigned short counter = 0;
561  char s0[40];
562  unsigned short n0;
563#if defined(MULTISAMPLING)
564  unsigned short n1;
565#endif
566  struct in6_addr in6addr;
567  struct in6_addr in6addr16;
568  int i = 0;
569  char prefixStrTab[MAX_IPV6_PREFIX][50];
570  unsigned short prefixIndex = 0;
571  int res = 0;
572
573  if (!(prefixFile = fopen(filename, "r"))) {
574    fprintf (stderr, "error during file \"%s\" opening\n", filename);
575    exit(1);
576  }
577
578  for(i=0;i<MAX_IPV6_PREFIX;i++){
579    pV6TabPtr[i].start[0] = 0;
580    pV6TabPtr[i].start[1] = 0;
581    pV6TabPtr[i].start[2] = 0;
582    pV6TabPtr[i].start[3] = 0;
583    pV6TabPtr[i].end[0] = 0;
584    pV6TabPtr[i].end[1] = 0;
585    pV6TabPtr[i].end[2] = 0;
586    pV6TabPtr[i].end[3] = 0;
587    pV6TabPtr[i].mask = 0;
588    pV6TabPtr[i].hasSubnet = 0;
589    pV6TabPtr[i].sampling = 0;
590    pV6TabPtr[i].flowNbIN = 0;
591    pV6TabPtr[i].bytesNbIN = 0;
592    pV6TabPtr[i].pktsNbIN = 0;
593    pV6TabPtr[i].flowNbOUT = 0;
594    pV6TabPtr[i].bytesNbOUT = 0;
595    pV6TabPtr[i].pktsNbOUT = 0;
596    pV6TabPtr[i].firstCoSIN = 0;
597    pV6TabPtr[i].secondCoSIN = 0;
598    pV6TabPtr[i].thirdCoSIN = 0;
599    pV6TabPtr[i].fourthCoSIN = 0;
600    pV6TabPtr[i].firstCoSOUT = 0;
601    pV6TabPtr[i].secondCoSOUT = 0;
602    pV6TabPtr[i].thirdCoSOUT = 0;
603    pV6TabPtr[i].fourthCoSOUT = 0;
604  }
605
606  while (fgets(line, 50, prefixFile) != 0)
607    {
608      strcpy(prefixStrTab[counter], line);
609      counter++;
610      if (counter == MAX_IPV6_PREFIX) {
611        fprintf(stderr, "bufferoverflow in getPrefixV6 function (get_conf.c)\
612change the value of MAX_IPV6_PREFIX  declaration and make again a compilation \n");
613        exit(1);
614      }
615    }
616#ifdef DEBUG
617  for(i=0;i<counter;i++) {
618    fprintf(stderr,"i : %hu - line : %s\n", i,prefixStrTab[i]);
619  }
620#endif
621  for(i=0;i<counter;i++)
622    {
623#if defined(IPV4AGGIDSNMP)
624#if defined(MULTISAMPLING)
625      sscanf(prefixStrTab[i],"%s %hu %hu\n",
626             s0,&n0,&n1);
627#else
628      sscanf(prefixStrTab[i],"%s %hu\n",
629             s0,&n0);
630#endif
631#endif
632      res = inet_pton(AF_INET6,
633                      s0,
634                      &in6addr16);
635      res = inet_pton(AF_INET6,
636                      s0,
637                      &in6addr);
638      if (res != 1){
639        fprintf(stderr,"BAD Prefix %s \n",s0);
640      } else {
641        pV6TabPtr[prefixIndex].start[0] = in6addr.s6_addr32[0];
642        pV6TabPtr[prefixIndex].start[1] = in6addr.s6_addr32[1];
643        pV6TabPtr[prefixIndex].start[2] = in6addr.s6_addr32[2];
644        pV6TabPtr[prefixIndex].start[3] = in6addr.s6_addr32[3];
645        if ((unsigned short)n0 <= 16) {
646            in6addr16.s6_addr16[0] = htons( ntohs(in6addr16.s6_addr16[0]) |~((~0)<<(16-(n0))));
647            in6addr16.s6_addr16[1] = (~0);
648            in6addr16.s6_addr16[2] = (~0);
649            in6addr16.s6_addr16[3] = (~0);
650            in6addr16.s6_addr16[4] = (~0);
651            in6addr16.s6_addr16[5] = (~0);
652            in6addr16.s6_addr16[6] = (~0);
653            in6addr16.s6_addr16[7] = (~0);
654        } else if ((unsigned short)n0 <= 32) {
655            in6addr16.s6_addr16[1] = htons( ntohs(in6addr16.s6_addr16[1]) |~((~0)<<(32-(n0))));
656            in6addr16.s6_addr16[2] = (~0);
657            in6addr16.s6_addr16[3] = (~0);
658            in6addr16.s6_addr16[4] = (~0);
659            in6addr16.s6_addr16[5] = (~0);
660            in6addr16.s6_addr16[6] = (~0);
661            in6addr16.s6_addr16[7] = (~0);
662        } else if ((unsigned short)n0 <= 48) {
663            in6addr16.s6_addr16[2] = htons( ntohs(in6addr16.s6_addr16[2]) |~((~0)<<(48-(n0))));
664            in6addr16.s6_addr16[3] = (~0);
665            in6addr16.s6_addr16[4] = (~0);
666            in6addr16.s6_addr16[5] = (~0);
667            in6addr16.s6_addr16[6] = (~0);
668            in6addr16.s6_addr16[7] = (~0);
669        } else if ((unsigned short)n0 <= 64) {
670            in6addr16.s6_addr16[3] = htons( ntohs(in6addr16.s6_addr16[3]) |~((~0)<<(64-(n0))));
671            in6addr16.s6_addr16[4] = (~0);
672            in6addr16.s6_addr16[5] = (~0);
673            in6addr16.s6_addr16[6] = (~0);
674            in6addr16.s6_addr16[7] = (~0);
675        } else if ((unsigned short)n0 <= 80) {
676            in6addr16.s6_addr16[4] = htons( ntohs(in6addr16.s6_addr16[4]) |~((~0)<<(80-(n0))));
677            in6addr16.s6_addr16[5] = (~0);
678            in6addr16.s6_addr16[6] = (~0);
679            in6addr16.s6_addr16[7] = (~0);
680        } else if ((unsigned short)n0 <= 96) {
681            in6addr16.s6_addr16[5] = htons( ntohs(in6addr16.s6_addr16[5]) |~((~0)<<(96-(n0))));
682            in6addr16.s6_addr16[6] = (~0);
683            in6addr16.s6_addr16[7] = (~0);
684        } else if ((unsigned short)n0 <= 112) {
685            in6addr16.s6_addr16[6] = htons( ntohs(in6addr16.s6_addr16[6]) |~((~0)<<(112-(n0))));
686            in6addr16.s6_addr16[7] = (~0);
687        } else {
688            in6addr16.s6_addr16[7] = htons( ntohs(in6addr16.s6_addr16[7]) |~((~0)<<(128-(n0))));
689        }
690        pV6TabPtr[prefixIndex].end[0] = in6addr16.s6_addr32[0];
691        pV6TabPtr[prefixIndex].end[1] = in6addr16.s6_addr32[1];
692        pV6TabPtr[prefixIndex].end[2] = in6addr16.s6_addr32[2];
693        pV6TabPtr[prefixIndex].end[3] = in6addr16.s6_addr32[3];
694        pV6TabPtr[prefixIndex].mask = n0;
695#if defined(MULTISAMPLING)
696        pV6TabPtr[prefixIndex].sampling = n1;
697#else
698        pV6TabPtr[prefixIndex].sampling = 0;
699#endif
700        prefixIndex++;
701      }
702    }
703  qsort(pV6TabPtr, prefixIndex, sizeof(struct PrefixV6), prefixV6Cmp);
704  if( fclose(prefixFile) == 0) {
705    return (prefixIndex);
706  } else {
707    fprintf(stderr,"%s not closed, \n", filename);
708    exit(1);
709    return(prefixIndex);
710  }
711}
Note: See TracBrowser for help on using the browser.