Changeset 3840760 for tools


Ignore:
Timestamp:
11/28/05 10:15:22 (16 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:
08594b8
Parents:
14d8a63
Message:

updated the examples/ and tools/ directories to correctly use trace_packet_create() now.

fixed a typo in format_wag (shouldn't use pcap_get_framing_length for wag!)

Location:
tools
Files:
7 edited

Legend:

Unmodified
Added
Removed
  • tools/traceanon/traceanon.c

    rca52edd r3840760  
    100100        char *key = NULL;
    101101        struct libtrace_t *trace = 0;
    102         struct libtrace_packet_t packet;
     102        struct libtrace_packet_t *packet = trace_packet_create();
    103103        struct libtrace_out_t *writer = 0;
    104104        bool enc_source = false;
     
    178178                struct libtrace_ip *ipptr;
    179179                int psize;
    180                 if ((psize = trace_read_packet(trace, &packet)) <= 0) {
     180                if ((psize = trace_read_packet(trace, packet)) <= 0) {
    181181                        break;
    182182                }
    183183
    184                 ipptr = trace_get_ip(&packet);
     184                ipptr = trace_get_ip(packet);
    185185
    186186                if (ipptr && (enc_source || enc_dest))
     
    189189                /* TODO: Encrypt IP's in ARP packets */
    190190
    191                 trace_write_packet(writer,&packet);
     191                trace_write_packet(writer,packet);
    192192        }
    193193        return 0;
  • tools/tracedump/tracedump.cc

    r0c9681f r3840760  
    2020{
    2121        struct libtrace_t *trace = NULL;
    22         struct libtrace_packet_t packet;
     22        struct libtrace_packet_t *packet = trace_packet_create();
    2323        struct libtrace_filter_t *filter=NULL;
    2424        uint64_t count=0;
     
    6565                }
    6666
    67                 while(trace_read_packet(trace,&packet)> 0 ){
    68                         if (filter && !trace_bpf_filter(filter,&packet))
     67                while(trace_read_packet(trace,packet)> 0 ){
     68                        if (filter && !trace_bpf_filter(filter,packet))
    6969                                continue;
    7070
    71                         trace_dump_packet(&packet);
     71                        trace_dump_packet(packet);
    7272                        if(count) {
    7373                                numpackets++;
  • tools/tracemerge/tracemerge.c

    rb297e50 r3840760  
    1919        struct libtrace_out_t *output;
    2020        struct libtrace_t **input;
    21         struct libtrace_packet_t *packet;
     21        struct libtrace_packet_t **packet;
    2222        bool *live;
    2323        bool set_interface=false;
     
    5757
    5858        input=calloc((argc-optind),sizeof(struct libtrace_t *));
    59         packet=calloc((argc-optind),sizeof(struct libtrace_packet_t));
     59        packet=calloc((argc-optind),sizeof(struct libtrace_packet_t *));
    6060        live=calloc((argc-optind),sizeof(bool));
    6161        for(i=0;i<argc-optind;++i) {
    6262                struct libtrace_t *f;
    63                 struct libtrace_packet_t p;
     63                struct libtrace_packet_t *p;
    6464                f=trace_create(argv[i+optind]);
     65                p=trace_packet_create();
    6566                input[i]=f;
     67                packet[i]=p;
    6668                if (!input[i]) {
    6769                        fprintf(stderr,"Could not read %s\n",argv[i+optind]);
    6870                        return 1;
    6971                }
    70                 trace_read_packet(f,&p);
     72                trace_read_packet(f,p);
    7173        }
    7274
     
    7678                for(i=0;i<argc-2;++i) {
    7779                        if (!live[i] && input[i]) {
    78                                 int ret=trace_read_packet(input[i],&packet[i]);
     80                                int ret=trace_read_packet(input[i],packet[i]);
    7981                                if (ret<0) {
    8082                                        /* Error */
     
    9395                        if (live[i] &&
    9496                                (oldest==-1 ||
    95                                  oldest_ts<trace_get_erf_timestamp(&packet[i]))) {
     97                                 oldest_ts<trace_get_erf_timestamp(packet[i]))) {
    9698                                oldest=i;
    97                                 oldest_ts=trace_get_erf_timestamp(&packet[i]);
     99                                oldest_ts=trace_get_erf_timestamp(packet[i]);
    98100                        }
    99101                }
     
    104106
    105107                if (set_interface)
    106                         trace_set_direction(&packet[oldest],oldest);
    107                 trace_write_packet(output,&packet[oldest]);
     108                        trace_set_direction(packet[oldest],oldest);
     109                trace_write_packet(output,packet[oldest]);
    108110                live[oldest]=false;
    109111               
  • tools/tracereport/tracereport.c

    re3b0188 r3840760  
    6161void run_trace(char *uri)
    6262{
    63         struct libtrace_packet_t packet;
     63        struct libtrace_packet_t *packet = trace_packet_create();
    6464
    6565        fprintf(stderr,"%s:\n",uri);
     
    6969        for (;;) {
    7070                int psize;
    71                 if ((psize = trace_read_packet(trace, &packet)) <1) {
     71                if ((psize = trace_read_packet(trace, packet)) <1) {
    7272                        break;
    7373                }
    7474
    75                 error_per_packet(&packet);
    76                 port_per_packet(&packet);
    77                 protocol_per_packet(&packet);
    78                 tos_per_packet(&packet);
    79                 ttl_per_packet(&packet);
    80                 flow_per_packet(&packet);
    81                 dir_per_packet(&packet);
     75                error_per_packet(packet);
     76                port_per_packet(packet);
     77                protocol_per_packet(packet);
     78                tos_per_packet(packet);
     79                ttl_per_packet(packet);
     80                flow_per_packet(packet);
     81                dir_per_packet(packet);
    8282
    8383        }
  • tools/tracertstats/tracertstats.c

    re3b0188 r3840760  
    9191void run_trace(char *uri)
    9292{
    93         struct libtrace_packet_t packet;
     93        struct libtrace_packet_t *packet = trace_packet_create();
    9494        int i;
    9595        uint64_t count = 0;
     
    116116        for (;;) {
    117117                int psize;
    118                 if ((psize = trace_read_packet(trace, &packet)) <1) {
     118                if ((psize = trace_read_packet(trace, packet)) <1) {
    119119                        break;
    120120                }
    121                 ts = trace_get_seconds(&packet);
     121                ts = trace_get_seconds(packet);
    122122
    123123                for(i=0;i<filter_count;++i) {
    124                         if(trace_bpf_filter(filters[i].filter,&packet)) {
     124                        if(trace_bpf_filter(filters[i].filter,packet)) {
    125125                                ++filters[i].count;
    126                                 filters[i].bytes+=trace_get_wire_length(&packet);
     126                                filters[i].bytes+=trace_get_wire_length(packet);
    127127                        }
    128128                }
    129129
    130130                ++count;
    131                 bytes+=trace_get_wire_length(&packet);
     131                bytes+=trace_get_wire_length(packet);
    132132
    133133                if (packet_interval!=UINT64_MAX
  • tools/tracesplit/tracesplit.c

    re3b0188 r3840760  
    4444        struct libtrace_out_t *output = NULL;
    4545        struct libtrace_t *input;
     46        struct libtrace_packet_t *packet = trace_packet_create();
    4647        uint64_t count=UINT64_MAX;
    4748        uint64_t bytes=UINT64_MAX;
     
    106107
    107108        while(1) {
    108                 struct libtrace_packet_t packet;
    109                 if (trace_read_packet(input,&packet)<1) {
     109                if (trace_read_packet(input,packet)<1) {
    110110                        break;
    111111                }
    112112
    113113
    114                 if (filter && !trace_bpf_filter(filter,&packet)) {
     114                if (filter && !trace_bpf_filter(filter,packet)) {
    115115                        continue;
    116116                }
    117117
    118                 if (trace_get_seconds(&packet)<starttime) {
     118                if (trace_get_seconds(packet)<starttime) {
    119119                        continue;
    120120                }
    121121
    122                 if (trace_get_seconds(&packet)>endtime) {
     122                if (trace_get_seconds(packet)>endtime) {
    123123                        break;
    124124                }
    125125
    126126                if (firsttime==0) {
    127                         firsttime=trace_get_seconds(&packet);
     127                        firsttime=trace_get_seconds(packet);
    128128                }
    129129
    130                 if (output && trace_get_seconds(&packet)>firsttime+interval) {
     130                if (output && trace_get_seconds(packet)>firsttime+interval) {
    131131                        trace_output_destroy(output);
    132132                        output=NULL;
     
    140140                }
    141141
    142                 totbytes+=trace_get_capture_length(&packet);
     142                totbytes+=trace_get_capture_length(packet);
    143143                if (output && totbytes-totbyteslast>=bytes) {
    144144                        trace_output_destroy(output);
     
    167167                }
    168168
    169                 trace_write_packet(output,&packet);
     169                trace_write_packet(output,packet);
    170170        }
    171171
  • tools/tracestats/tracestats.c

    r130a0e4 r3840760  
    6868void run_trace(char *uri)
    6969{
    70         struct libtrace_packet_t packet;
     70        struct libtrace_packet_t *packet = trace_packet_create();
    7171        int i;
    7272        uint64_t count = 0;
     
    7979        for (;;) {
    8080                int psize;
    81                 if ((psize = trace_read_packet(trace, &packet)) <1) {
     81                if ((psize = trace_read_packet(trace, packet)) <1) {
    8282                        break;
    8383                }
    8484
    8585                for(i=0;i<filter_count;++i) {
    86                         if(trace_bpf_filter(filters[i].filter,&packet)) {
     86                        if(trace_bpf_filter(filters[i].filter,packet)) {
    8787                                ++filters[i].count;
    88                                 filters[i].bytes+=trace_get_wire_length(&packet);
     88                                filters[i].bytes+=trace_get_wire_length(packet);
    8989                        }
    9090                }
    9191
    9292                ++count;
    93                 bytes+=trace_get_wire_length(&packet);
     93                bytes+=trace_get_wire_length(packet);
    9494        }
    9595
Note: See TracChangeset for help on using the changeset viewer.