Changeset aa27e1e for examples/capture/capture.c

Timestamp:

10/26/04 16:16:27 (18 years ago)

Author:

Daniel Lawson <dlawson@…>

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:

a6d38b6

Parents:

678048a

Message:

added loss detection to 'capture'

File:

• examples/capture/capture.c (modified) (5 diffs)

examples/capture/capture.c

@@ -52 +52 @@
 typedef enum counter_type {
         BYTES = 0,
-        PACKETS = 1
+        PACKETS = 1,
+        LOSS = 2,
 } counter_type_t;
 
-#define MAXCOUNTERTYPE (PACKETS + 1)
+#define MAXCOUNTERTYPE (LOSS + 1)
 
 uint32_t counter[MAXCOUNTERTYPE];
@@ -70 +71 @@
 
         if (hdrcount >= 10) {
-                printf("Byte count:                     Packet count: \n");
+                printf("Byte count:     Packet count:           Loss count\n");
                 hdrcount = 0;
         }
         hdrcount++;
-        printf("\t\t%d\t\t\t%d \n", 
+        printf("\t\t%d\t\t%d\t\t%d \n", 
                         counter[BYTES],
-                        counter[PACKETS]);
+                        counter[PACKETS],
+                        counter[LOSS]);
         counter[BYTES] = 0;
         counter[PACKETS] = 0;
+        counter[LOSS] = 0;
         docalc=0;
 }
@@ -109 +112 @@
         if (argc == 2) {
                 uri = strdup(argv[1]);
-                filename = "./output";
+                filename = 0;
         }
 
@@ -115 +118 @@
                 uri = strdup(argv[1]);
                 filename = strdup(argv[2]);
+                fout = fopen(filename,"w");
         }
-
-        fout = fopen(filename,"w");
+        
         // create an trace to uri
         trace = trace_create(uri);
@@ -135 +138 @@
                 counter[BYTES] += ntohs(erfptr->rlen);
                 counter[PACKETS] ++;
+                counter[LOSS] += ntohs(erfptr->lctr);
 
                 if(docalc) {
                         secondreport();
                 }
-
-                fwrite(erfptr,psize,1,fout);
+                
+                if (filename) 
+                        fwrite(erfptr,psize,1,fout);