source: lib/format_wag.c @ ffc8c8d

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

better return codes in format_*.c, trace_perror stuff

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