Changeset d5879cc for lib/format_erf.c


Ignore:
Timestamp:
02/27/06 16:40:19 (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:
8a8e54b
Parents:
ab4cb04
Message:

Fix various issues

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/format_erf.c

    rab4cb04 rd5879cc  
    7272#endif
    7373
    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)
     74#define DATA(x) ((struct erf_format_data_t *)x->format_data)
     75#define DATAOUT(x) ((struct erf_format_data_out_t *)x->format_data)
     76
    7677#define CONNINFO DATA(libtrace)->conn_info
    7778#define INPUT DATA(libtrace)->input
     
    8182#endif
    8283#define OPTIONS DATAOUT(libtrace)->options
    83 struct libtrace_format_data_t {
     84struct erf_format_data_t {
    8485        union {
    8586                struct {
     
    106107};
    107108
    108 struct libtrace_format_data_out_t {
     109struct erf_format_data_out_t {
    109110        union {
    110111                struct {
     
    154155        if (stat(libtrace->uridata, &buf) == -1) {
    155156                trace_set_err(libtrace,errno,"stat(%s)",libtrace->uridata);
    156                 return 0;
     157                return -1;
    157158        }
    158159        if (S_ISCHR(buf.st_mode)) {
     
    161162                        trace_set_err(libtrace,errno,"Cannot open DAG %s",
    162163                                        libtrace->uridata);
    163                         return 0;
     164                        return -1;
    164165                }
    165166                if((DAG.buf = (void *)dag_mmap(INPUT.fd)) == MAP_FAILED) {
    166167                        trace_set_err(libtrace,errno,"Cannot mmap DAG %s",
    167168                                        libtrace->uridata);
    168                         return 0;
     169                        return -1;
    169170                }
    170171                if(dag_start(INPUT.fd) < 0) {
    171172                        trace_set_err(libtrace,errno,"Cannot start DAG %s",
    172173                                        libtrace->uridata);
    173                         return 0;
     174                        return -1;
    174175                }
    175176        } else {
    176177                trace_set_err(libtrace,errno,"Not a valid dag device: %s",
    177178                                libtrace->uridata);
    178                 return 0;
    179         }
    180         return 1;
     179                return -1;
     180        }
     181        return 0;
    181182}
    182183#endif
     
    201202static int erf_init_input(struct libtrace_t *libtrace)
    202203{
    203         libtrace->format_data = (struct libtrace_format_data_t *)
    204                 malloc(sizeof(struct libtrace_format_data_t));
    205 
     204        libtrace->format_data = malloc(sizeof(struct erf_format_data_t));
     205
     206        return 0; /* success */
    206207}
    207208
     
    213214                return -1;
    214215
    215         return 0;
     216        return 0; /* success */
    216217}
    217218
    218219static int rtclient_init_input(struct libtrace_t *libtrace) {
    219220        char *scan;
    220         libtrace->format_data = (struct libtrace_format_data_t *)
    221                 malloc(sizeof(struct libtrace_format_data_t));
     221        libtrace->format_data = malloc(sizeof(struct erf_format_data_t));
    222222
    223223
     
    241241                }
    242242        }
    243        
     243
     244        return 0; /* success */
    244245}
    245246
     
    267268                trace_set_err(libtrace,errno,"connect(%s)",
    268269                                CONNINFO.rt.hostname);
    269                 return 0;
    270         }
    271         return -1;
     270                return -1;
     271        }
     272        return 0;
    272273}
    273274
    274275static int erf_init_output(struct libtrace_out_t *libtrace) {
    275         libtrace->format_data = (struct libtrace_format_data_out_t *)
    276                 calloc(1,sizeof(struct libtrace_format_data_out_t));
     276        libtrace->format_data = calloc(1,sizeof(struct erf_format_data_out_t));
    277277
    278278        OPTIONS.erf.level = 0;
Note: See TracChangeset for help on using the changeset viewer.