Changeset 96 for trunk/src/dataFlowSet.c

Show
Ignore:
Timestamp:
02/12/09 17:54:45 (14 years ago)
Author:
andreu
Message:

IPV6 links aggregation UP

Files:
1 modified

Legend:

Unmodified
Added
Removed
  • trunk/src/dataFlowSet.c

    r95 r96  
    10871087#ifdef IPV6LINKAGG 
    10881088        if ( ( isIPv6 == 1 ) && (isMplsFlow == 0) ){ 
    1089           for (i=0; i<MAX_INDEX_BY_ROUTER; i++){ /* FIXME : to optimized */ 
    1090             if (agCache.inputSnmp == myPtrs->currentRouterPtr->snmpIndexID[i] ) { 
    1091               break; 
    1092             } 
    1093           } 
    1094           /* FIXME : here we need to make two case switch sampling values !!! */ 
    10951089          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
    10961090                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
    1097                               +(agCache.inputSnmp)))->bytesNbIN = agCache.bytes; 
    1098           for (i=0; i<MAX_INDEX_BY_ROUTER; i++){ /* FIXME : to optimized */ 
    1099             if (agCache.outputSnmp == myPtrs->currentRouterPtr->snmpIndexID[i] ) { 
    1100               break; 
    1101             } 
    1102           } 
     1091                              +(agCache.inputSnmp)))->routerIPAddress = myPtrs->currentRouterPtr->IpAddress; 
    11031092          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
    11041093                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
    1105                               +(agCache.outputSnmp)))->bytesNbOUT = agCache.bytes; 
     1094                              +(agCache.inputSnmp)))->indexSNMP = agCache.inputSnmp; 
     1095          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1096                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1097                              +(agCache.outputSnmp)))->indexSNMP = agCache.outputSnmp;  
     1098          /* FIXME, error or warning if (indexSNMP != agCache.outputSnmp) */ 
     1099          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1100                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1101                              +(agCache.inputSnmp)))->hasStats = 1; 
     1102          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1103                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1104                              +(agCache.outputSnmp)))->hasStats = 1; 
     1105          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1106                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1107                              +(agCache.inputSnmp)))->bytesNbIN += agCache.bytes; 
     1108          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1109                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1110                              +(agCache.outputSnmp)))->bytesNbOUT += agCache.bytes; 
     1111          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1112                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1113                              +(agCache.inputSnmp)))->pktsNbIN += agCache.pkts; 
     1114          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1115                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1116                              +(agCache.outputSnmp)))->pktsNbOUT += agCache.pkts; 
     1117          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1118                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1119                              +(agCache.inputSnmp)))->flowNbIN++; 
     1120          ((struct IndexV6 *)((myPtrs->currentV6IndexTab) 
     1121                              +((myPtrs->currentRouterPtr->ID)*ROUTER_INDEX_MAX) 
     1122                              +(agCache.outputSnmp)))->flowNbOUT++; 
    11061123          isIPv6 = 0; 
    1107           fprintf(stderr,"IPV6LINKAGG .%hu -> .%hu , router : %lu\n", 
    1108                  agCache.inputSnmp, 
    1109                  agCache.outputSnmp, 
    1110                  myPtrs->currentRouterPtr->IpAddress 
    1111                  ); 
     1124/*        fprintf(stderr,"IPV6LINKAGG;IN;%hu;OUT;%hu;router;%lu;bytes;%lu\n", */ 
     1125/*                agCache.inputSnmp, */ 
     1126/*                agCache.outputSnmp, */ 
     1127/*                myPtrs->currentRouterPtr->IpAddress, */ 
     1128/*                agCache.bytes */ 
     1129/*               ); */ 
    11121130        } 
    11131131#endif /* IPV6LINKAGG */