Changeset 72bfe20 for lib/format_erf.c


Ignore:
Timestamp:
08/08/05 16:33:16 (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:
c3274c6
Parents:
8184acc
Message:

trace_event fixed

File:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/format_erf.c

    rdf2dff9 r72bfe20  
    3131#include "libtrace.h"
    3232#include "libtrace_int.h"
     33#include "format_helper.h"
    3334#include "rtserver.h"
    3435#include "parse_cmd.h"
     
    136137        if (S_ISCHR(buf.st_mode)) {
    137138                // DEVICE
     139                libtrace->sourcetype = DEVICE;
    138140                if((INPUT.fd =
    139141                                dag_open(CONNINFO.path)) < 0) {
     
    172174        if (!strncmp(CONNINFO.path,"-",1)) {
    173175                // STDIN
     176                libtrace->sourcetype = STDIN;
    174177#if HAVE_ZLIB
    175178                INPUT.file = gzdopen(STDIN, "r");
     
    184187                }
    185188                if (S_ISSOCK(buf.st_mode)) {
    186                         // SOCKET
     189                        libtrace->sourcetype = SOCKET;
    187190                        if ((INPUT.fd = socket(
    188191                                        AF_UNIX, SOCK_STREAM, 0)) == -1) {
     
    203206                        }
    204207                } else {
    205                         // TRACE
     208                        libtrace->sourcetype = TRACE;
    206209#if HAVE_ZLIB
    207210                        // using gzdopen means we can set O_LARGEFILE
     
    230233        libtrace->format_data = (struct libtrace_format_data_t *)
    231234                malloc(sizeof(struct libtrace_format_data_t));
     235
     236        libtrace->sourcetype = RT;
    232237
    233238        if (strlen(uridata) == 0) {
     
    733738}
    734739
     740static int rtclient_get_fd(struct libtrace_packet_t *packet) {
     741        return packet->trace->format_data->input.fd;
     742}
     743
     744static int erf_get_fd(struct libtrace_packet_t *packet) {
     745        return packet->trace->format_data->input.fd;
     746}
     747
    735748static void dag_help() {
    736749        printf("dag format module: $Revision$\n");
     
    799812        erf_fin_input,                  /* fin_input */
    800813        erf_fin_output,                 /* fin_output */
    801         NULL,                           /* read */
    802814        erf_read_packet,                /* read_packet */
    803815        erf_write_packet,               /* write_packet */
     
    812824        erf_get_wire_length,            /* get_wire_length */
    813825        erf_set_capture_length,         /* set_capture_length */
     826        erf_get_fd,                     /* get_fd */
     827        trace_event_trace,              /* trace_event */
    814828        erf_help                        /* help */
    815829};
     
    824838        dag_fin_input,                  /* fin_input */
    825839        NULL,                           /* fin_output */
    826         dag_read,                       /* read */
    827840        dag_read_packet,                /* read_packet */
    828841        NULL,                           /* write_packet */
     
    837850        erf_get_wire_length,            /* get_wire_length */
    838851        erf_set_capture_length,         /* set_capture_length */
     852        NULL,                           /* get_fd */
     853        trace_event_trace,              /* trace_event */
    839854        dag_help                        /* help */
    840855};
     
    849864        rtclient_fin_input,             /* fin_input */
    850865        rtclient_fin_output,            /* fin_output */
    851         rtclient_read,                  /* read */
    852866        rtclient_read_packet,           /* read_packet */
    853867        rtclient_write_packet,          /* write_packet */
     
    862876        erf_get_wire_length,            /* get_wire_length */
    863877        erf_set_capture_length,         /* set_capture_length */
     878        rtclient_get_fd,                /* get_fd */
     879        trace_event_device,             /* trace_event */
    864880        rtclient_help                   /* help */
    865881};
Note: See TracChangeset for help on using the changeset viewer.