root/trunk/src/dataFlowSet.c @ 84

Revision 84, 37.3 KB (checked in by andreu, 14 years ago)

multi-sampling implementation - phase 1
  • Property svn:eol-style set to native
Line 
1/*
2 * File: dataFlowSet.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 "dataFlowSet.h"
27
28/*
29 * Check Data FlowSet
30 *
31 */
32short 
33checkDataFlowSet(short shift,
34                 struct MyPtrs *myPtrs,
35                 int myQueue,
36                 struct PrefixV4 *V4PTab,
37                 size_t nbPV4,
38                 struct PrefixV4 *V4STab,
39                 size_t nbSV4
40                 )
41{
42  TplFlowSetPtr tmp = NULL;
43  TplOptionPtr tmpOpt = NULL;
44  FieldPtr pftmp = NULL;
45  FieldPtr secondPftmp = NULL;
46  unsigned short data_length = 0;
47  unsigned short flow_size = 0;
48  unsigned short oldOffset = *myPtrs->offsetV9Ptr;
49  unsigned short secondOffset = 0;
50  unsigned short secondOldOffset = 0;
51  int moreIsNecessary = 1;
52  int field_size = 0;
53  int cpt = 0;
54  int secondCpt = 0;
55  int overflow = 0;
56  int noEnd = 1;
57  int i = 0;
58  int j = 0;
59  int pos = 0;
60  unsigned char buffer1; 
61  unsigned char buffer2[2];
62  unsigned char buffer4[4];
63  RulesPtr tmpRuleList = myPtrs->rulesListPtr;
64  RulesPtr tmpRL = myPtrs->rulesListPtr;
65  msgType myMsg;
66  char *msgTextIndex;
67
68  unsigned short tplMsgType = 11;
69  struct PrefixV4 prefixKey, *res, *res2, *resSub; /* for bsearch */
70#if defined(IPV4AGGIDSNMP)
71  struct PrefixV4 *res3;
72#endif
73#ifdef ASACC
74  struct AS asKey, *asres; /* for bsearch */
75#endif
76  struct AggCache agCache;
77  int bool = 0; /* in IPV4 Agg mode enabled, we need to now if it's an IPv4 */
78  /* flow, we test on the field and then put bool at 1 */
79  int isMplsFlow = 0;
80  int paddingCounter = 0;
81  int crazyCounter = 0;
82
83  buffer2[1] = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
84  (*myPtrs->offsetV9Ptr)++;
85  buffer2[0] = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
86  (*myPtrs->offsetV9Ptr)++;
87  (*myPtrs->currentFlowsetIdPtr) = *((unsigned short*)&buffer2);
88  buffer2[1] = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
89  (*myPtrs->offsetV9Ptr)++;
90  buffer2[0] = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
91  (*myPtrs->offsetV9Ptr)++;
92  data_length = *((unsigned short*)&buffer2);
93  if (data_length == 0) {
94    syslog(LOG_INFO, "data flowset length null; all next informations of this data flowset are not considered! flowset ID: %hu, from router: %lu.%lu.%lu.%lu",
95           (*myPtrs->currentFlowsetIdPtr),
96           (myPtrs->pcktPtr->ipH->srcAdd>>24),
97           (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
98           (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
99           (myPtrs->pcktPtr->ipH->srcAdd<<24>>24));
100    return (-1);
101
102  }
103
104  if ( (tmp=existTplId(myPtrs->currentRouterPtr,
105                       myPtrs->currentHeaderV9Ptr->sourceId,
106                       (*myPtrs->currentFlowsetIdPtr)))!=NULL ) {
107#ifdef DEBUG
108    fprintf(stderr,
109            "{d id: %hu, lg %hu",
110            (*myPtrs->currentFlowsetIdPtr),
111            data_length);
112    if ( (*myPtrs->currentFlowsetIdPtr) > TRESHOLD_TEMPLATE_ID ) {
113      /*        fprintf(stderr,"Bad TID from router: %lu.%lu.%lu.%lu\n", */
114      /*                (*myPtrs->currentFlowsetIdPtr), */
115      /*                (myPtrs->pcktPtr->ipH->srcAdd>>24), */
116      /*                (myPtrs->pcktPtr->ipH->srcAdd<<8>>24), */
117      /*                (myPtrs->pcktPtr->ipH->srcAdd<<16>>24), */
118      /*                (myPtrs->pcktPtr->ipH->srcAdd<<24>>24)); */
119      /*        fprintf(stderr," Bytes : \n"); */
120      /*        while ( ( myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr) ) > (myPtrs->ptr_buffer+1416) ){ */
121      /*          buffer1= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));(*myPtrs->offsetV9Ptr)++; */
122      /*          tmp = *((unsigned char*)&buffer1); */
123      /*          fprintf (stderr, " %s ", tmp); */
124      /*        } */
125      /*        exit(-1); */
126      return (data_length+shift);
127    }
128#endif
129    pftmp = tmp->lastField;
130    for (; pftmp; pftmp = pftmp->prev) {
131      flow_size += pftmp->fieldLength;
132    }
133    if ( data_length%flow_size >= 9 ) {
134      (*myPtrs->currentFlowsetNumberPtr) = myPtrs->currentHeaderV9Ptr->count;
135      syslog(LOG_INFO, "data flowset length not match with length from template definition, wrong template definition suspected; all next informations of this data flowset are not considered! flowset ID: %hu, from router: %lu.%lu.%lu.%lu",
136             (*myPtrs->currentFlowsetIdPtr),
137             (myPtrs->pcktPtr->ipH->srcAdd>>24),
138             (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
139             (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
140             (myPtrs->pcktPtr->ipH->srcAdd<<24>>24));
141      return (data_length+shift);
142    }
143    if ( data_length >= 1452 ) {
144      syslog(LOG_INFO, "data flowset length too raised; all next informations of this data flowset are not considered! flowset ID: %hu, from router: %lu.%lu.%lu.%lu",
145             (*myPtrs->currentFlowsetIdPtr),
146             (myPtrs->pcktPtr->ipH->srcAdd>>24),
147             (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
148             (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
149             (myPtrs->pcktPtr->ipH->srcAdd<<24>>24));
150      return (-1);
151    }
152#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
153    agCache.routerAd = myPtrs->pcktPtr->ipH->srcAdd;
154#endif
155
156    pftmp = tmp->lastField;
157    secondPftmp = tmp->lastField;   
158    secondOffset = *myPtrs->offsetV9Ptr;
159    secondOldOffset = secondOffset;
160    while ( (((*myPtrs->offsetV9Ptr)-48-shift) <= data_length)
161            && (overflow!=1) ) {
162      /*
163       * progression in a data flow Set
164       * notes:
165       *   48= IP header size + NetFlow header size
166       *   shift = shift because we have a template declaration
167       *           inside data templates
168       */
169      cpt++;
170      j = 0;
171      pos = (pftmp->fieldType)*MAX_RULES_PER_FIELD+j;
172      field_size = (int) pftmp->fieldLength;
173
174      /* special case: check yes on all flows from one router */
175      /* (phantom field nb 0) */
176      /* FIXME : this code is repeated, perhaps past before */
177      while ( ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+j))) != NULL ) {
178        if ( (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+j)))->value->stor.lvalue)
179             == myPtrs->pcktPtr->ipH->srcAdd )
180          {
181            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+j)))->check = 1;
182          }     
183        j++;
184      }   
185      j = 0;
186
187      /*
188       * Comparaison between the field value and the rules
189       * ... if one rule exist
190       * FIXME : warning, if no rules, no accounting ?
191       */
192      if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos))) != NULL) {
193        oldOffset = *myPtrs->offsetV9Ptr;
194        while (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos))) != NULL){
195          /*
196           * while on one cache table line
197           */
198          *myPtrs->offsetV9Ptr = oldOffset;
199          switch ((int)
200                  (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->operator)){
201          case 2:
202            /* operator: "=" */ 
203            switch (field_size) {
204            case 1:
205              buffer1 = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
206              (*myPtrs->offsetV9Ptr)++;
207              /* rule check */
208              if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.cvalue
209                  == *((unsigned char*)&buffer1)) {
210                ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
211              }
212              /* end rule check */
213#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
214              if ((pftmp->fieldType==9)||(pftmp->fieldType==29)){
215                agCache.maskS = *((unsigned char*)&buffer1);
216              }
217              if ((pftmp->fieldType==13)||(pftmp->fieldType==30)){
218                agCache.maskD = *((unsigned char*)&buffer1);
219              }
220              if (pftmp->fieldType==60){
221                agCache.ipProt = *((unsigned char*)&buffer1);
222              }
223              if (pftmp->fieldType==4){
224                agCache.tProt = *((unsigned char*)&buffer1);
225              }
226              if (pftmp->fieldType==61){
227                agCache.sens = *((unsigned char*)&buffer1);
228              }
229              if (pftmp->fieldType==5){
230                agCache.dscp = *((unsigned char*)&buffer1);
231              }
232#endif       
233              break;
234            case 2:
235              buffer2[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
236              (*myPtrs->offsetV9Ptr)++;
237              buffer2[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
238              (*myPtrs->offsetV9Ptr)++;
239              if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.svalue
240                  == *((unsigned short*)&buffer2))
241                ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
242#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
243              if (pftmp->fieldType==10){
244                agCache.inputSnmp = *((unsigned short*)&buffer2);
245              }
246              if (pftmp->fieldType==14){
247                agCache.outputSnmp = *((unsigned short*)&buffer2);
248              }
249#endif
250#ifdef ASACC
251              if (pftmp->fieldType==16){
252                agCache.asS = *((unsigned short*)&buffer2);
253              }   
254              if (pftmp->fieldType==17){
255                agCache.asD = *((unsigned short*)&buffer2);
256              }
257#endif
258              break;
259            case 3:
260              buffer4[3]= 0;
261              buffer4[2]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
262              (*myPtrs->offsetV9Ptr)++;
263              buffer4[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
264              (*myPtrs->offsetV9Ptr)++;
265              buffer4[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
266              (*myPtrs->offsetV9Ptr)++;
267              if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue
268                  == *((unsigned long*)&buffer4))
269                ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
270              /* aggregation */
271              /* end aggregation */
272              if (pftmp->fieldType==70){
273                isMplsFlow = 1;
274              }
275              break;
276            case 4:
277              buffer4[3]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
278              (*myPtrs->offsetV9Ptr)++;
279              buffer4[2]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
280              (*myPtrs->offsetV9Ptr)++;
281              buffer4[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
282              (*myPtrs->offsetV9Ptr)++;
283              buffer4[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
284              (*myPtrs->offsetV9Ptr)++;
285              /* FIXME : here , add a check on the field type */
286              if ((pftmp->fieldType==8)||(pftmp->fieldType==12)
287                  ||(pftmp->fieldType==15)||(pftmp->fieldType==18)){
288                if ((((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue)
289                    == (*((unsigned long*)&buffer4))>>(32-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)<<(32-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask) )
290                  {
291                    ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
292                  }
293              }
294              if ((pftmp->fieldType==10)||(pftmp->fieldType==14)){
295                if ((((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue)
296                    == (*((unsigned long*)&buffer4)))
297                  {
298                    ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
299                  }
300              }
301              if (pftmp->fieldType==1){
302                agCache.bytes = *((unsigned long*)&buffer4);
303                if (
304                    ((unsigned long)((((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue) + ( (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue)*10/100))
305                     >= (*((unsigned long*)&buffer4)))
306                    &&
307                    ( (unsigned long)((((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue) - ( (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue)*10/100))
308                      <= (*((unsigned long*)&buffer4)) )
309                    )
310                  {
311                    ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
312                  }
313              }
314#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
315              if ((pftmp->fieldType==8)){
316                bool = 1; /* very important, test if we have an IPv4 flow for Agg */
317                agCache.v4AdS = *((unsigned long*)&buffer4);
318              }
319              if ((pftmp->fieldType==12)){
320                agCache.v4AdD = *((unsigned long*)&buffer4);
321              }
322              if (pftmp->fieldType==1){
323                agCache.bytes = *((unsigned long*)&buffer4);
324              }
325              if (pftmp->fieldType==2){
326                agCache.pkts = *((unsigned long*)&buffer4);
327              }
328#endif
329              break;
330            case 16:
331              for (i=0; i<4; i++) {
332                buffer4[3]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
333                (*myPtrs->offsetV9Ptr)++;
334                buffer4[2]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
335                (*myPtrs->offsetV9Ptr)++;
336                buffer4[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
337                (*myPtrs->offsetV9Ptr)++;
338                buffer4[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
339                (*myPtrs->offsetV9Ptr)++;
340                if (1==moreIsNecessary){
341                  switch(i){
342                  case 0:
343                    if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask <= 32){
344                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
345                          ==
346                          (*((unsigned long*)&buffer4))>>(32-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)<<(32-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)
347                          )
348                        {
349                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
350                          moreIsNecessary = 0;
351                        } else {
352                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
353                        moreIsNecessary = 0;
354                      }
355                    } else {
356                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
357                          ==
358                          (*((unsigned long*)&buffer4))
359                          )
360                        {
361                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1;
362                        } else {
363                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
364                        moreIsNecessary = 0;
365                      }
366                    }
367                    break;
368                  case 1:
369                    if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask <= 64){
370                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
371                          ==
372                          (*((unsigned long*)&buffer4))>>(64-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)<<(64-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)
373                          )
374                        {
375                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check =
376                            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check && 1;
377                          moreIsNecessary = 0;
378                        } else {
379                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
380                        moreIsNecessary = 0;
381                      }
382                    } else {
383                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
384                          ==
385                          (*((unsigned long*)&buffer4))
386                          )
387                        {
388                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check =
389                            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check && 1;
390                        } else {
391                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
392                        moreIsNecessary = 0;
393                      }
394                    }
395                    break;
396                  case 2:
397                    if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask <= 96){
398                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
399                          ==
400                          (*((unsigned long*)&buffer4))>>(96-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)<<(96-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)
401                          )
402                        {
403                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check =
404                            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check && 1;
405                          moreIsNecessary = 0;
406                        } else {
407                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
408                        moreIsNecessary = 0;
409                      }
410                    } else {
411                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
412                          ==
413                          (*((unsigned long*)&buffer4))
414                          )
415                        {
416                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check =
417                            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check && 1;
418                        } else {
419                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
420                        moreIsNecessary = 0;
421                      }
422                    }
423                    break;
424                  case 3:
425                    if (((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask <= 128){
426                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
427                          ==
428                          (*((unsigned long*)&buffer4))>>(128-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)<<(128-((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->mask)
429                          )
430                        {
431                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check =
432                            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check && 1;
433                        } else {
434                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
435                        moreIsNecessary = 0;
436                      }
437                    } else {
438                      if (ntohl(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.tabAdd6[i])
439                          ==
440                          (*((unsigned long*)&buffer4))
441                          )
442                        {
443                          ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check =
444                            ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check && 1;
445                        } else {
446                        ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 0;
447                        moreIsNecessary = 0;
448                      }
449                    }
450                    break;
451                  default:
452                    break;
453                  } /* end of switch(i) */
454                } /* end of if moreIsNecessary */
455              }
456              moreIsNecessary = 1;
457              /* aggregation for IPv6 flows */
458
459              /* end aggregation */
460              break;
461            default:
462              syslog(LOG_INFO, "Field size not known: %d\n", field_size);
463              for (i=0; i<field_size; i++){
464                (*myPtrs->offsetV9Ptr)++;
465              }
466              break;
467            }
468            break;
469          default:
470            syslog(LOG_INFO, "Operator not known: %d\n",
471                   (int)(((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->operator));
472            break;
473          }
474          j++;
475          pos = (pftmp->fieldType)*10+j;
476        } /* end while myPtrs->rulesAddressPtr */
477      } else {
478        /*
479         * no rule within this field type, but we must read the value
480         */
481        switch (field_size) {
482        case 1:
483          buffer1 = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
484          (*myPtrs->offsetV9Ptr)++;
485#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
486          if ((pftmp->fieldType==9)||(pftmp->fieldType==29)){
487            agCache.maskS = *((unsigned char*)&buffer1);
488          }
489          if ((pftmp->fieldType==13)||(pftmp->fieldType==30)){
490            agCache.maskD = *((unsigned char*)&buffer1);
491          }
492          if (pftmp->fieldType==60){
493            agCache.ipProt = *((unsigned char*)&buffer1);
494          }
495          if (pftmp->fieldType==4){
496            agCache.tProt = *((unsigned char*)&buffer1);
497          }
498          if (pftmp->fieldType==61){
499            agCache.sens = *((unsigned char*)&buffer1);
500          }
501          if (pftmp->fieldType==5){
502            agCache.dscp = *((unsigned char*)&buffer1);
503          }       
504#endif
505          break;
506        case 2:
507          buffer2[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
508          (*myPtrs->offsetV9Ptr)++;
509          buffer2[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
510          (*myPtrs->offsetV9Ptr)++;
511#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
512          if (pftmp->fieldType==10){
513            agCache.inputSnmp = *((unsigned short*)&buffer2);
514          }       
515          if (pftmp->fieldType==14){
516            agCache.outputSnmp = *((unsigned short*)&buffer2);
517          }       
518#endif
519#ifdef ASACC
520          if (pftmp->fieldType==16){
521            agCache.asS = *((unsigned short*)&buffer2);
522          }       
523          if (pftmp->fieldType==17){
524            agCache.asD = *((unsigned short*)&buffer2);
525          }
526#endif
527          break;
528        case 3:
529          buffer4[3]= 0;
530          buffer4[2]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
531          (*myPtrs->offsetV9Ptr)++;
532          buffer4[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
533          (*myPtrs->offsetV9Ptr)++;
534          buffer4[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
535          (*myPtrs->offsetV9Ptr)++;
536          /* aggregation */
537          /* end aggregation */
538          if (pftmp->fieldType==70){
539            isMplsFlow = 1;
540          }
541          break;
542        case 4:
543          buffer4[3]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
544          (*myPtrs->offsetV9Ptr)++;
545          buffer4[2]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
546          (*myPtrs->offsetV9Ptr)++;
547          buffer4[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
548          (*myPtrs->offsetV9Ptr)++;
549          buffer4[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
550          (*myPtrs->offsetV9Ptr)++;
551#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
552          if ((pftmp->fieldType==8)){
553            bool = 1;
554            agCache.v4AdS = *((unsigned long*)&buffer4);
555          } else if ((pftmp->fieldType==12)){
556            agCache.v4AdD = *((unsigned long*)&buffer4);
557          } else if (pftmp->fieldType==1){
558            agCache.bytes = *((unsigned long*)&buffer4);
559          } else if (pftmp->fieldType==2){
560            agCache.pkts = *((unsigned long*)&buffer4);
561          }
562#endif
563          break;
564        case 16:
565          for (i=0; i<4; i++) {
566            buffer2[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
567            (*myPtrs->offsetV9Ptr)++;
568            buffer2[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
569            (*myPtrs->offsetV9Ptr)++;
570            buffer2[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
571            (*myPtrs->offsetV9Ptr)++;
572            buffer2[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr));
573            (*myPtrs->offsetV9Ptr)++;
574          }
575          /* aggregation IPv6 */         
576          /* end aggregation */
577          break;
578        default:
579          syslog(LOG_INFO,"UNKNOWN FIELDS LENGTH: %d ", field_size);
580          for (i=0; i<field_size; i++){
581            (*myPtrs->offsetV9Ptr)++;
582          }
583        }
584      } /* end if one cache table line existence */
585      if (cpt==tmp->fieldCount) {
586        /*
587         * end of one flow (not the flowset)
588         */
589
590        /* put aggregation cache information to IPv4 Prefixes table */
591        /* Aggregation mode must be enable in ./configure options   */
592        /* first we must know if the address belong to our prefix   */
593        /*
594         * AS ACCOUNTING
595         */
596#if defined(ASACC) && defined(IPV4AGGIDSNMP)
597        if ( (bool == 1) && (isMplsFlow == 0) ){
598          asKey.as = agCache.asS;
599          asres = bsearch(&asKey, myPtrs->currentASTab, myPtrs->asNb, sizeof(struct AS), asGlobalCmp);
600          if (asres != NULL) {
601            if ( myPtrs->currentRouterPtr->snmpIndexList[agCache.inputSnmp] == 1  ) {         
602              if (myPtrs->currentRouterPtr->sampled != 0 ){
603                /* OUT ("traffic from the AS")  */
604                asres->bytesNbOUT += agCache.bytes;
605                asres->pktsNbOUT += agCache.pkts;
606                (asres->flowNbOUT)++;
607              }
608              if (asres->sampling == 0
609                  && myPtrs->currentRouterPtr->sampled != 0){
610                asres->sampling = myPtrs->currentRouterPtr->sampled;
611              }
612              asres = NULL;
613              asKey.as = agCache.asD;
614              asres = bsearch(&asKey, myPtrs->currentASTab, myPtrs->asNb, sizeof(struct AS), asGlobalCmp);
615              if (asres!=NULL){
616                if (myPtrs->currentRouterPtr->sampled != 0 ){
617                  /* IN ("traffic to the AS")  */
618                  asres->bytesNbIN += agCache.bytes;
619                  asres->pktsNbIN += agCache.pkts;
620                  (asres->flowNbIN)++;
621                }
622                if (asres->sampling == 0
623                    && myPtrs->currentRouterPtr->sampled != 0){
624                  asres->sampling = myPtrs->currentRouterPtr->sampled;
625                }
626                asres = NULL;
627              }
628            }
629          } else {
630            asres = NULL;
631            asKey.as = agCache.asD;
632            asres = bsearch(&asKey, myPtrs->currentASTab, myPtrs->asNb, sizeof(struct AS), asGlobalCmp);
633            if (asres!=NULL){
634              if ( myPtrs->currentRouterPtr->snmpIndexList[agCache.inputSnmp] == 1  ) {
635                if (myPtrs->currentRouterPtr->sampled != 0 ){
636                  /* IN ("traffic to the AS")  */
637                  asres->bytesNbIN += agCache.bytes;
638                  asres->pktsNbIN += agCache.pkts;
639                  (asres->flowNbIN)++;
640                }
641                if (asres->sampling == 0
642                    && myPtrs->currentRouterPtr->sampled != 0){
643                  asres->sampling = myPtrs->currentRouterPtr->sampled;
644                }
645              }
646            }
647          }
648        }
649#endif
650        /*
651         * PREFIX &/or MATRIX ACCOUNTING
652         */
653#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP)
654        if ( (bool == 1) && (isMplsFlow == 0) ){
655          prefixKey.beginning = agCache.v4AdS>>(32-agCache.maskS)<<(32-agCache.maskS);
656          res = bsearch(&prefixKey, V4PTab, nbPV4,
657                        sizeof(struct PrefixV4), prefGlobalCmp);
658          if (res!=NULL){
659            /* WE HAVE FOUND SOURCE ADDRESS IN OUR LIST */
660            if (res->hasSubnet == 1) {
661              resSub = NULL;
662              resSub = bsearch(&prefixKey, V4STab, nbSV4,
663                               sizeof(struct PrefixV4), prefGlobalCmp);
664              if (resSub != NULL) {
665                res = resSub;
666                resSub = NULL;
667              }
668            }
669#ifdef DEBUG
670            fprintf(stderr,"S %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu\n",
671                    (agCache.v4AdS>>24),
672                    (agCache.v4AdS<<8>>24),
673                    (agCache.v4AdS<<16>>24),
674                    (agCache.v4AdS<<24>>24),
675                    (agCache.maskS),
676                    (agCache.v4AdD>>24),
677                    (agCache.v4AdD<<8>>24),
678                    (agCache.v4AdD<<16>>24),
679                    (agCache.v4AdD<<24>>24),
680                    (agCache.maskD),
681                    myPtrs->currentRouterPtr->sampled,
682                    res->sampling);
683#endif
684#if defined(IPV4AGGIDR)
685            if ( myPtrs->routersID[res->routerNb] == agCache.routerAd  ) {
686#elif defined(IPV4AGGIDSNMP)
687              if ( myPtrs->currentRouterPtr->snmpIndexList[agCache.inputSnmp] == 1  ) {       
688#endif
689                /* OUT ("traffic from the prefix/subnet")  */
690#if defined(MULTISAMPLING)
691                if (myPtrs->currentRouterPtr->sampled != res->sampling ){
692                  res->bytesNbOUT += agCache.bytes*myPtrs->currentRouterPtr->sampled/res->sampling;
693                  res->pktsNbOUT += agCache.pkts*myPtrs->currentRouterPtr->sampled/res->sampling;
694                  /* (res->flowNbOUT)++; FIXME : FIND SOMETHING*/
695                }else{
696                  res->bytesNbOUT += agCache.bytes;
697                  res->pktsNbOUT += agCache.pkts;
698                  (res->flowNbOUT)++;             
699                }
700#else
701                if (myPtrs->currentRouterPtr->sampled != 0 ){
702                  res->bytesNbOUT += agCache.bytes;
703                  res->pktsNbOUT += agCache.pkts;
704                  (res->flowNbOUT)++;
705                }
706                if (res->sampling == 0
707                    && myPtrs->currentRouterPtr->sampled != 0){
708                  res->sampling = myPtrs->currentRouterPtr->sampled;
709                }
710#endif
711#if defined(IPV4AGGIDSNMP)
712                prefixKey.beginning = agCache.v4AdD>>(32-agCache.maskD)<<(32-agCache.maskD);
713                res3 = bsearch(&prefixKey, V4PTab, nbPV4,
714                               sizeof(struct PrefixV4), prefGlobalCmp);
715                if (res3!=NULL){
716                  /* res is supernet or subnet ? */
717                  if (res3->hasSubnet == 1) {
718                    resSub = NULL;
719                    resSub = bsearch(&prefixKey, V4STab, nbSV4,
720                                     sizeof(struct PrefixV4), prefGlobalCmp);
721                    if (resSub != NULL) {
722                      res3 = resSub;
723                      resSub = NULL;
724                    }
725                  }
726#ifdef DEBUG
727            fprintf(stderr,"S&D %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu\n",
728                    (agCache.v4AdS>>24),
729                    (agCache.v4AdS<<8>>24),
730                    (agCache.v4AdS<<16>>24),
731                    (agCache.v4AdS<<24>>24),
732                    (agCache.maskS),
733                    (agCache.v4AdD>>24),
734                    (agCache.v4AdD<<8>>24),
735                    (agCache.v4AdD<<16>>24),
736                    (agCache.v4AdD<<24>>24),
737                    (agCache.maskD),
738                    myPtrs->currentRouterPtr->sampled,
739                    res3->sampling);
740#endif
741#if defined(MULTISAMPLING)
742                  if (myPtrs->currentRouterPtr->sampled != res3->sampling ){
743                    res3->bytesNbIN += agCache.bytes*myPtrs->currentRouterPtr->sampled/res3->sampling;
744                    res3->pktsNbIN += agCache.pkts*myPtrs->currentRouterPtr->sampled/res3->sampling;
745                    /* (res3->flowNbIN)++;  FIXME : FIND SOMETHING */
746                  }else{
747                    res3->bytesNbIN += agCache.bytes;
748                    res3->pktsNbIN += agCache.pkts;
749                    (res3->flowNbIN)++;
750                  }
751#else
752                  if (myPtrs->currentRouterPtr->sampled != 0 ){
753                    /* IN ("traffic to the prefix/subnet")  */
754                    res3->bytesNbIN += agCache.bytes;
755                    res3->pktsNbIN += agCache.pkts;
756                    (res3->flowNbIN)++;
757                  }
758                  if (res3->sampling == 0
759                      && myPtrs->currentRouterPtr->sampled != 0){
760                    res3->sampling = myPtrs->currentRouterPtr->sampled;
761                  }
762#endif
763                }
764#endif
765#if defined(MATRIX) && defined(IPV4AGGIDR)
766                /* inter-pop matrix Accounting */
767                prefixKey.beginning = agCache.v4AdD>>(32-agCache.maskD)<<(32-agCache.maskD);
768                res2 = bsearch(&prefixKey, V4PTab, nbPV4,
769                               sizeof(struct PrefixV4), prefGlobalCmp);
770                if (res2!=NULL){               
771                  ((struct POP *)((myPtrs->matrixPOP)
772                                  +((res->routerNb)*ROUTER_INDEX_MAX)
773                                  +((res2->routerNb))))->pktsNb += agCache.pkts;
774                  ((struct POP *)((myPtrs->matrixPOP)
775                                  +((res->routerNb)*ROUTER_INDEX_MAX)
776                                  +((res2->routerNb))))->bytesNb += agCache.bytes;
777                  ((struct POP *)((myPtrs->matrixPOP)
778                                  +((res->routerNb)*ROUTER_INDEX_MAX)
779                                  +((res2->routerNb))))->flowNb++;
780                } else {
781                  (
782                   ((struct POP *)(myPtrs->matrixPOP)
783                    +((res->routerNb)*ROUTER_INDEX_MAX)
784                    +((ROUTER_INDEX_MAX-1))))->pktsNb += agCache.pkts;
785                  (
786                   ((struct POP *)(myPtrs->matrixPOP)
787                    +((res->routerNb)*ROUTER_INDEX_MAX)
788                    +((ROUTER_INDEX_MAX-1))))->bytesNb += agCache.bytes;
789                  (
790                   ((struct POP *)(myPtrs->matrixPOP)
791                    +((res->routerNb)*ROUTER_INDEX_MAX)
792                    +((ROUTER_INDEX_MAX-1))))->flowNb++;
793                }
794                /* end interpop matrix accounting */
795#endif /* matrix */
796              } else {
797                /* doublon or bad reference in prefix list */
798#if defined(IPV4AGGIDR)
799              }
800#elif defined(IPV4AGGIDSNMP)
801            }
802#endif
803          } else { /* SOURCE ADDRESS DOESN'T IN OUR LIST */
804            prefixKey.beginning = agCache.v4AdD>>(32-agCache.maskD)<<(32-agCache.maskD);
805            res = bsearch(&prefixKey, V4PTab, nbPV4,
806                          sizeof(struct PrefixV4), prefGlobalCmp);
807            if (res!=NULL){
808              /* DESTINATION ADDRESS IS IN OUR LIST */
809              if (res->hasSubnet == 1) {
810                resSub = NULL;
811                resSub = bsearch(&prefixKey, V4STab, nbSV4,
812                                 sizeof(struct PrefixV4), prefGlobalCmp);
813                if (resSub != NULL) {
814                  res = resSub;
815                  resSub = NULL;
816                }
817              }
818#ifdef DEBUG
819            fprintf(stderr,"D %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu R@ %lu.%lu.%lu.%lu\n",
820                    (agCache.v4AdS>>24),
821                    (agCache.v4AdS<<8>>24),
822                    (agCache.v4AdS<<16>>24),
823                    (agCache.v4AdS<<24>>24),
824                    (agCache.maskS),
825                    (agCache.v4AdD>>24),
826                    (agCache.v4AdD<<8>>24),
827                    (agCache.v4AdD<<16>>24),
828                    (agCache.v4AdD<<24>>24),
829                    (agCache.maskD),
830                    myPtrs->currentRouterPtr->sampled,
831                    res->sampling,
832                    (myPtrs->pcktPtr->ipH->srcAdd>>24),
833                    (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
834                    (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
835                    (myPtrs->pcktPtr->ipH->srcAdd<<24>>24));
836#endif
837#if defined(IPV4AGGIDSNMP)
838              if ( myPtrs->currentRouterPtr->snmpIndexList[agCache.inputSnmp] == 1  ) {
839#if defined(MULTISAMPLING)
840                if (myPtrs->currentRouterPtr->sampled != res->sampling ){
841                  res->bytesNbIN += agCache.bytes*myPtrs->currentRouterPtr->sampled/res->sampling;
842                  res->pktsNbIN += agCache.pkts*myPtrs->currentRouterPtr->sampled/res->sampling;
843                }else{
844                  res->bytesNbIN += agCache.bytes;
845                  res->pktsNbIN += agCache.pkts;
846                  (res->flowNbIN)++;
847                }
848#else
849                if (myPtrs->currentRouterPtr->sampled != 0 ){
850                  /* IN ("traffic to the prefix/subnet")  */
851                  res->bytesNbIN += agCache.bytes;
852                  res->pktsNbIN += agCache.pkts;
853                  (res->flowNbIN)++;
854                }
855#endif
856              }
857#endif
858#if defined(IPV4AGGIDR)
859              if ( myPtrs->routersID[res->routerNb] == agCache.routerAd  ) {
860                if (myPtrs->currentRouterPtr->sampled != 0 ){
861                  /* IN ("traffic to the prefix")  */
862                  res->bytesNbIN += agCache.bytes;
863                  res->pktsNbIN += agCache.pkts;
864                  (res->flowNbIN)++;
865                }
866              }
867              if (res->sampling == 0
868                  && myPtrs->currentRouterPtr->sampled != 0 ){
869                res->sampling = myPtrs->currentRouterPtr->sampled;
870              }
871#endif
872            } else {
873              /* UNKNOW SUBNET CASE                                        */
874              /*                                                           */
875              /* HERE : we are in the cases of the address/mask don't      */
876              /*        belong to a prefix listed in the IPv4 prefix file  */
877              /* possibilities :                                           */
878              /*     -  prefix not referenced but allowed to be routed     */
879              /*     -  prefix not referenced but not allowed to be routed */
880              /*     -  spoofing                                           */
881#ifdef PRINTUNKNOWNSUBNET 
882              fprintf(stderr, "%lu.%lu.%lu.%lu/%hu -> %lu.%lu.%lu.%lu/%hu (R:%lu.%lu.%lu.%lu) \n",
883                      (agCache.v4AdS>>24),
884                      (agCache.v4AdS<<8>>24),
885                      (agCache.v4AdS<<16>>24),
886                      (agCache.v4AdS<<24>>24),
887                      (agCache.maskS),
888                      (agCache.v4AdD>>24),
889                      (agCache.v4AdD<<8>>24),
890                      (agCache.v4AdD<<16>>24),
891                      (agCache.v4AdD<<24>>24),
892                      (agCache.maskD),
893                      (myPtrs->pcktPtr->ipH->srcAdd>>24),
894                      (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
895                      (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
896                      (myPtrs->pcktPtr->ipH->srcAdd<<24>>24)
897                      );
898#endif /* PRINTUNKNOWNSUBNET */
899            }
900          } /* end of the Destination prefix is in our list */
901        } /* end of the prefix is in our list */
902        bool = 0;
903        isMplsFlow = 0;
904#endif /* (IPV4AGGIDR) || (IPV4AGGIDSNMP) */
905        /*
906         *
907         * SOCKET OUTPUT TO A REMOTE CLIENT
908         *
909         * switch the rules definition (check & fieldToRecord),
910         * we send the flow or a part of the flow to a remote host or a file.
911         * In a first time (until release 0.0.7, the information was sent via
912         * the process renetcolSender with an IPC message queue. But, the perf
913         * of IPC Msg was very bad with a default system compilation.
914         * So, now, we send information directly from here through sockets.
915         */
916        tmpRuleList = myPtrs->rulesListPtr;
917        tmpRL = myPtrs->rulesListPtr;
918        while (tmpRuleList){
919          RuleDefPtr tmpRuleDefList = tmpRuleList->def;
920          unsigned short check = 1;
921          int s=0;
922          secondOffset = secondOldOffset;
923          while (tmpRuleDefList){
924            check = check && tmpRuleDefList->check;
925            tmpRuleDefList->check = 0;
926            tmpRuleDefList = tmpRuleDefList->next;
927          }
928          if ( (tmpRuleList->def != NULL) && (check == 1)) {
929            /* msg building */
930            secondPftmp = tmp->lastField;
931            msgTextIndex = mempcpy(mempcpy(mempcpy(myMsg.text,   
932                                                   &tplMsgType,
933                                                   sizeof(unsigned short)
934                                                   ),
935                                           &tmpRuleList->id,
936                                           sizeof(tmpRuleList->id)
937                                           ),
938                                   &myPtrs->currentRouterPtr->IpAddress,
939                                   sizeof(unsigned long)
940                                   );
941            msgTextIndex = mempcpy(mempcpy(mempcpy(msgTextIndex,
942                                                   &tmp->sourceId,
943                                                   sizeof(unsigned long)
944                                                   ),
945                                           &tmp->templateFlowSetId,
946                                           sizeof(tmp->templateFlowSetId)
947                                           ),
948                                   myPtrs->ptr_buffer+secondOffset,
949                                   flow_size
950                                   );
951            myMsg.type = 1;
952             
953
954            /* NEW transfert type */
955            for ( ; tmpRL; tmpRL=tmpRL->next){
956              if (tmpRL->id == tmpRuleList->id){       
957                s = sendMessage(tmpRL->host->sockId, myMsg.text, sizeof(myMsg.text),
958                                tmpRL->host->hostAddressPtr);
959              }
960            }
961            /* FIXME : perhaps check "s" */
962            noEnd = 1;
963            secondCpt=0;
964          } /* end if check */
965          tmpRuleList = tmpRuleList->next;
966          tmpRL = myPtrs->rulesListPtr; /* ticket #11 */
967          secondPftmp = tmp->lastField;
968        } /* end while tmpRuleList */
969        /*
970         * end redirection
971         */
972        secondOffset = *myPtrs->offsetV9Ptr;
973        secondOldOffset = secondOffset;
974        pftmp = tmp->lastField;
975        cpt=0;
976        (*myPtrs->currentFlowsetNumberPtr)++; /* pointer on the flows number */
977        if (((*myPtrs->offsetV9Ptr)-48-shift+flow_size) > data_length){
978          overflow = 1; /* buffer index not correct */
979        }
980      } else {
981        /* not the flow end, progress in field list */
982        pftmp = pftmp->prev;
983      }
984    } /* end of the while on one flow record */
985     
986    while ( ((*myPtrs->offsetV9Ptr)-48-shift) < data_length ) {
987      (*myPtrs->offsetV9Ptr)++; /* if padding */
988      paddingCounter++;
989      if ( paddingCounter > 8 ) {
990#ifdef DEBUG
991        fprintf(stderr," padding too high: %d ", paddingCounter);
992#endif
993        syslog(LOG_INFO,"padding too high: %d ", paddingCounter);
994        return (-1);
995      }
996    }
997    while ( (*myPtrs->offsetV9Ptr)-48-shift > data_length ) {
998      (*myPtrs->offsetV9Ptr)--; /* crazy loop (when bug appears in template def) */
999      crazyCounter++;
1000    }
1001#ifdef DEBUG
1002    if (crazyCounter != 0){ fprintf(stderr," crazyCounter: %d ", crazyCounter); }
1003#endif
1004    if (crazyCounter!=0) { syslog(LOG_INFO,"crazyCounter: %d ", crazyCounter);}
1005     
1006#ifdef DEBUG
1007    fprintf(stderr,"}");
1008#endif
1009     
1010    return (data_length+shift);
1011    /* end new place */
1012
1013  } else {
1014    /*
1015     *
1016     *
1017     *  OPTIONAL TEMPLATE
1018     *
1019     *
1020     */
1021    if ((tmpOpt=existTplOptId(myPtrs->currentRouterPtr, myPtrs->currentHeaderV9Ptr->sourceId,
1022                              (*myPtrs->currentFlowsetIdPtr)))!=NULL) {       
1023#ifdef DEBUG
1024      fprintf(stderr,"<d id: %hu, lg %hu", (*myPtrs->currentFlowsetIdPtr), data_length);
1025#endif
1026      for ( i=0; i<(tmpOpt->optionScopeLg/4); i++){
1027        /* FIXME : today we skip the scope fields, it's bad :( */ 
1028        if ((pftmp=tmpOpt->lastField)!=NULL) {
1029          for (j=0; j<pftmp->fieldLength; j++) {
1030            (*myPtrs->offsetV9Ptr)++;
1031          }
1032          pftmp = pftmp->prev;
1033        }
1034      }
1035      while (pftmp != NULL) {
1036        if (pftmp->fieldLength==1){
1037          buffer1 = *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1038        }
1039        if (pftmp->fieldLength==2){
1040          buffer2[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1041          buffer2[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1042        }
1043        if (pftmp->fieldLength==4){
1044          buffer4[3]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1045          buffer4[2]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1046          buffer4[1]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1047          buffer4[0]= *(myPtrs->ptr_buffer+(*myPtrs->offsetV9Ptr)); (*myPtrs->offsetV9Ptr)++;
1048          if (pftmp->fieldType==34||pftmp->fieldType==50){
1049            if ((*((unsigned long*)&buffer4)==1)
1050                || (*((unsigned long*)&buffer4)==10)
1051                || (*((unsigned long*)&buffer4)==100)
1052                || (*((unsigned long*)&buffer4)==1000)) {
1053              if (myPtrs->currentRouterPtr->sampled != *((unsigned long*)&buffer4) ) {
1054#ifdef DEBUGAGG
1055                fprintf(stderr,"\n SV (p) %lu != %lu (r)", *((unsigned long*)&buffer4),
1056                        myPtrs->currentRouterPtr->sampled);
1057#endif
1058                syslog(LOG_INFO,"Sampling value change for router : %lu.%lu.%lu.%lu, old: %lu, new: %lu",
1059                       (myPtrs->pcktPtr->ipH->srcAdd>>24),
1060                       (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
1061                       (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
1062                       (myPtrs->pcktPtr->ipH->srcAdd<<24>>24),
1063                       myPtrs->currentRouterPtr->sampled,
1064                       *((unsigned long*)&buffer4)
1065                       );
1066                myPtrs->currentRouterPtr->sampled = *((unsigned long*)&buffer4);
1067              }
1068            }else{
1069              syslog(LOG_INFO,"Sampling value not standard for router : %lu.%lu.%lu.%lu, value : %lu",
1070                     (myPtrs->pcktPtr->ipH->srcAdd>>24),
1071                     (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
1072                     (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
1073                     (myPtrs->pcktPtr->ipH->srcAdd<<24>>24),
1074                     *((unsigned long*)&buffer4)
1075                     );
1076            }
1077          }
1078        }       
1079        pftmp = pftmp->prev;
1080      }
1081      if ( pftmp == NULL ) {
1082        while ((*myPtrs->offsetV9Ptr)%4 != 0) {
1083          (*myPtrs->offsetV9Ptr)++;
1084#ifdef DEBUG
1085          fprintf(stderr," p ");
1086#endif
1087        }
1088      } else {
1089        fprintf(stderr,"PB ");
1090      }
1091#ifdef DEBUG
1092      fprintf(stderr,">");
1093#endif
1094      return (data_length+shift);
1095    } else {
1096      /*
1097       * template unknown, we skip this all the data
1098       */
1099      (*myPtrs->offsetV9Ptr)+=(data_length-4);
1100      (*myPtrs->currentFlowsetNumberPtr) = myPtrs->currentHeaderV9Ptr->count;
1101#ifdef DEBUG
1102      fprintf(stderr, " U, r: %lu.%lu.%lu.%lu, sourceId: %lu, TID: %hu",
1103              (myPtrs->pcktPtr->ipH->srcAdd>>24),
1104              (myPtrs->pcktPtr->ipH->srcAdd<<8>>24),
1105              (myPtrs->pcktPtr->ipH->srcAdd<<16>>24),
1106              (myPtrs->pcktPtr->ipH->srcAdd<<24>>24),
1107              myPtrs->currentHeaderV9Ptr->sourceId,
1108              (*myPtrs->currentFlowsetIdPtr)
1109              );
1110#endif
1111      return (data_length+shift);
1112    }
1113  }
1114}
Note: See TracBrowser for help on using the browser.