source: lib/format_wag.c @ 9e2a109

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

moved format.h to libtrace_int.h

pulled out all the format-specific libtrace_t stuff into an opaque pointer which is defined inside each format_*.o file, for both input and output

This seems to work, it compiles at least, and wag and erf both work

rtclient input is currently broken, I suspect it's not stepping over the status properly

  • Property mode set to 100644
File size: 8.5 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#include "libtrace.h"
32#include "libtrace_int.h"
33#include "wag.h"
34
35#ifdef HAVE_INTTYPES_H
36#  include <inttypes.h>
37#else
38#  error "Can't find inttypes.h - this needs to be fixed"
39#endif
40
41#ifdef HAVE_STDDEF_H
42#  include <stddef.h>
43#else
44# error "Can't find stddef.h - do you define ptrdiff_t elsewhere?"
45#endif
46#include <sys/types.h>
47#include <sys/socket.h>
48#include <sys/un.h>
49#include <sys/mman.h>
50#include <sys/stat.h>
51#include <fcntl.h>
52#include <unistd.h>
53#include <assert.h>
54#include <errno.h>
55#include <netdb.h>
56
57#ifndef O_LARGEFILE
58#define O_LARGEFILE 0
59#endif
60
61struct libtrace_format_data_t {
62        union {
63                /** Information about rtclients */
64                struct {
65                        char *hostname;
66                        short port;
67                } rt;
68                char *path;             /**< information for local sockets */
69        } conn_info;
70        /** Information about the current state of the input device */
71        union {
72                int fd;
73#if HAVE_ZLIB
74                gzFile *file;
75#else   
76                FILE *file;
77#endif
78        } input;       
79};
80
81static int wag_init_input(struct libtrace_t *libtrace) {
82        struct stat buf;
83        struct hostent *he;
84        struct sockaddr_in remote;
85        struct sockaddr_un unix_sock;
86        libtrace->format_data = (struct libtrace_format_data_t *) 
87                calloc(1,sizeof(struct libtrace_format_data_t));
88        libtrace->format_data->conn_info.path = libtrace->uridata;
89        if (!strncmp(libtrace->format_data->conn_info.path,"-",1)) {
90                // STDIN
91#if HAVE_ZLIB
92                libtrace->format_data->input.file = gzdopen(STDIN, "r");
93#else   
94                libtrace->format_data->input.file = stdin;
95#endif
96
97        } else {
98                if (stat(libtrace->format_data->conn_info.path,&buf) == -1 ) {
99                        perror("stat");
100                        return 0;
101                }
102                if (S_ISSOCK(buf.st_mode)) {
103                        // SOCKET
104                        if ((libtrace->format_data->input.fd = socket(
105                                        AF_UNIX, SOCK_STREAM, 0)) == -1) {
106                                perror("socket");
107                                return 0;
108                        }
109                        unix_sock.sun_family = AF_UNIX;
110                        bzero(unix_sock.sun_path,108);
111                        snprintf(unix_sock.sun_path,
112                                        108,"%s"
113                                        ,libtrace->format_data->conn_info.path);
114
115                        if (connect(libtrace->format_data->input.fd, 
116                                        (struct sockaddr *)&unix_sock,
117                                        sizeof(struct sockaddr)) == -1) {
118                                perror("connect (unix)");
119                                return 0;
120                        }
121                } else { 
122                        // TRACE
123#if HAVE_ZLIB
124                        // using gzdopen means we can set O_LARGEFILE
125                        // ourselves. However, this way is messy and
126                        // we lose any error checking on "open"
127                        libtrace->format_data->input.file = 
128                                gzdopen(open(
129                                        libtrace->format_data->conn_info.path,
130                                        O_LARGEFILE), "r");
131#else
132                        libtrace->format_data->input.file = 
133                                fdopen(open(
134                                        libtrace->format_data->conn_info.path,
135                                        O_LARGEFILE), "r");
136#endif
137
138                }
139        }
140}
141
142static int wag_fin_input(struct libtrace_t *libtrace) {
143#if HAVE_ZLIB
144        gzclose(libtrace->format_data->input.file);
145#else   
146        fclose(libtrace->format_data->input.file);     
147#endif
148}
149
150static int wag_read(struct libtrace_t *libtrace, void *buffer, size_t len) {
151        int numbytes;
152        static short lctr = 0;
153        int rlen;
154        assert(libtrace);
155        assert(len >= 0);
156
157        if (buffer == 0)
158                buffer = malloc(len);
159
160        while(1) {
161                switch(libtrace->sourcetype) {
162                        case DEVICE:
163                                if ((numbytes=read(libtrace->format_data->input.fd, 
164                                                                buffer, 
165                                                                len)) == -1) {
166                                        perror("read");
167                                        return -1;
168                                }
169                                break;
170                        default:
171#if HAVE_ZLIB
172                                if ((numbytes=gzread(libtrace->format_data->input.file,
173                                                                buffer,
174                                                                len)) == -1) {
175                                        perror("gzread");
176                                        return -1;
177                                }
178#else
179                                if ((numbytes=fread(buffer,len,1,
180                                        libtrace->format_data->input.file)) == 0 ) {
181                                        if(feof(libtrace->format_data->input.file)) {
182                                                return 0;
183                                        }
184                                        if(ferror(libtrace->format_data->input.file)) {
185                                                perror("fread");
186                                                return -1;
187                                        }
188                                        return 0;
189                                }
190#endif
191                }
192                break;
193        }
194        return numbytes;
195
196}
197
198
199static int wag_read_packet(struct libtrace_t *libtrace, struct libtrace_packet_t *packet) {
200        int numbytes;
201        int size;
202        char buf[RP_BUFSIZE];
203        int read_required = 0;
204        struct wag_frame_hdr *waghdr = 0;
205
206        void *buffer = 0;
207
208        packet->trace = libtrace;
209        buffer = packet->buffer;
210       
211
212        do {
213                if (fifo_out_available(libtrace->fifo) == 0 || read_required) {
214                        if ((numbytes = wag_read(libtrace,buf,RP_BUFSIZE)) <= 0) {
215                                return numbytes;
216                        }
217                        assert(libtrace->fifo);
218                        fifo_write(libtrace->fifo,buf,numbytes);
219                        read_required = 0;
220                }
221                // read in wag_frame_hdr
222                if ((numbytes = fifo_out_read(libtrace->fifo, 
223                                                buffer,
224                                                sizeof(struct wag_frame_hdr)))
225                                == 0 ) {
226                        fifo_out_reset(libtrace->fifo);
227                        read_required = 1;
228                        continue;
229                }
230               
231                size = ntohs(((struct wag_frame_hdr *)buffer)->size);
232
233                // wag isn't in network byte order yet
234                size = htons(size);
235                //printf("%d %d\n",size,htons(size));
236
237                // read in full packet
238                if((numbytes = fifo_out_read(libtrace->fifo,buffer,size)) == 0) {
239                        fifo_out_reset(libtrace->fifo);
240                        read_required = 1;
241                        continue;
242                }
243
244                // have the whole packet
245                fifo_out_update(libtrace->fifo,size);
246                fifo_ack_update(libtrace->fifo,size);
247
248                packet->size = numbytes;
249                return numbytes;
250        } while(1);
251}
252
253static void *wag_get_link(const struct libtrace_packet_t *packet) {
254        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
255        void *payload = wagptr->data;
256        return (void*)payload;
257}
258
259static libtrace_linktype_t wag_get_link_type(const struct libtrace_packet_t *packet) {
260        return TRACE_TYPE_80211;
261}
262
263static int8_t wag_get_direction(const struct libtrace_packet_t *packet) {
264        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
265        if (wagptr->hdr.type == 0) {
266                return wagptr->hdr.subtype;
267        }
268        return -1;
269}
270
271static uint64_t wag_get_erf_timestamp(const struct libtrace_packet_t *packet) {
272        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
273        uint64_t timestamp = 0;
274        timestamp = wagptr->ts.subsecs;
275        timestamp |= (uint64_t)wagptr->ts.secs<<32;
276        timestamp = ((timestamp%44000000)*(UINT_MAX/44000000)) 
277                | ((timestamp/44000000)<<32);
278        return timestamp;
279}
280
281static int wag_get_capture_length(const struct libtrace_packet_t *packet) {
282        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
283        return (wagptr->hdr.size);
284        //return ntohs(wagptr->hdr.size);
285}
286
287static int wag_get_wire_length(const struct libtrace_packet_t *packet) {
288        struct wag_data_frame *wagptr = (struct wag_data_frame *)packet->buffer;
289        return (wagptr->hdr.size);
290        //return ntohs(wagptr->hdr.size);
291}
292
293static int wag_help() {
294        printf("wag format module: $Revision$\n");
295        printf("Supported input URIs:\n");
296        printf("\twag:/dev/wagn\n");
297        printf("\twag:/path/to/trace.wag\n");
298        printf("\twag:/path/to/trace.wag.gz\n");
299        printf("\n");
300        printf("\te.g.: wag:/dev/wag0\n");
301        printf("\te.g.: wag:/tmp/trace.wag.gz\n");
302        printf("\n");
303        printf("Supported output URIs:\n");
304        printf("\tnone\n");
305        printf("\n");
306
307}
308
309static struct libtrace_format_t wag = {
310        "wag",
311        "$Id$",
312        wag_init_input,                 /* init_input */       
313        NULL,                           /* init_output */
314        NULL,                           /* config_output */
315        wag_fin_input,                  /* fin_input */
316        NULL,                           /* fin_output */
317        NULL,                           /* read */
318        wag_read_packet,                /* read_packet */
319        NULL,                           /* write_packet */
320        wag_get_link,                   /* get_link */
321        wag_get_link_type,              /* get_link_type */
322        wag_get_direction,              /* get_direction */
323        NULL,                           /* set_direction */
324        wag_get_erf_timestamp,          /* get_wag_timestamp */
325        NULL,                           /* get_timeval */
326        NULL,                           /* get_seconds */
327        wag_get_capture_length,         /* get_capture_length */
328        wag_get_wire_length,            /* get_wire_length */
329        NULL,                           /* set_capture_length */
330        wag_help                        /* help */
331};
332
333void __attribute__((constructor)) wag_constructor() {
334        register_format(&wag);
335}
Note: See TracBrowser for help on using the repository browser.