source: lib/format_wag.c @ f66a4933

4.0.1-hotfixescachetimestampsdevelopdpdk-ndagetsilivegetfragoffhelplibtrace4ndag_formatpfringrc-4.0.1rc-4.0.2rc-4.0.3rc-4.0.4ringdecrementfixringperformanceringtimestampfixes
Last change on this file since f66a4933 was f66a4933, checked in by Daniel Lawson <dlawson@…>, 16 years ago

moved LIBTRACE_READ etc defines into common.h

if we don't have zlib, use read,open etc. We were using fread,fopen, but these take different parameters, and i couldn't make them work nicely.

stdin doesn't seem to work for non-zlib paths however

  • Property mode set to 100644
File size: 11.1 KB
Line 
1/*
2 * This file is part of libtrace
3 *
4 * Copyright (c) 2004 The University of Waikato, Hamilton, New Zealand.
5 * Authors: Daniel Lawson
6 *          Perry Lorier
7 *         
8 * All rights reserved.
9 *
10 * This code has been developed by the University of Waikato WAND
11 * research group. For further information please see http://www.wand.net.nz/
12 *
13 * libtrace is free software; you can redistribute it and/or modify
14 * it under the terms of the GNU General Public License as published by
15 * the Free Software Foundation; either version 2 of the License, or
16 * (at your option) any later version.
17 *
18 * libtrace is distributed in the hope that it will be useful,
19 * but WITHOUT ANY WARRANTY; without even the implied warranty of
20 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
21 * GNU General Public License for more details.
22 *
23 * You should have received a copy of the GNU General Public License
24 * along with libtrace; if not, write to the Free Software
25 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
26 *
27 * $Id$
28 *
29 */
30
31#define _GNU_SOURCE
32#include "libtrace.h"
33#include "libtrace_int.h"
34#include "format_helper.h"
35#include "wag.h"
36#include "config.h"
37
38#ifdef HAVE_INTTYPES_H
39#  include <inttypes.h>
40#else
41#  error "Can't find inttypes.h - this needs to be fixed"
42#endif
43
44#ifdef HAVE_STDDEF_H
45#  include <stddef.h>
46#else
47# error "Can't find stddef.h - do you define ptrdiff_t elsewhere?"
48#endif
49#include <sys/types.h>
50#include <sys/time.h>
51#include <time.h>
52#include <sys/socket.h>
53#include <sys/un.h>
54#include <sys/mman.h>
55#include <sys/stat.h>
56#include <fcntl.h>
57#include <unistd.h>
58#include <assert.h>
59#include <errno.h>
60#include <netdb.h>
61#include <stdio.h>
62#include <string.h>
63#include <stdlib.h>
64
65/*
66#if HAVE_ZLIB
67#  include <zlib.h>
68#  define LIBTRACE_READ gzread
69#  define LIBTRACE_FDOPEN gzdopen
70#  define LIBTRACE_CLOSE gzclose
71#  define LIBTRACE_WRITE gzwrite
72#else
73#  define LIBTRACE_READ read
74#  define LIBTRACE_FDOPEN open
75#  define LIBTRACE_CLOSE close
76#  define LIBTRACE_WRITE write
77#endif
78*/
79#ifdef HAVE_LIMITS_H
80#  include <limits.h>
81#endif
82
83#ifdef HAVE_SYS_LIMITS_H
84#  include <sys/limits.h>
85#endif
86
87#ifndef O_LARGEFILE
88#define O_LARGEFILE 0
89#endif
90
91static struct libtrace_format_t wag;
92
93#define CONNINFO libtrace->format_data->conn_info
94#define INPUT libtrace->format_data->input
95#define OUTPUT libtrace->format_data->output
96#define OPTIONS libtrace->format_data->options
97
98struct libtrace_format_data_t {
99        union {
100                /** Information about rtclients */
101                struct {
102                        char *hostname;
103                        short port;
104                } rt;
105                char *path;             /**< information for local sockets */
106        } conn_info;
107        /** Information about the current state of the input device */
108        union {
109                int fd;
110#if HAVE_ZLIB
111                gzFile *file;
112#else   
113                //FILE *file;
114                int file;
115#endif
116        } input;       
117};
118
119struct libtrace_format_data_out_t {
120        union {
121                char *path;
122        } conn_info;
123        union {
124                struct {
125                        int level;
126                } zlib;
127        } options;
128        union {
129                int fd;
130#if HAVE_ZLIB
131                gzFile *file;
132#else
133                //FILE *file;
134                int file;
135#endif
136        } output;
137};
138
139static int wag_init_input(struct libtrace_t *libtrace) {
140        struct stat buf;
141        struct sockaddr_un unix_sock;
142        libtrace->format_data = (struct libtrace_format_data_t *) 
143                calloc(1,sizeof(struct libtrace_format_data_t));
144        CONNINFO.path = libtrace->uridata;
145        if (!strncmp(CONNINFO.path,"-",1)) {
146                // STDIN
147                libtrace->sourcetype = STDIN;
148                INPUT.file = LIBTRACE_FDOPEN(STDIN,"r");
149
150        } else {
151                if (stat(CONNINFO.path,&buf) == -1 ) {
152                        perror("stat");
153                        return 0;
154                }
155                if (S_ISSOCK(buf.st_mode)) {
156                        libtrace->sourcetype = SOCKET;
157                        // SOCKET
158                        if ((INPUT.fd = socket(
159                                        AF_UNIX, SOCK_STREAM, 0)) == -1) {
160                                perror("socket");
161                                return 0;
162                        }
163                        unix_sock.sun_family = AF_UNIX;
164                        bzero(unix_sock.sun_path,108);
165                        snprintf(unix_sock.sun_path,
166                                        108,"%s"
167                                        ,CONNINFO.path);
168
169                        if (connect(INPUT.fd, 
170                                        (struct sockaddr *)&unix_sock,
171                                        sizeof(struct sockaddr)) == -1) {
172                                perror("connect (unix)");
173                                return 0;
174                        }
175                } else { 
176                        // TRACE
177                        libtrace->sourcetype = TRACE;
178                       
179                        // we use an FDOPEN call to reopen an FD
180                        // returned from open(), so that we can set
181                        // O_LARGEFILE. This gets around gzopen not
182                        // letting you do this...
183                        INPUT.file = LIBTRACE_FDOPEN(open(
184                                        CONNINFO.path,
185                                        O_LARGEFILE), "r");
186
187                }
188        }
189        return 1;
190}
191
192static int wag_init_output(struct libtrace_out_t *libtrace) {
193        char *filemode = 0;
194        libtrace->format_data = (struct libtrace_format_data_out_t *)
195                calloc(1,sizeof(struct libtrace_format_data_out_t));
196
197        OPTIONS.zlib.level = 0;
198        asprintf(&filemode,"wb%d",OPTIONS.zlib.level);
199        if (!strncmp(libtrace->uridata,"-",1)) {
200                // STDOUT                               
201                OUTPUT.file = LIBTRACE_FDOPEN(dup(1), filemode);
202        } else {
203                // TRACE
204                OUTPUT.file = LIBTRACE_FDOPEN(open(
205                                        libtrace->uridata,
206                                        O_CREAT | O_LARGEFILE | O_WRONLY,
207                                        S_IRUSR | S_IWUSR), filemode);
208        }
209
210        return 1;
211}
212
213static int wag_config_output(struct libtrace_out_t *libtrace, int argc, char *argv[]) {
214#if HAVE_ZLIB
215        int opt;
216        int level = OPTIONS.zlib.level;
217        optind = 1;
218        while ((opt = getopt(argc, argv, "z:")) != EOF) {
219                switch (opt) {
220                        case 'z':
221                                level = atoi(optarg);
222                                break;
223                        default:
224                                printf("Bad argument to wag: %s\n", optarg);
225                                return -1;
226                }
227        }
228        if (level != OPTIONS.zlib.level) {
229                if (level > 9 || level < 0) {
230                        // retarded level choice
231                        printf("Compression level must be between 0 and 9 inclusive - you selected %i \n", level);
232                } else {
233                        OPTIONS.zlib.level = level;
234                        return gzsetparams(OUTPUT.file, level, Z_DEFAULT_STRATEGY);
235                }
236        }
237#endif
238        return 0;
239}
240
241static int wag_fin_input(struct libtrace_t *libtrace) {
242        LIBTRACE_CLOSE(INPUT.file);
243        return 0;
244}
245
246static int wag_fin_output(struct libtrace_out_t *libtrace) {
247        LIBTRACE_CLOSE(OUTPUT.file);
248        return 0;
249}
250
251static int wag_read(struct libtrace_t *libtrace, void *buffer, size_t len) {
252        int numbytes;
253        assert(libtrace);
254
255        if (buffer == 0)
256                buffer = malloc(len);
257
258        while(1) {
259                switch(libtrace->sourcetype) {
260                        case DEVICE:
261                                if ((numbytes=read(INPUT.fd, 
262                                                                buffer, 
263                                                                len)) == -1) {
264                                        perror("read");
265                                        return -1;
266                                }
267                                break;
268                        default:
269                                if ((numbytes=LIBTRACE_READ(INPUT.file,
270                                                                buffer,
271                                                                len)) == -1) {
272                                        perror("libtrace_read");
273                                        return -1;
274                                }
275                }
276                break;
277        }
278        return numbytes;
279
280}
281
282
283static int wag_read_packet(struct libtrace_t *libtrace, struct libtrace_packet_t *packet) {
284        int numbytes;
285        int size;
286        char buf[RP_BUFSIZE];
287        int read_required = 0;
288
289        void *buffer = 0;
290
291        packet->trace = libtrace;
292        buffer = packet->buffer;
293       
294
295        do {
296                if (tracefifo_out_available(libtrace->fifo) == 0 || read_required) {
297                        if ((numbytes = wag_read(libtrace,buf,RP_BUFSIZE)) <= 0) {
298                                return numbytes;
299                        }
300                        assert(libtrace->fifo);
301                        tracefifo_write(libtrace->fifo,buf,numbytes);
302                        read_required = 0;
303                }
304                // read in wag_frame_hdr
305                if ((numbytes = tracefifo_out_read(libtrace->fifo, 
306                                                buffer,
307                                                sizeof(struct wag_frame_hdr)))
308                                == 0 ) {
309                        tracefifo_out_reset(libtrace->fifo);
310                        read_required = 1;
311                        continue;
312                }
313               
314                size = ntohs(((struct wag_frame_hdr *)buffer)->size);
315
316                // wag isn't in network byte order yet
317                //size = htons(size);
318                //printf("%d %d\n",size,htons(size));
319
320                // read in full packet
321                if((numbytes = tracefifo_out_read(libtrace->fifo,buffer,size)) == 0) {
322                        tracefifo_out_reset(libtrace->fifo);
323                        read_required = 1;
324                        continue;
325                }
326
327                // have the whole packet
328                tracefifo_out_update(libtrace->fifo,size);
329                tracefifo_ack_update(libtrace->fifo,size);
330
331                packet->status.type = RT_DATA;
332                packet->status.message = 0;
333                packet->size = numbytes;
334                return numbytes;
335        } while(1);
336}
337
338static int wag_write_packet(struct libtrace_out_t *libtrace, const struct libtrace_packet_t *packet) {
339        int numbytes =0 ;
340        if (packet->trace->format != &wag) {
341                fprintf(stderr,"Cannot convert from wag to %s format yet\n",
342                                packet->trace->format->name);
343                return -1;
344        }
345        if ((numbytes = LIBTRACE_WRITE(OUTPUT.file, packet->buffer, packet->size)) == 0) {
346                perror("libtrace_write");
347                return -1;
348        }
349        return numbytes;
350}
351
352static void *wag_get_link(const struct libtrace_packet_t *packet) {
353        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
354        void *payload = wagptr->data;
355        return (void*)payload;
356}
357
358static libtrace_linktype_t wag_get_link_type(const struct libtrace_packet_t *packet __attribute__((unused))) {
359        return TRACE_TYPE_80211;
360}
361
362static int8_t wag_get_direction(const struct libtrace_packet_t *packet) {
363        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
364        if (wagptr->hdr.type == 0) {
365                return wagptr->hdr.subtype;
366        }
367        return -1;
368}
369
370static uint64_t wag_get_erf_timestamp(const struct libtrace_packet_t *packet) {
371        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
372        uint64_t timestamp = 0;
373        timestamp = wagptr->ts.subsecs;
374        //timestamp |= (uint64_t)wagptr->ts.secs<<32;
375        timestamp = ((timestamp%44000000)*(UINT_MAX/44000000)) 
376                | ((timestamp/44000000)<<32);
377        return timestamp;
378}
379
380static int wag_get_capture_length(const struct libtrace_packet_t *packet) {
381        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
382        //return (wagptr->hdr.size);
383        return ntohs(wagptr->hdr.size);
384}
385
386static int wag_get_wire_length(const struct libtrace_packet_t *packet) {
387        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
388        //return (wagptr->hdr.size);
389        return ntohs(wagptr->hdr.size);
390}
391
392static int wag_get_framing_length(const struct libtrace_packet_t *packet) {
393        return sizeof(struct wag_data_frame);
394}
395
396static int wag_get_fd(const struct libtrace_packet_t *packet) {
397        return packet->trace->format_data->input.fd;
398}
399
400static struct libtrace_eventobj_t wag_event_trace(struct libtrace_t *trace, struct libtrace_packet_t *packet) {
401        switch(trace->sourcetype) {
402                case DEVICE:
403                        return trace_event_device(trace,packet);
404                default:
405                        return trace_event_trace(trace,packet);
406        }
407}
408static void wag_help() {
409        printf("wag format module: $Revision$\n");
410        printf("Supported input URIs:\n");
411        printf("\twag:/dev/wagn\n");
412        printf("\twag:/path/to/trace.wag\n");
413        printf("\twag:/path/to/trace.wag.gz\n");
414        printf("\n");
415        printf("\te.g.: wag:/dev/wag0\n");
416        printf("\te.g.: wag:/tmp/trace.wag.gz\n");
417        printf("\n");
418        printf("Supported output URIs:\n");
419        printf("\tnone\n");
420        printf("\n");
421}
422
423static struct libtrace_format_t wag = {
424        "wag",
425        "$Id$",
426        "wag",
427        wag_init_input,                 /* init_input */       
428        wag_init_output,                /* init_output */
429        wag_config_output,              /* config_output */
430        wag_fin_input,                  /* fin_input */
431        wag_fin_output,                 /* fin_output */
432        wag_read_packet,                /* read_packet */
433        wag_write_packet,               /* write_packet */
434        wag_get_link,                   /* get_link */
435        wag_get_link_type,              /* get_link_type */
436        wag_get_direction,              /* get_direction */
437        NULL,                           /* set_direction */
438        wag_get_erf_timestamp,          /* get_erf_timestamp */
439        NULL,                           /* get_timeval */
440        NULL,                           /* get_seconds */
441        wag_get_capture_length,         /* get_capture_length */
442        wag_get_wire_length,            /* get_wire_length */
443        wag_get_framing_length,         /* get_framing_length */
444        NULL,                           /* set_capture_length */
445        wag_get_fd,                     /* get_fd */
446        wag_event_trace,                /* trace_event */
447        wag_help                        /* help */
448};
449
450void __attribute__((constructor)) wag_constructor() {
451        register_format(&wag);
452}
Note: See TracBrowser for help on using the repository browser.