Changeset da8b03e


Ignore:
Timestamp:
08/04/05 17:42:41 (15 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:
df2dff9
Parents:
77bd94f
Message:

used macros to improve readability

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/format_erf.c

    ref55d05 rda8b03e  
    6464#define CONNINFO libtrace->format_data->conn_info
    6565#define INPUT libtrace->format_data->input
     66#define OUTPUT libtrace->format_data->output
    6667#define DAG libtrace->format_data->dag
     68#define OPTIONS libtrace->format_data->options
    6769struct libtrace_format_data_t {
    6870        union {
     
    275277                calloc(1,sizeof(struct libtrace_format_data_out_t));
    276278
    277         libtrace->format_data->options.erf.level = 1;
    278         asprintf(&filemode,"wb%d",libtrace->format_data->options.erf.level);
     279        OPTIONS.erf.level = 1;
     280        asprintf(&filemode,"wb%d",OPTIONS.erf.level);
    279281
    280282        if (!strncmp(libtrace->uridata,"-",1)) {
     
    314316        // extract conn_info from uridata
    315317        if (strlen(uridata) == 0) {
    316                 libtrace->conn_info.rt.hostname = NULL;
    317                 libtrace->conn_info.rt.port = COLLECTOR_PORT;
     318                CONNINFO.rt.hostname = NULL;
     319                CONNINFO.rt.port = COLLECTOR_PORT;
    318320        }
    319321        else {
    320322                if ((scan = strchr(uridata,':')) == NULL) {
    321                         libtrace->conn_info.rt.hostname =
     323                        CONNINFO.rt.hostname =
    322324                                NULL;
    323                         libtrace->conn_info.rt.port =
     325                        CONNINFO.rt.port =
    324326                                atoi(uridata);
    325327                } else {
    326                         libtrace->format_data->conn_info.rt.hostname =
     328                        CONNINFO.rt.hostname =
    327329                                (char *)strndup(uridata,
    328330                                                (scan - uridata));
    329                         libtrace->format_data->conn_info.rt.port =
     331                        CONNINFO.rt.port =
    330332                                atoi(++scan);
    331333                }
     
    333335       
    334336       
    335         libtrace->format_data->output.rtserver =
    336                 rtserver_create(libtrace->format_data->conn_info.rt.hostname,
    337                                 libtrace->format_data->conn_info.rt.port);
    338         if (!libtrace->format_data->output.rtserver)
     337        OUTPUT.rtserver =
     338                rtserver_create(CONNINFO.rt.hostname,
     339                                CONNINFO.rt.port);
     340        if (!OUTPUT.rtserver)
    339341                return 0;
    340342       
     
    343345static int erf_config_output(struct libtrace_out_t *libtrace, int argc, char *argv[]) {
    344346        int opt;
    345         int level = libtrace->format_data->options.erf.level;
     347        int level = OPTIONS.erf.level;
    346348        optind = 1;
    347349
     
    357359                }
    358360        }
    359         if (level != libtrace->format_data->options.erf.level) {
     361        if (level != OPTIONS.erf.level) {
    360362                if (level > 9 || level < 0) {
    361363                        // retarded level choice
     
    363365                       
    364366                } else {
    365                         libtrace->format_data->options.erf.level = level;
     367                        OPTIONS.erf.level = level;
    366368                        return gzsetparams(libtrace->format_data->output.file, level, Z_DEFAULT_STRATEGY);
    367369                }
     
    533535
    534536static int rtclient_read_packet(struct libtrace_t *libtrace, struct libtrace_packet_t *packet) {
    535         int numbytes;
    536         int size;
     537        int numbytes = 0;
     538        int size = 0;
    537539        char buf[RP_BUFSIZE];
    538         dag_record_t *erfptr;
     540        dag_record_t *erfptr = 0;
    539541        int read_required = 0;
    540542       
    541543        void *buffer = 0;
     544
     545        packet->trace = libtrace;
    542546        buffer = packet->buffer;
    543547
     
    548552                                return numbytes;
    549553                        }
    550                         assert(libtrace->fifo);
    551554                        fifo_write(libtrace->fifo,buf,numbytes);
    552555                        read_required = 0;
     
    568571                }
    569572                size = ntohs(((dag_record_t *)buffer)->rlen);
    570 
     573               
    571574                // read in the full packet
    572575                if ((numbytes = fifo_out_read(libtrace->fifo,
     
    666669        dag_record_t *erfptr = 0;
    667670        erfptr = (dag_record_t *)packet->buffer;
    668         printf("%d\n",erfptr->type);
    669671        switch (erfptr->type) {
    670672                case TYPE_ETH: return TRACE_TYPE_ETH;
Note: See TracChangeset for help on using the changeset viewer.