Changeset ab4cb04 for lib/format_erf.c


Ignore:
Timestamp:
02/27/06 14:31:09 (16 years ago)
Author:
Perry Lorier <perry@…>
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:
d5879cc
Parents:
afd0b73
Message:

Cleanup struct libtrace_Format_data_t

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/format_erf.c

    rafd0b73 rab4cb04  
    7272#endif
    7373
    74 #define CONNINFO libtrace->format_data->conn_info
    75 #define INPUT libtrace->format_data->input
    76 #define OUTPUT libtrace->format_data->output
     74#define DATA(x) ((struct libtrace_format_data_t *)x->format_data)
     75#define DATAOUT(x) ((struct libtrace_format_data_out_t *)x->format_data)
     76#define CONNINFO DATA(libtrace)->conn_info
     77#define INPUT DATA(libtrace)->input
     78#define OUTPUT DATAOUT(libtrace)->output
    7779#if HAVE_DAG
    78 #define DAG libtrace->format_data->dag
    79 #endif
    80 #define OPTIONS libtrace->format_data->options
     80#define DAG DATA(libtrace)->dag
     81#endif
     82#define OPTIONS DATAOUT(libtrace)->options
    8183struct libtrace_format_data_t {
    8284        union {
     
    206208static int erf_start_input(struct libtrace_t *libtrace)
    207209{
    208         libtrace->format_data->input.file = trace_open_file(libtrace);
    209 
    210         if (libtrace->format_data->input.file)
    211                 return 1;
     210        INPUT.file = trace_open_file(libtrace);
     211
     212        if (!INPUT.file)
     213                return -1;
    212214
    213215        return 0;
     
    216218static int rtclient_init_input(struct libtrace_t *libtrace) {
    217219        char *scan;
    218         char *uridata = libtrace->uridata;
    219         struct hostent *he;
    220         struct sockaddr_in remote;
    221220        libtrace->format_data = (struct libtrace_format_data_t *)
    222221                malloc(sizeof(struct libtrace_format_data_t));
    223222
    224223
    225         if (strlen(uridata) == 0) {
     224        if (strlen(libtrace->uridata) == 0) {
    226225                CONNINFO.rt.hostname =
    227226                        strdup("localhost");
     
    229228                        COLLECTOR_PORT;
    230229        } else {
    231                 if ((scan = strchr(uridata,':')) == NULL) {
     230                if ((scan = strchr(libtrace->uridata,':')) == NULL) {
    232231                        CONNINFO.rt.hostname =
    233                                 strdup(uridata);
     232                                strdup(libtrace->uridata);
    234233                        CONNINFO.rt.port =
    235234                                COLLECTOR_PORT;
    236235                } else {
    237236                        CONNINFO.rt.hostname =
    238                                 (char *)strndup(uridata,
    239                                                 (scan - uridata));
     237                                (char *)strndup(libtrace->uridata,
     238                                                (scan - libtrace->uridata));
    240239                        CONNINFO.rt.port =
    241240                                atoi(++scan);
     
    243242        }
    244243       
     244}
     245
     246static int rtclient_start_input(libtrace_t *libtrace)
     247{
     248        struct hostent *he;
     249        struct sockaddr_in remote;
    245250        if ((he=gethostbyname(CONNINFO.rt.hostname)) == NULL) { 
    246251                trace_set_err(libtrace,errno,"failed to resolve %s",
    247252                                CONNINFO.rt.hostname);
    248                 return 0;
     253                return -1;
    249254        }
    250255        if ((INPUT.fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
    251256                trace_set_err(libtrace,errno,"socket(AF_INET,SOCK_STREAM)");
    252                 return 0;
     257                return -1;
    253258        }
    254259
     
    264269                return 0;
    265270        }
    266         return 1;
     271        return -1;
    267272}
    268273
     
    683688}
    684689
    685 static int rtclient_get_fd(const libtrace_t *trace) {
    686         return trace->format_data->input.fd;
    687 }
    688 
    689 static int erf_get_fd(const libtrace_t *trace) {
    690         return trace->format_data->input.fd;
     690static int rtclient_get_fd(const libtrace_t *libtrace) {
     691        return INPUT.fd;
     692}
     693
     694static int erf_get_fd(const libtrace_t *libtrace) {
     695        return INPUT.fd;
    691696}
    692697
     
    841846        rtclient_init_input,            /* init_input */       
    842847        NULL,                           /* config_input */
    843         NULL,                           /* start_input */
     848        rtclient_start_input,           /* start_input */
    844849        NULL,                           /* pause_input */
    845850        NULL,                           /* init_output */
Note: See TracChangeset for help on using the changeset viewer.