Changeset b535184 for examples


Ignore:
Timestamp:
08/05/04 16:14:07 (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:
2137b49
Parents:
9729a8d
Message:

updated examples to use 1.1.0 api

Location:
examples
Files:
6 edited

Legend:

Unmodified
Added
Removed
  • examples/pcap2erf/Makefile

    r167adf2 rb535184  
    1 include= /usr/local/dag-2.4.11/include
    2 dagcdir= /usr/local/dag-2.4.11/utils/
     1include= /usr/local/dag/include
     2dagcdir= /usr/local/dag/utils/
    33
    44CC=g++-3.0
  • examples/pcap2erf/pcap2erf.c

    ra79ddbe rb535184  
    4646#include <linux/if_ether.h>
    4747
    48 extern "C" {
     48//extern "C" {
    4949#include "dagformat.h"
    5050#include "libtrace.h"
    51 }
     51//}
    5252
    5353struct libtrace_t *trace;
     
    6666int main(int argc, char *argv[]) {
    6767
    68     char *hostname;
     68    char *uri;
    6969    int psize = 0;
    70     int status = 0;
    7170    char *filename;
    7271    FILE* input;
    7372   
    7473    struct pcap_pkthdr *header;
     74    struct libtrace_packet_t packet;
    7575    unsigned long seconds, subseconds;
    7676    unsigned short rlen, lctr, wlen, offset, pad;
     
    8080    uint32_t netmask = 0;
    8181    int data_size;
    82     struct tcphdr *tcpptr = 0;
     82    struct libtrace_tcp *tcpptr = 0;
    8383    int octets[4];
    8484    int hlen;
    85     ip *ipptr;
     85    struct libtrace_ip *ipptr;
    8686
    8787   
    8888    // 2 parameters only, both neccessary
    8989    if (argc == 3) {
    90         hostname = strdup(argv[1]);
     90        uri = strdup(argv[1]);
    9191        filename = strdup(argv[2]);
    9292    }
     
    159159    //----------------------------------------------------------------------
    160160
    161     // create an trace to hostname, on the default port
    162     trace = create_trace(hostname);
     161    // create an trace to the given uri
     162    trace = trace_create(uri);
    163163
    164164    for (;;) {
    165         if ((psize = libtrace_read_packet(trace, buffer,SCANSIZE, &status))
     165        if ((psize = trace_read_packet(trace, &packet))
    166166                == -1) {
    167167            // terminate
     
    169169        }
    170170        // buffer returned is pcap-->ethernet-->upperlayers
    171         header = (struct pcap_pkthdr*) buffer;
     171        header = (struct pcap_pkthdr*)packet.buffer;
    172172
    173173        // if this isnt an ip packet, ignore it
    174         if(! ((buffer + sizeof(struct pcap_pkthdr))[12] == 8 &&
    175             (buffer + sizeof(struct pcap_pkthdr))[13] == 0))
     174        if(! ((packet.buffer + sizeof(struct pcap_pkthdr))[12] == 8 &&
     175            (packet.buffer + sizeof(struct pcap_pkthdr))[13] == 0))
    176176            continue;
    177177       
    178         ipptr = (ip *)(buffer + (sizeof(uint8_t)*30));// wtf is 30
     178
     179        ipptr = trace_get_ip(&packet);
    179180        hlen = ipptr->ip_hl*4;
    180181
     
    183184        {
    184185            case 1: data_size = 14 + hlen; break;
    185             case 6: tcpptr = (struct tcphdr *) ((uint8_t *)ipptr + hlen);
     186            case 6: tcpptr = (struct libtrace_tcp *) ((uint8_t *)ipptr + hlen);
    186187                    data_size = 14 + hlen + (tcpptr->doff*4); break;
    187188            case 17: data_size = 14 + hlen + 8; break;
     
    244245
    245246        // write as much of the packet as we need (just the headers)
    246         fwrite(buffer + sizeof(pcap_pkthdr), 1, data_size, stdout);
    247     }
    248 
    249     destroy_trace(trace);
     247        fwrite(packet.buffer + sizeof(pcap_pkthdr), 1, data_size, stdout);
     248    }
     249
     250    trace_destroy(trace);
    250251    return 0;
    251252}
  • examples/protocol/protocol.c

    ra257602 rb535184  
    9797
    9898        struct libtrace_ip *ipptr = 0;
    99         dag_record_t *erfptr = 0;
     99        struct libtrace_packet_t packet;
    100100       
    101         int status;
    102101        int psize;
    103102
    104103        parse_cmdline(argc,argv);
    105104
    106         trace = create_trace(uri);
     105        trace = trace_create(uri);
    107106        if (filterstring) {
    108                 filter = libtrace_bpf_setfilter(filterstring);
     107                filter = trace_bpf_setfilter(filterstring);
    109108        }
    110109
    111110        for (;;) {
    112                 if ((psize = libtrace_read_packet(trace, buffer,4096, &status)) <= 0) {
     111                if ((psize = trace_read_packet(trace, &packet)) <= 0) {
    113112                        // terminate
    114113                        break;
    115114                }
    116                 erfptr = (dag_record_t *)buffer;
    117                
    118                 if (erfptr->flags.rxerror) {
    119                         rxerr ++;
    120                         continue;
    121                 }
     115
    122116                if (filter) {
    123                         if (!libtrace_bpf_filter(trace, filter, buffer, 4096)) {
     117                        if (!trace_bpf_filter(filter,&packet)) {
    124118                        continue;
    125119                        }
    126120                }
    127                 ipptr = get_ip(trace,buffer,4096);
     121                ipptr = trace_get_ip(&packet);
    128122
    129123                if (ipptr) {
     
    133127                                badchksum ++;
    134128                        } else {
    135                                 printf("%d:%d\n",ipptr->ip_p,get_link_type(trace,buffer,4096));
     129                                printf("%d:%d\n",ipptr->ip_p,trace_get_link_type(&packet));
    136130                        }
    137131                }
     
    141135                printf("RX Errors seen: %llu\n",rxerr);
    142136        }
    143         destroy_trace(trace);
     137        trace_destroy(trace);
    144138        return 0;
    145139}
  • examples/rate/rate.c

    re9f521e rb535184  
    9696int main(int argc, char *argv[]) {
    9797
    98         char *hostname = 0;
     98        char *uri = 0;
    9999        int psize = 0;
    100         int status = 0;
    101100        struct sigaction sigact;
    102101        struct libtrace_ip *ipptr = 0;
     102        struct libtrace_packet_t packet;
    103103
    104104        struct itimerval itv;
     
    119119
    120120        if (argc == 2) {
    121                 hostname = strdup(argv[1]);
     121                uri = strdup(argv[1]);
    122122        }
    123123
    124         // create an trace to hostname, on the default port
    125         trace = create_trace(hostname);
     124        // create an trace to uri
     125        trace = trace_create(uri);
    126126
    127127
    128128        for (;;) {
    129                 if ((psize = libtrace_read_packet(trace, buffer,SCANSIZE, &status)) == -1) {
     129                if ((psize = trace_read_packet(trace,&packet)) == -1) {
    130130                        // terminate
    131131                        break;
     
    137137                //erfptr = (dag_record_t *)buffer;
    138138                //ipptr = (struct ip *)erfptr->rec.eth.pload;
    139                 if((ipptr = get_ip(trace,buffer,SCANSIZE)) == 0) {
     139                if((ipptr = trace_get_ip(&packet)) == 0) {
    140140                        continue;
    141141                }
     
    151151        }
    152152
    153         destroy_trace(trace);
     153        trace_destroy(trace);
    154154        return 0;
    155155}
  • examples/sample/Makefile

    r2c060e3 rb535184  
    11
    2 wand_include = /usr/local/wand/include
    3 wand_libs = /usr/local/wand/lib
     2libtrace_include = /usr/local/wand/include
     3libtrace_libs = /usr/local/wand/lib
    44
    55CC=gcc-3.0
    66
    7 INCLUDE = -I../include -I$(wand_include)
     7INCLUDE =  -I$(libtrace_include)
    88CFLAGS = -Wall -Wimplicit -Wformat -pipe -g -O2
    99CFLAGS += $(INCLUDE)
    10 libdir = -L$(wand_libs)
     10libdir = -L$(libtrace_libs)
    1111LDLIBS = $(libdir) -ltrace
    1212
  • examples/sample/sample.c

    re9f521e rb535184  
    6262        int status = 0;
    6363        struct libtrace_ip *ipptr = 0;
     64        struct libtrace_packet_t packet;
    6465
    6566        if (argc == 2) {
     
    6869
    6970        // open a trace
    70         trace = create_trace(uri);
     71        trace = trace_create(uri);
     72       
    7173
    7274        for (;;) {
    7375                unsigned char *x;
    7476                int i;
    75                 if ((psize = libtrace_read_packet(trace, buffer, SCANSIZE, &status)) <1) {
     77                if ((psize = trace_read_packet(trace, &packet)) <1) {
    7678                        break;
    7779                }
    7880
    79                 printf("TS %f: ",get_seconds(trace,buffer,SCANSIZE));
     81                printf("TS %f: ",trace_get_seconds(&packet));
    8082
    81                 ipptr = get_ip(trace,buffer,SCANSIZE);
     83                ipptr = trace_get_ip(&packet);
    8284                if (!ipptr) {
    8385                        printf("Non IP\n");
     
    9092                                        ipptr->ip_p);
    9193                x=(void*)ipptr;
    92                 for(i=0;i<get_capture_length(trace,buffer,SCANSIZE);i++) {
     94                for(i=0;i<trace_get_capture_length(&packet);i++) {
    9395                        if (i%4==0 && i!=0)
    9496                                printf("\n");
     
    98100        }
    99101
    100         destroy_trace(trace);
     102        trace_destroy(trace);
    101103        return 0;
    102104}
Note: See TracChangeset for help on using the changeset viewer.