Changeset 83 for trunk/src/dataFlowSet.c

Show
Ignore:
Timestamp:
11/06/08 16:37:23 (14 years ago)
Author:
andreu
Message:

release tag 0.0.13beta ; beginning of multisampling implementation

Files:
1 modified

Legend:

Unmodified
Added
Removed
  • trunk/src/dataFlowSet.c

    r80 r83  
    672672              if ( myPtrs->currentRouterPtr->snmpIndexList[agCache.inputSnmp] == 1  ) {        
    673673#endif 
     674 
     675                /* OUT ("traffic from the prefix/subnet")  */ 
     676#if defined(MULTISAMPLING) 
     677                if (myPtrs->currentRouterPtr->sampled != res->sampling ){ 
     678                  res->bytesNbOUT += agCache.bytes*myPtrs->currentRouterPtr->sampled/res->sampling; 
     679                  res->pktsNbOUT += agCache.pkts*myPtrs->currentRouterPtr->sampled/res->sampling; 
     680                  /* (res->flowNbOUT)++; FIXME : FIND SOMETHING*/ 
     681                }else{ 
     682                  res->bytesNbOUT += agCache.bytes; 
     683                  res->pktsNbOUT += agCache.pkts; 
     684                  (res->flowNbOUT)++;              
     685                } 
     686#else 
    674687                if (myPtrs->currentRouterPtr->sampled != 0 ){ 
    675                   /* OUT ("traffic from the prefix/subnet")  */ 
    676688                  res->bytesNbOUT += agCache.bytes; 
    677689                  res->pktsNbOUT += agCache.pkts; 
     
    682694                  res->sampling = myPtrs->currentRouterPtr->sampled; 
    683695                } 
     696#endif 
    684697#if defined(IPV4AGGIDSNMP) 
    685698                prefixKey.beginning = agCache.v4AdD>>(32-agCache.maskD)<<(32-agCache.maskD); 
     
    697710                    } 
    698711                  } 
     712#if defined(MULTISAMPLING) 
     713                  if (myPtrs->currentRouterPtr->sampled != res3->sampling ){ 
     714                    res3->bytesNbIN += agCache.bytes*myPtrs->currentRouterPtr->sampled/res3->sampling; 
     715                    res3->pktsNbIN += agCache.pkts*myPtrs->currentRouterPtr->sampled/res3->sampling; 
     716                    /* (res3->flowNbIN)++;  FIXME : FIND SOMETHING */ 
     717                  }else{ 
     718                    res3->bytesNbIN += agCache.bytes; 
     719                    res3->pktsNbIN += agCache.pkts; 
     720                    (res3->flowNbIN)++; 
     721                  } 
     722#else 
    699723                  if (myPtrs->currentRouterPtr->sampled != 0 ){ 
    700724                    /* IN ("traffic to the prefix/subnet")  */ 
     
    707731                    res3->sampling = myPtrs->currentRouterPtr->sampled; 
    708732                  } 
     733#endif 
    709734                } 
    710735#endif