Changeset 85

Show
Ignore:
Timestamp:
11/19/08 12:07:14 (14 years ago)
Author:
andreu
Message:

#ticket 24

Files:
1 modified

Legend:

Unmodified
Added
Removed
  • trunk/src/dataFlowSet.c

    r84 r85  
    293293              } 
    294294              if ((pftmp->fieldType==10)||(pftmp->fieldType==14)){ 
    295                 if ((((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.lvalue)  
    296                     == (*((unsigned long*)&buffer4))) 
     295                if ((((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->value->stor.svalue)  
     296                    == ((unsigned short)*((unsigned long*)&buffer4))) 
    297297                  { 
    298298                    ((RuleDefPtr)(*(myPtrs->rulesAddressPtr+pos)))->check = 1; 
     
    313313              } 
    314314#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP) 
     315              if (pftmp->fieldType==10){ 
     316                agCache.inputSnmp = (unsigned short)*((unsigned long*)&buffer4); 
     317              } 
     318              if (pftmp->fieldType==14){ 
     319                agCache.outputSnmp = (unsigned short)*((unsigned long*)&buffer4); 
     320              }  
    315321              if ((pftmp->fieldType==8)){ 
    316322                bool = 1; /* very important, test if we have an IPv4 flow for Agg */ 
     
    550556          (*myPtrs->offsetV9Ptr)++; 
    551557#if defined(IPV4AGGIDR) || defined(IPV4AGGIDSNMP) 
     558          if (pftmp->fieldType==10){ 
     559            agCache.inputSnmp = (unsigned short)*((unsigned long*)&buffer4); 
     560          } 
     561          if (pftmp->fieldType==14){ 
     562            agCache.outputSnmp = (unsigned short)*((unsigned long*)&buffer4); 
     563          }  
    552564          if ((pftmp->fieldType==8)){ 
    553565            bool = 1; 
     
    668680            } 
    669681#ifdef DEBUG 
    670             fprintf(stderr,"S %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu\n", 
     682            fprintf(stderr,"S %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu SNMPin(hu) %hu\n", 
    671683                    (agCache.v4AdS>>24), 
    672684                    (agCache.v4AdS<<8>>24),  
     
    680692                    (agCache.maskD), 
    681693                    myPtrs->currentRouterPtr->sampled, 
    682                     res->sampling); 
     694                    res->sampling, 
     695                    agCache.inputSnmp); 
    683696#endif 
    684697#if defined(IPV4AGGIDR) 
     
    725738                  } 
    726739#ifdef DEBUG 
    727             fprintf(stderr,"S&D %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu\n", 
     740            fprintf(stderr,"S&D %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu SNMPin %hu\n", 
    728741                    (agCache.v4AdS>>24), 
    729742                    (agCache.v4AdS<<8>>24),  
     
    737750                    (agCache.maskD), 
    738751                    myPtrs->currentRouterPtr->sampled, 
    739                     res3->sampling); 
     752                    res3->sampling, 
     753                    agCache.inputSnmp); 
    740754#endif 
    741755#if defined(MULTISAMPLING) 
     
    817831              } 
    818832#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", 
     833            fprintf(stderr,"D %lu.%lu.%lu.%lu/%hu %lu.%lu.%lu.%lu/%hu Rs %lu Ps %lu R@ %lu.%lu.%lu.%lu SNMPin %hu\n", 
    820834                    (agCache.v4AdS>>24), 
    821835                    (agCache.v4AdS<<8>>24),  
     
    833847                    (myPtrs->pcktPtr->ipH->srcAdd<<8>>24), 
    834848                    (myPtrs->pcktPtr->ipH->srcAdd<<16>>24), 
    835                     (myPtrs->pcktPtr->ipH->srcAdd<<24>>24)); 
     849                    (myPtrs->pcktPtr->ipH->srcAdd<<24>>24), 
     850                    agCache.inputSnmp); 
    836851#endif 
    837852#if defined(IPV4AGGIDSNMP)