Changeset d4336d5 for tools/tracereport/port_report.c

Timestamp:

02/21/07 14:39:26 (14 years ago)

Author:

Shane Alcock <salcock@…>

Branches:

4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, getfragoff, help, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes

Children:

09be643

Parents:

c14602f

Message:

Updated tracereport to include all the work Josef has done

File:

• tools/tracereport/port_report.c (modified) (5 diffs)

tools/tracereport/port_report.c

@@ -8 +8 @@
 #include "tracereport.h"
 #include "contain.h"
-#include "report.h"
 
-stat_t ports[256][65536]={{{0,0}}};
+stat_t ports[4][256][65536]={{{{0,0}}}};
 char protn[256]={0};
+static bool suppress[4] = {true,true,true,true};
 
 void port_per_packet(struct libtrace_packet_t *packet)
@@ -17 +17 @@
         uint8_t proto;
         int port;
-
+        int dir = trace_get_direction(packet);
+        if(dir < 0 || dir > 1)
+                dir = 2;
         if(trace_get_transport(packet,&proto,NULL)==NULL) 
                 return;
@@ -27 +29 @@
                 : trace_get_destination_port(packet);
 
-        ports[proto][port].bytes+=trace_get_wire_length(packet);
-        ports[proto][port].count++;
+        ports[dir][proto][port].bytes+=trace_get_wire_length(packet);
+        ports[dir][proto][port].count++;
         protn[proto]=1;
+        suppress[dir] = false;
 }
 
-static void port_port(int i,char *prot, int j)
+void port_suppress()
+{
+        int i;
+        printf("%-20s","Direction:");
+        //printf("%20s", " ");
+        for(i=0;i<4;i++){
+                if(!suppress[i]){
+                        switch(i){
+                                case 0:
+                                        printf("\t%24s", "Outbound   ");
+                                        break;
+                                case 1:
+                                        printf("\t%24s", "Inbound   ");
+                                        break;
+                                case 2:
+                                        printf("\t%24s", "Undefined   ");
+                                        break;
+                                default:
+                                        break;
+                        }
+                }
+        }
+        printf("\n");
+        printf("%-20s","Port");
+        for(i=0;i<4;i++){
+                if(!suppress[i]){
+                        printf("\t%12s\t%12s", "bytes","packets");
+                }
+        }
+        printf("\n");
+}
+
+void port_port(int i,char *prot, int j)
 {
         struct servent *ent = getservbyport(htons(j),prot);
-        if(ent)
-                printf("%20s:\t%12" PRIu64 "\t%12" PRIu64 "\n",
-                                ent->s_name,
-                                ports[i][j].bytes,
-                                ports[i][j].count
+        int k;
+        
+        if(ent){
+                printf("%20s:",ent->s_name);
+                for(k=0;k<4;k++){
+                        if (ports[k][i][j].count==0){
+                                if(!suppress[k])
+                                        printf("\t%24s"," ");
+                                continue;
+                        }
+                        printf("\t%12" PRIu64 "\t%12" PRIu64,
+                                ports[k][i][j].bytes,
+                                ports[k][i][j].count
                       );
-        else
-                printf("%20i:\t%12" PRIu64 "\t%12" PRIu64 "\n",
-                                j,
-                                ports[i][j].bytes,
-                                ports[i][j].count
+                }
+        }
+        else{
+                printf("%20i:",j);
+                for(k=0;k<4;k++){
+                        if (ports[k][i][j].count==0){
+                                if(!suppress[k])
+                                        printf("\t%24s"," ");
+                                continue;
+                        }
+                        printf("\t%12" PRIu64 "\t%12" PRIu64,
+                                ports[k][i][j].bytes,
+                                ports[k][i][j].count
                       );
+                }
+        }
+        printf("\n");
 }
 
-static void port_protocol(int i)
+void port_protocol(int i)
 {
-        int j;
+        int j,k;
         struct protoent *ent = getprotobynumber(i);
         printf("Protocol: %i %s%s%s\n",i,
                         ent?"(":"",ent?ent->p_name:"",ent?")":"");
         for(j=0;j<65536;++j) {
-                if (ports[i][j].count) {
-                        port_port(i,ent?ent->p_name:"",j);
+                for(k=0;k<4;k++){
+                        if (ports[k][i][j].count) {
+                                port_port(i,ent?ent->p_name:"",j);
+                                break;
+                        }
                 }
         }
@@ -66 +123 @@
         int i;
         printf("# Port breakdown:\n");
-        printf("%-20s \t%12s\t%12s\n","Port","Bytes","Packets");
+        port_suppress();
         setservent(1);
         setprotoent(1);
@@ -76 +133 @@
         endprotoent();
         endservent();
+        
+        int total, j,k;
+        for(i=0;i<4;i++){
+                total = 0;
+                for(j=0;j<256;j++)
+                        for(k=0;k<65536;k++)
+                                total += ports[i][j][k].count;
+                //printf("%s: %i\n", "Total", total);
+        }
 }