Changeset 3840760


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!)

Files:
23 edited

Legend:

Unmodified
Added
Removed

  • examples/capture/capture.c

    r05e83dc r3840760  
    9898        struct sigaction sigact;
    9999        dag_record_t *erfptr = 0;
    100         struct libtrace_packet_t packet;
     100        struct libtrace_packet_t *packet = trace_packet_create();
    101101
    102102        struct itimerval itv;

  • examples/count/tracestats.c

    r4dd7363 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;

  • examples/erfsplit/erfsplit.c

    r7e9d51c r3840760  
    7575        time_t ts = 0;
    7676        uint64_t number = 0;
    77         struct libtrace_packet_t packet;
     77        struct libtrace_packet_t *packet = trace_packet_create();
    7878        parse_cmdline(argc,argv);
    7979

  • examples/event/rate-tracetime.c

    r264f4469 r3840760  
    100100        int psize = 0;
    101101        struct libtrace_ip *ipptr = 0;
    102         struct libtrace_packet_t packet;
     102        struct libtrace_packet_t *packet = trace_packet_create();
    103103        uint32_t last_second = 0;
    104104        double ts = 0.0;

  • examples/event/rate.c

    re81d1af r3840760  
    105105        struct sigaction sigact;
    106106        struct libtrace_ip *ipptr = 0;
    107         struct libtrace_packet_t packet;
     107        struct libtrace_packet_t *packet = trace_packet_create();
    108108
    109109        struct itimerval itv;

  • examples/munge/munge.c

    r1974620 r3840760  
    177177        struct libtrace_filter_t *filter = NULL;
    178178        struct libtrace_t *trace = 0;
    179         struct libtrace_packet_t packet;
     179        struct libtrace_packet_t *packet = trace_packet_create();
    180180        struct libtrace_out_t *writer = 0;
    181181        bool enc_source = false;

  • examples/pcap2erf/pcap2erf.c

    rb535184 r3840760  
    7272   
    7373    struct pcap_pkthdr *header;
    74     struct libtrace_packet_t packet;
     74    struct libtrace_packet_t *packet = trace_packet_create();
    7575    unsigned long seconds, subseconds;
    7676    unsigned short rlen, lctr, wlen, offset, pad;

  • examples/protocol/protocol.c

    r5ed52b8 r3840760  
    9898
    9999        struct libtrace_ip *ipptr = 0;
    100         struct libtrace_packet_t packet;
     100        struct libtrace_packet_t *packet = trace_packet_create();
    101101       
    102102        int psize;

  • examples/rate/rate-dir.c

    r2cc187b r3840760  
    117117        int direction = 0;
    118118        struct libtrace_ip *ipptr = 0;
    119         struct libtrace_packet_t packet;
     119        struct libtrace_packet_t *packet = trace_packet_create();
    120120       
    121121        uint32_t last_second = 0;

  • examples/rate/rate.c

    r0675ea1 r3840760  
    9595        int psize = 0;
    9696        struct libtrace_ip *ipptr = 0;
    97         struct libtrace_packet_t packet;
     97        struct libtrace_packet_t *packet = trace_packet_create();
    9898
    9999        uint32_t last_second = 0;

  • examples/rxtest/rxtest.c

    r85c7de8 r3840760  
    5353int main(int argc, char **argv) {
    5454
    55         struct libtrace_packet_t packet;
     55        struct libtrace_packet_t *packet = trace_packet_create();
    5656        dag_record_t *erfptr;
    5757       

  • examples/sample/sample.c

    rde67322 r3840760  
    6464        int psize = 0;
    6565        struct libtrace_ip *ipptr = 0;
    66         struct libtrace_packet_t packet;
     66        struct libtrace_packet_t *packet = trace_packet_create();
    6767        struct libtrace_filter_t *filter = 0;
    6868

  • examples/tracedump/tracedump.c

    rf20b30e r3840760  
    3535int main(int argc, char *argv[]) {
    3636
    37         struct libtrace_packet_t packet;
     37        struct libtrace_packet_t *packet = trace_packet_create();
    3838        struct libtrace_t *trace;
    3939

  • examples/tracemark/tracemark.c

    redca0b8 r3840760  
    5858void run_trace(char *uri)
    5959{
    60         struct libtrace_packet_t packet;
     60        struct libtrace_packet_t *packet = trace_packet_create();
    6161        uint64_t count = 0;
    6262        uint64_t bytes = 0;

  • lib/format_wag.c

    r14d8a63 r3840760  
    323323                packet->status.message = 0;
    324324                packet->header = packet->buffer;
    325                 packet->payload = packet->buffer + pcap_get_framing_length(packet);
     325                packet->payload = packet->buffer + trace_get_framing_length(packet);
    326326                packet->size = numbytes;
    327327                return numbytes;

  • libpacketdump/libpacketdump.cc

    re3b0188 r3840760  
    6464
    6565        printf("%s",ctime(&sec));
    66         decode_next(link,packet->size-(link-packet->buffer),"link",trace_get_link_type(packet));
     66        decode_next(link,packet->size - trace_get_framing_length(packet),"link",trace_get_link_type(packet));
    6767}
    6868

  • 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.