Fixed a few "statement not reached" warnings and a "assignment type mismatch" warning.
[metze/wireshark/wip.git] / tshark.c
1 /* tshark.c
2  *
3  * $Id$
4  *
5  * Wireshark - Network traffic analyzer
6  * By Gerald Combs <gerald@wireshark.org>
7  * Copyright 1998 Gerald Combs
8  *
9  * Text-mode variant, by Gilbert Ramirez <gram@alumni.rice.edu>
10  * and Guy Harris <guy@alum.mit.edu>.
11  *
12  * This program is free software; you can redistribute it and/or
13  * modify it under the terms of the GNU General Public License
14  * as published by the Free Software Foundation; either version 2
15  * of the License, or (at your option) any later version.
16  *
17  * This program is distributed in the hope that it will be useful,
18  * but WITHOUT ANY WARRANTY; without even the implied warranty of
19  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
20  * GNU General Public License for more details.
21  *
22  * You should have received a copy of the GNU General Public License
23  * along with this program; if not, write to the Free Software
24  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25  */
26
27 #ifdef HAVE_CONFIG_H
28 # include "config.h"
29 #endif
30
31 #include <stdlib.h>
32 #include <stdio.h>
33 #include <string.h>
34 #include <ctype.h>
35 #include <locale.h>
36 #include <limits.h>
37
38 #ifdef HAVE_UNISTD_H
39 #include <unistd.h>
40 #endif
41
42 #include <errno.h>
43
44 #ifdef HAVE_FCNTL_H
45 #include <fcntl.h>
46 #endif
47
48 #include <signal.h>
49
50 #ifdef HAVE_SYS_STAT_H
51 # include <sys/stat.h>
52 #endif
53
54 #ifdef NEED_STRERROR_H
55 #include "strerror.h"
56 #endif
57
58 #ifdef NEED_GETOPT_H
59 #include "getopt.h"
60 #endif
61
62 #include <glib.h>
63 #include <epan/epan.h>
64 #include <epan/filesystem.h>
65 #include <epan/privileges.h>
66 #include <wiretap/file_util.h>
67
68 #include "globals.h"
69 #include <epan/timestamp.h>
70 #include <epan/packet.h>
71 #include "file.h"
72 #include "disabled_protos.h"
73 #include <epan/prefs.h>
74 #include <epan/column.h>
75 #include "print.h"
76 #include <epan/addr_resolv.h>
77 #include "util.h"
78 #include "clopts_common.h"
79 #include "cmdarg_err.h"
80 #include "version_info.h"
81 #include <epan/conversation.h>
82 #include <epan/plugins.h>
83 #include "register.h"
84 #include <epan/epan_dissect.h>
85 #include <epan/tap.h>
86 #include <epan/stat_cmd_args.h>
87 #include <epan/timestamp.h>
88 #include <epan/ex-opt.h>
89
90 #ifdef HAVE_LIBPCAP
91 #include "capture_ui_utils.h"
92 #include <pcap.h>
93 #include "capture-pcap-util.h"
94 #ifdef _WIN32
95 #include "capture-wpcap.h"
96 #include "capture_errs.h"
97 #endif /* _WIN32 */
98 #include "capture_sync.h"
99 #endif /* HAVE_LIBPCAP */
100 #include "epan/emem.h"
101 #include "log.h"
102 #include <epan/funnel.h>
103
104
105 /*
106  * This is the template for the decode as option; it is shared between the
107  * various functions that output the usage for this parameter.
108  */
109 static const gchar decode_as_arg_template[] = "<layer_type>==<selector>,<decode_as_protocol>";
110
111 static nstime_t first_ts;
112 static nstime_t prev_dis_ts;
113 static nstime_t prev_cap_ts;
114 static GString *comp_info_str, *runtime_info_str;
115
116 static gboolean print_packet_info;      /* TRUE if we're to print packet information */
117 /*
118  * The way the packet decode is to be written.
119  */
120 typedef enum {
121         WRITE_TEXT,     /* summary or detail text */
122         WRITE_XML,      /* PDML or PSML */
123         WRITE_FIELDS    /* User defined list of fields */
124         /* Add CSV and the like here */
125 } output_action_e;
126 static output_action_e output_action;
127 static gboolean do_dissection;  /* TRUE if we have to dissect each packet */
128 static gboolean verbose;
129 static gboolean print_hex;
130 static gboolean line_buffered;
131 static guint32 cum_bytes = 0;
132 static print_format_e print_format = PR_FMT_TEXT;
133 static print_stream_t *print_stream;
134
135 static output_fields_t* output_fields  = NULL;
136
137 /*
138  * Standard secondary message for unexpected errors.
139  */
140 static const char please_report[] =
141     "Please report this to the Wireshark developers";
142
143 #ifdef HAVE_LIBPCAP
144 /*
145  * TRUE if we're to print packet counts to keep track of captured packets.
146  */
147 static gboolean print_packet_counts;
148
149
150 static capture_options capture_opts;
151
152 #ifdef SIGINFO
153 static gboolean infodelay;      /* if TRUE, don't print capture info in SIGINFO handler */
154 static gboolean infoprint;      /* if TRUE, print capture info after clearing infodelay */
155 #endif /* SIGINFO */
156
157 static int capture(void);
158 static void report_counts(void);
159 #ifdef _WIN32
160 static BOOL WINAPI capture_cleanup(DWORD);
161 #else /* _WIN32 */
162 static void capture_cleanup(int);
163 #ifdef SIGINFO
164 static void report_counts_siginfo(int);
165 #endif /* SIGINFO */
166 #endif /* _WIN32 */
167 #endif /* HAVE_LIBPCAP */
168
169 static int load_cap_file(capture_file *, char *, int, int, gint64);
170 static gboolean process_packet(capture_file *cf, gint64 offset,
171     const struct wtap_pkthdr *whdr, union wtap_pseudo_header *pseudo_header,
172     const guchar *pd);
173 static void show_capture_file_io_error(const char *, int, gboolean);
174 static void show_print_file_io_error(int err);
175 static gboolean write_preamble(capture_file *cf);
176 static gboolean print_packet(capture_file *cf, epan_dissect_t *edt);
177 static gboolean write_finale(void);
178 static const char *cf_open_error_message(int err, gchar *err_info,
179     gboolean for_writing, int file_type);
180
181 static void open_failure_message(const char *filename, int err,
182     gboolean for_writing);
183 static void failure_message(const char *msg_format, va_list ap);
184 static void read_failure_message(const char *filename, int err);
185
186 capture_file cfile;
187
188
189 static void list_capture_types(void) {
190     int i;
191
192     fprintf(stderr, "editcap: The available capture file types for \"F\":\n");
193     for (i = 0; i < WTAP_NUM_FILE_TYPES; i++) {
194       if (wtap_dump_can_open(i))
195         fprintf(stderr, "    %s - %s\n",
196           wtap_file_type_short_string(i), wtap_file_type_string(i));
197     }
198 }
199
200 static void
201 print_usage(gboolean print_ver)
202 {
203   FILE *output;
204
205   if (print_ver) {
206     output = stdout;
207     fprintf(output,
208         "TShark " VERSION "%s\n"
209         "Dump and analyze network traffic.\n"
210         "See http://www.wireshark.org for more information.\n"
211         "\n"
212         "%s",
213         wireshark_svnversion, get_copyright_info());
214   } else {
215     output = stderr;
216   }
217   fprintf(output, "\n");
218   fprintf(output, "Usage: tshark [options] ...\n");
219   fprintf(output, "\n");
220
221 #ifdef HAVE_LIBPCAP
222   fprintf(output, "Capture interface:\n");
223   fprintf(output, "  -i <interface>           name or idx of interface (def: first non-loopback)\n");
224   fprintf(output, "  -f <capture filter>      packet filter in libpcap filter syntax\n");
225   fprintf(output, "  -s <snaplen>             packet snapshot length (def: 65535)\n");
226   fprintf(output, "  -p                       don't capture in promiscuous mode\n");
227 #ifdef _WIN32
228   fprintf(output, "  -B <buffer size>         size of kernel buffer (def: 1MB)\n");
229 #endif
230   fprintf(output, "  -y <link type>           link layer type (def: first appropriate)\n");
231   fprintf(output, "  -D                       print list of interfaces and exit\n");
232   fprintf(output, "  -L                       print list of link-layer types of iface and exit\n");
233   fprintf(output, "\n");
234   fprintf(output, "Capture stop conditions:\n");
235   fprintf(output, "  -c <packet count>        stop after n packets (def: infinite)\n");
236   fprintf(output, "  -a <autostop cond.> ...  duration:NUM - stop after NUM seconds\n");
237   fprintf(output, "                           filesize:NUM - stop this file after NUM KB\n");
238   fprintf(output, "                              files:NUM - stop after NUM files\n");
239   /*fprintf(output, "\n");*/
240   fprintf(output, "Capture output:\n");
241   fprintf(output, "  -b <ringbuffer opt.> ... duration:NUM - switch to next file after NUM secs\n");
242   fprintf(output, "                           filesize:NUM - switch to next file after NUM KB\n");
243   fprintf(output, "                              files:NUM - ringbuffer: replace after NUM files\n");
244 #endif  /* HAVE_LIBPCAP */
245
246   /*fprintf(output, "\n");*/
247   fprintf(output, "Input file:\n");
248   fprintf(output, "  -r <infile>              set the filename to read from (no pipes or stdin!)\n");
249
250   fprintf(output, "\n");
251   fprintf(output, "Processing:\n");
252   fprintf(output, "  -R <read filter>         packet filter in Wireshark display filter syntax\n");
253   fprintf(output, "  -n                       disable all name resolutions (def: all enabled)\n");
254   fprintf(output, "  -N <name resolve flags>  enable specific name resolution(s): \"mntC\"\n");
255   fprintf(output, "  -d %s ...\n", decode_as_arg_template);
256   fprintf(output, "                           \"Decode As\", see the man page for details\n");
257   fprintf(output, "                           Example: tcp.port==8888,http\n");
258
259   /*fprintf(output, "\n");*/
260   fprintf(output, "Output:\n");
261   fprintf(output, "  -w <outfile|->           set the output filename (or '-' for stdout)\n");
262   fprintf(output, "  -F <output file type>    set the output file type, default is libpcap\n");
263   fprintf(output, "                           an empty \"-F\" option will list the file types\n");
264   fprintf(output, "  -V                       add output of packet tree        (Packet Details)\n");
265   fprintf(output, "  -S                       display packets even when writing to a file\n");
266   fprintf(output, "  -x                       add output of hex and ASCII dump (Packet Bytes)\n");
267   fprintf(output, "  -T pdml|ps|psml|text|fields\n");
268   fprintf(output, "                           format of text output (def: text)\n");
269   fprintf(output, "  -e <field>               field to print if -Tfields selected (e.g. tcp.port);\n");
270   fprintf(output, "                           this option can be repeated to print multiple fields\n");
271   fprintf(output, "  -E<fieldsoption>=<value> set options for output when -Tfields selected:\n");
272   fprintf(output, "     header=y|n            switch headers on and off\n");
273   fprintf(output, "     separator=/t|/s|<char> select tab, space, printable character as separator\n");
274   fprintf(output, "     quote=d|s|n           select double, single, no quotes for values\n");
275   fprintf(output, "  -t ad|a|r|d|dd|e         output format of time stamps (def: r: rel. to first)\n");
276   fprintf(output, "  -l                       flush standard output after each packet\n");
277   fprintf(output, "  -q                       be more quiet on stdout (e.g. when using statistics)\n");
278   fprintf(output, "  -X <key>:<value>         eXtension options, see the man page for details\n");
279   fprintf(output, "  -z <statistics>          various statistics, see the man page for details\n");
280
281   fprintf(output, "\n");
282   fprintf(output, "Miscellaneous:\n");
283   fprintf(output, "  -h                       display this help and exit\n");
284   fprintf(output, "  -v                       display version info and exit\n");
285   fprintf(output, "  -o <name>:<value> ...    override preference setting\n");
286 }
287
288 /*
289  * For a dissector table, print on the stream described by output,
290  * its short name (which is what's used in the "-d" option) and its
291  * descriptive name.
292  */
293 static void
294 display_dissector_table_names(const char *table_name, const char *ui_name,
295                               gpointer output)
296 {
297   fprintf((FILE *)output, "\t%s (%s)\n", table_name, ui_name);
298 }
299
300 /*
301  * For a dissector handle, print on the stream described by output,
302  * the filter name (which is what's used in the "-d" option) and the full
303  * name for the protocol that corresponds to this handle.
304  */
305 static void
306 display_dissector_names(const gchar *table _U_, gpointer handle, gpointer output)
307 {
308   int                proto_id;
309   const gchar*       proto_filter_name;
310   const gchar*       proto_ui_name;
311
312   proto_id = dissector_handle_get_protocol_index((dissector_handle_t)handle);
313
314   if (proto_id != -1) {
315     proto_filter_name = proto_get_protocol_filter_name(proto_id);
316     proto_ui_name =  proto_get_protocol_name(proto_id);
317     g_assert(proto_filter_name != NULL);
318     g_assert(proto_ui_name != NULL);
319
320     fprintf((FILE *)output, "\t%s (%s)\n",
321             proto_filter_name,
322             proto_ui_name);
323   }
324 }
325
326 /*
327  * The protocol_name_search structure is used by find_protocol_name_func()
328  * to pass parameters and store results
329  */
330 struct protocol_name_search{
331   gchar              *searched_name;  /* Protocol filter name we are looking for */
332   dissector_handle_t  matched_handle; /* Handle for a dissector whose protocol has the specified filter name */
333   guint               nb_match;       /* How many dissectors matched searched_name */
334 };
335 typedef struct protocol_name_search *protocol_name_search_t;
336
337 /*
338  * This function parses all dissectors associated with a table to find the
339  * one whose protocol has the specified filter name.  It is called
340  * as a reference function in a call to dissector_table_foreach_handle.
341  * The name we are looking for, as well as the results, are stored in the
342  * protocol_name_search struct pointed to by user_data.
343  * If called using dissector_table_foreach_handle, we actually parse the
344  * whole list of dissectors.
345  */
346 static void
347 find_protocol_name_func(const gchar *table _U_, gpointer handle, gpointer user_data)
348
349 {
350   int                         proto_id;
351   const gchar                *protocol_filter_name;
352   protocol_name_search_t      search_info;
353
354   g_assert(handle);
355
356   search_info = (protocol_name_search_t)user_data;
357
358   proto_id = dissector_handle_get_protocol_index((dissector_handle_t)handle);
359   if (proto_id != -1) {
360     protocol_filter_name = proto_get_protocol_filter_name(proto_id);
361     g_assert(protocol_filter_name != NULL);
362     if (strcmp(protocol_filter_name, search_info->searched_name) == 0) {
363       /* Found a match */
364       if (search_info->nb_match == 0) {
365         /* Record this handle only if this is the first match */
366         search_info->matched_handle = (dissector_handle_t)handle; /* Record the handle for this matching dissector */
367       }
368       search_info->nb_match++;
369     }
370   }
371 }
372
373 /*
374  * Print all layer type names supported.
375  * We send the output to the stream described by the handle output.
376  */
377
378 static void
379 fprint_all_layer_types(FILE *output)
380
381 {
382   dissector_all_tables_foreach_table(display_dissector_table_names, (gpointer)output);
383 }
384
385 /*
386  * Print all protocol names supported for a specific layer type.
387  * table_name contains the layer type name in which the search is performed.
388  * We send the output to the stream described by the handle output.
389  */
390
391 static void
392 fprint_all_protocols_for_layer_types(FILE *output, gchar *table_name)
393
394 {
395   dissector_table_foreach_handle(table_name,
396                                  display_dissector_names,
397                                  (gpointer)output);
398 }
399
400 /*
401  * The function below parses the command-line parameters for the decode as
402  * feature (a string pointer by cl_param).
403  * It checks the format of the command-line, searches for a matching table
404  * and dissector.  If a table/dissector match is not found, we display a
405  * summary of the available tables/dissectors (on stderr) and return FALSE.
406  * If everything is fine, we get the "Decode as" preference activated,
407  * then we return TRUE.
408  */
409 static gboolean
410 add_decode_as(const gchar *cl_param)
411 {
412   gchar                        *table_name;
413   guint32                       selector;
414   gchar                        *decoded_param;
415   gchar                        *remaining_param;
416   gchar                        *selector_str;
417   gchar                        *dissector_str;
418   dissector_handle_t            dissector_matching;
419   dissector_table_t             table_matching;
420   ftenum_t                      dissector_table_selector_type;
421   struct protocol_name_search   user_protocol_name;
422
423 /* The following code will allocate and copy the command-line options in a string pointed by decoded_param */
424
425   g_assert(cl_param);
426   decoded_param = g_malloc( sizeof(gchar) * (strlen(cl_param) + 1) ); /* Allocate enough space to have a working copy of the command-line parameter */
427   g_assert(decoded_param);
428   strcpy(decoded_param, cl_param);
429
430
431   /* The lines below will parse this string (modifying it) to extract all
432     necessary information.  Note that decoded_param is still needed since
433     strings are not copied - we just save pointers. */
434
435   /* This section extracts a layer type (table_name) from decoded_param */
436   table_name = decoded_param; /* Layer type string starts from beginning */
437
438   remaining_param = strchr(table_name, '=');
439   if (remaining_param == NULL) {
440     cmdarg_err("Parameter \"%s\" doesn't follow the template \"%s\"", cl_param, decode_as_arg_template);
441     /* If the argument does not follow the template, carry on anyway to check
442        if the table name is at least correct.  If remaining_param is NULL,
443        we'll exit anyway further down */
444   }
445   else {
446     *remaining_param = '\0'; /* Terminate the layer type string (table_name) where '=' was detected */
447   }
448
449   /* Remove leading and trailing spaces from the table name */
450   while ( table_name[0] == ' ' )
451     table_name++;
452   while ( table_name[strlen(table_name) - 1] == ' ' )
453     table_name[strlen(table_name) - 1] = '\0'; /* Note: if empty string, while loop will eventually exit */
454
455 /* The following part searches a table matching with the layer type specified */
456   table_matching = NULL;
457
458 /* Look for the requested table */
459   if ( !(*(table_name)) ) { /* Is the table name empty, if so, don't even search for anything, display a message */
460     cmdarg_err("No layer type specified"); /* Note, we don't exit here, but table_matching will remain NULL, so we exit below */
461   }
462   else {
463     table_matching = find_dissector_table(table_name);
464     if (!table_matching) {
465       cmdarg_err("Unknown layer type -- %s", table_name); /* Note, we don't exit here, but table_matching will remain NULL, so we exit below */
466     }
467   }
468
469   if (!table_matching) {
470     /* Display a list of supported layer types to help the user, if the
471        specified layer type was not found */
472     cmdarg_err("Valid layer types are:");
473     fprint_all_layer_types(stderr);
474   }
475   if (remaining_param == NULL || !table_matching) {
476     /* Exit if the layer type was not found, or if no '=' separator was found
477        (see above) */
478     g_free(decoded_param);
479     return FALSE;
480   }
481
482   if (*(remaining_param + 1) != '=') { /* Check for "==" and not only '=' */
483     cmdarg_err("WARNING: -d requires \"==\" instead of \"=\". Option will be treated as \"%s==%s\"", table_name, remaining_param + 1);
484   }
485   else {
486     remaining_param++; /* Move to the second '=' */
487     *remaining_param = '\0'; /* Remove the second '=' */
488   }
489   remaining_param++; /* Position after the layer type string */
490
491   /* This section extracts a selector value (selector_str) from decoded_param */
492
493   selector_str = remaining_param; /* Next part starts with the selector number */
494
495   remaining_param = strchr(selector_str, ',');
496   if (remaining_param == NULL) {
497     cmdarg_err("Parameter \"%s\" doesn't follow the template \"%s\"", cl_param, decode_as_arg_template);
498     /* If the argument does not follow the template, carry on anyway to check
499        if the selector value is at least correct.  If remaining_param is NULL,
500        we'll exit anyway further down */
501   }
502   else {
503     *remaining_param = '\0'; /* Terminate the selector number string (selector_str) where ',' was detected */
504   }
505
506   dissector_table_selector_type = get_dissector_table_selector_type(table_name);
507
508   switch (dissector_table_selector_type) {
509
510   case FT_UINT8:
511   case FT_UINT16:
512   case FT_UINT24:
513   case FT_UINT32:
514     /* The selector for this table is an unsigned number.  Parse it as such.
515        There's no need to remove leading and trailing spaces from the
516        selector number string, because sscanf will do that for us. */
517     if ( sscanf(selector_str, "%u", &selector) != 1 ) {
518       cmdarg_err("Invalid selector number \"%s\"", selector_str);
519       g_free(decoded_param);
520       return FALSE;
521     }
522     break;
523
524   case FT_STRING:
525   case FT_STRINGZ:
526   case FT_EBCDIC:
527     /* The selector for this table is a string. */
528     break;
529
530   default:
531     /* There are currently no dissector tables with any types other
532        than the ones listed above. */
533     g_assert_not_reached();
534   }
535
536   if (remaining_param == NULL) {
537     /* Exit if no ',' separator was found (see above) */
538     cmdarg_err("Valid protocols for layer type \"%s\" are:", table_name);
539     fprint_all_protocols_for_layer_types(stderr, table_name);
540     g_free(decoded_param);
541     return FALSE;
542   }
543
544   remaining_param++; /* Position after the selector number string */
545
546   /* This section extracts a protocol filter name (dissector_str) from decoded_param */
547
548   dissector_str = remaining_param; /* All the rest of the string is the dissector (decode as protocol) name */
549
550   /* Remove leading and trailing spaces from the dissector name */
551   while ( dissector_str[0] == ' ' )
552     dissector_str++;
553   while ( dissector_str[strlen(dissector_str) - 1] == ' ' )
554     dissector_str[strlen(dissector_str) - 1] = '\0'; /* Note: if empty string, while loop will eventually exit */
555
556   dissector_matching = NULL;
557
558   /* We now have a pointer to the handle for the requested table inside the variable table_matching */
559   if ( ! (*dissector_str) ) { /* Is the dissector name empty, if so, don't even search for a matching dissector and display all dissectors found for the selected table */
560     cmdarg_err("No protocol name specified"); /* Note, we don't exit here, but dissector_matching will remain NULL, so we exit below */
561   }
562   else {
563     user_protocol_name.nb_match = 0;
564     user_protocol_name.searched_name = dissector_str;
565     user_protocol_name.matched_handle = NULL;
566
567     dissector_table_foreach_handle(table_name, find_protocol_name_func, &user_protocol_name); /* Go and perform the search for this dissector in the this table's dissectors' names and shortnames */
568
569     if (user_protocol_name.nb_match != 0) {
570       dissector_matching = user_protocol_name.matched_handle;
571       if (user_protocol_name.nb_match > 1) {
572         cmdarg_err("WARNING: Protocol \"%s\" matched %u dissectors, first one will be used", dissector_str, user_protocol_name.nb_match);
573       }
574     }
575     else {
576       /* OK, check whether the problem is that there isn't any such
577          protocol, or that there is but it's not specified as a protocol
578          that's valid for that dissector table.
579          Note, we don't exit here, but dissector_matching will remain NULL,
580          so we exit below */
581       if (proto_get_id_by_filter_name(dissector_str) == -1) {
582         /* No such protocol */
583         cmdarg_err("Unknown protocol -- \"%s\"", dissector_str);
584       } else {
585         cmdarg_err("Protocol \"%s\" isn't valid for layer type \"%s\"",
586                 dissector_str, table_name);
587       }
588     }
589   }
590
591   if (!dissector_matching) {
592     cmdarg_err("Valid protocols for layer type \"%s\" are:", table_name);
593     fprint_all_protocols_for_layer_types(stderr, table_name);
594     g_free(decoded_param);
595     return FALSE;
596   }
597
598 /* This is the end of the code that parses the command-line options.
599    All information is now stored in the variables:
600    table_name
601    selector
602    dissector_matching
603    The above variables that are strings are still pointing to areas within
604    decoded_parm.  decoded_parm thus still needs to be kept allocated in
605    until we stop needing these variables
606    decoded_param will be deallocated at each exit point of this function */
607
608
609   /* We now have a pointer to the handle for the requested dissector
610      (requested protocol) inside the variable dissector_matching */
611   switch (dissector_table_selector_type) {
612
613   case FT_UINT8:
614   case FT_UINT16:
615   case FT_UINT24:
616   case FT_UINT32:
617     /* The selector for this table is an unsigned number. */
618     dissector_change(table_name, selector, dissector_matching);
619     break;
620
621   case FT_STRING:
622   case FT_STRINGZ:
623   case FT_EBCDIC:
624     /* The selector for this table is a string. */
625     dissector_change_string(table_name, selector_str, dissector_matching);
626     break;
627
628   default:
629     /* There are currently no dissector tables with any types other
630        than the ones listed above. */
631     g_assert_not_reached();
632   }
633   g_free(decoded_param); /* "Decode As" rule has been succesfully added */
634   return TRUE;
635 }
636
637 static void
638 log_func_ignore (const gchar *log_domain _U_, GLogLevelFlags log_level _U_,
639     const gchar *message _U_, gpointer user_data _U_)
640 {
641 }
642
643 static char *
644 output_file_description(const char *fname)
645 {
646   char *save_file_string;
647
648   /* Get a string that describes what we're writing to */
649   if (strcmp(fname, "-") == 0) {
650     /* We're writing to the standard output */
651     save_file_string = g_strdup("standard output");
652   } else {
653     /* We're writing to a file with the name in save_file */
654     save_file_string = g_strdup_printf("file \"%s\"", fname);
655   }
656   return save_file_string;
657 }
658
659 static void
660 print_current_user(void) {
661   gchar *cur_user, *cur_group;
662   if (started_with_special_privs()) {
663     cur_user = get_cur_username();
664     cur_group = get_cur_groupname();
665     fprintf(stderr, "Running as user \"%s\" and group \"%s\".",
666       cur_user, cur_group);
667     g_free(cur_user);
668     g_free(cur_group);
669     if (running_with_special_privs()) {
670       fprintf(stderr, " This could be dangerous.");
671     }
672     fprintf(stderr, "\n");
673   }
674 }
675
676 static void
677 check_capture_privs(void) {
678 #ifdef _WIN32
679   load_wpcap();
680   /* Warn the user if npf.sys isn't loaded. */
681   if (!npf_sys_is_running() && get_os_major_version() >= 6) {
682     fprintf(stderr, "The NPF driver isn't running.  You may have trouble "
683       "capturing or\nlisting interfaces.\n");
684   }
685 #endif
686 }
687
688
689
690 int
691 main(int argc, char *argv[])
692 {
693   char                *init_progfile_dir_error;
694   int                  opt, i;
695   extern char         *optarg;
696   gboolean             arg_error = FALSE;
697
698 #ifdef _WIN32
699   WSADATA               wsaData;
700 #endif  /* _WIN32 */
701
702   char                *gpf_path, *pf_path;
703   char                *gdp_path, *dp_path;
704   int                  gpf_open_errno, gpf_read_errno;
705   int                  pf_open_errno, pf_read_errno;
706   int                  gdp_open_errno, gdp_read_errno;
707   int                  dp_open_errno, dp_read_errno;
708   int                  err;
709 #ifdef HAVE_LIBPCAP
710   gboolean             list_link_layer_types = FALSE;
711   gboolean             start_capture = FALSE;
712   int                  status;
713 #else
714   gboolean             capture_option_specified = FALSE;
715 #endif
716   gboolean             quiet = FALSE;
717   int                  out_file_type = WTAP_FILE_PCAP;
718   gchar               *cf_name = NULL, *rfilter = NULL;
719 #ifdef HAVE_PCAP_OPEN_DEAD
720   struct bpf_program   fcode;
721 #endif
722   dfilter_t           *rfcode = NULL;
723   e_prefs             *prefs;
724   char                 badopt;
725   GLogLevelFlags       log_flags;
726   int                  optind_initial;
727
728 #define OPTSTRING_INIT "a:b:c:d:De:E:f:F:G:hi:lLnN:o:pqr:R:s:St:T:vVw:xX:y:z:"
729 #ifdef HAVE_LIBPCAP
730 #ifdef _WIN32
731 #define OPTSTRING_WIN32 "B:"
732 #else
733 #define OPTSTRING_WIN32 ""
734 #endif  /* _WIN32 */
735 #else
736 #define OPTSTRING_WIN32 ""
737 #endif  /* HAVE_LIBPCAP */
738
739   static const char    optstring[] = OPTSTRING_INIT OPTSTRING_WIN32;
740
741   /*
742    * Get credential information for later use.
743    */
744   get_credential_info();
745
746   /*
747    * Attempt to get the pathname of the executable file.
748    */
749   init_progfile_dir_error = init_progfile_dir(argv[0]);
750   if (init_progfile_dir_error != NULL) {
751     fprintf(stderr, "tshark: Can't get pathname of tshark program: %s.\n",
752             init_progfile_dir_error);
753   }
754
755   /*
756    * In order to have the -X opts assigned before the wslua machine starts
757    * we need to call getopts before epan_init() gets called.
758    */
759   opterr = 0;
760   optind_initial = optind;
761
762   while ((opt = getopt(argc, argv, optstring)) != -1) {
763           switch (opt) {
764                   case 'X':
765                           ex_opt_add(optarg);
766                           break;
767                   default:
768                           break;
769           }
770   }
771
772   optind = optind_initial;
773   opterr = 1;
774
775   /* nothing more than the standard GLib handler, but without a warning */
776   log_flags =
777                     G_LOG_LEVEL_WARNING|
778                     G_LOG_LEVEL_MESSAGE|
779                     G_LOG_LEVEL_INFO|
780                     G_LOG_LEVEL_DEBUG;
781
782   g_log_set_handler(NULL,
783                     log_flags,
784                     log_func_ignore, NULL /* user_data */);
785   g_log_set_handler(LOG_DOMAIN_CAPTURE,
786                     log_flags,
787                     log_func_ignore, NULL /* user_data */);
788
789   initialize_funnel_ops();
790
791 #ifdef HAVE_LIBPCAP
792   capture_opts_init(&capture_opts, NULL /* cfile */);
793 #endif
794
795   timestamp_set_type(TS_RELATIVE);
796   timestamp_set_precision(TS_PREC_AUTO);
797
798   /* Register all dissectors; we must do this before checking for the
799      "-G" flag, as the "-G" flag dumps information registered by the
800      dissectors, and we must do it before we read the preferences, in
801      case any dissectors register preferences. */
802   epan_init(register_all_protocols, register_all_protocol_handoffs, NULL, NULL,
803             failure_message, open_failure_message, read_failure_message);
804
805   /* Register all tap listeners; we do this before we parse the arguments,
806      as the "-z" argument can specify a registered tap. */
807
808   /* we register the plugin taps before the other taps because
809      stats_tree taps plugins will be registered as tap listeners
810      by stats_tree_stat.c and need to registered before that */
811 #ifdef HAVE_PLUGINS
812   register_all_plugin_tap_listeners();
813 #endif
814   register_all_tap_listeners();
815
816   /* Now register the preferences for any non-dissector modules.
817      We must do that before we read the preferences as well. */
818   prefs_register_modules();
819
820   /* If invoked with the "-G" flag, we dump out information based on
821      the argument to the "-G" flag; if no argument is specified,
822      for backwards compatibility we dump out a glossary of display
823      filter symbols.
824
825      XXX - we do this here, for now, to support "-G" with no arguments.
826      If none of our build or other processes uses "-G" with no arguments,
827      we can just process it with the other arguments. */
828   if (argc >= 2 && strcmp(argv[1], "-G") == 0) {
829     if (argc == 2)
830       proto_registrar_dump_fields(1);
831     else {
832       if (strcmp(argv[2], "fields") == 0)
833         proto_registrar_dump_fields(1);
834       else if (strcmp(argv[2], "fields2") == 0)
835         proto_registrar_dump_fields(2);
836       else if (strcmp(argv[2], "fields3") == 0)
837         proto_registrar_dump_fields(3);
838       else if (strcmp(argv[2], "protocols") == 0)
839         proto_registrar_dump_protocols();
840       else if (strcmp(argv[2], "values") == 0)
841         proto_registrar_dump_values();
842       else if (strcmp(argv[2], "decodes") == 0)
843         dissector_dump_decodes();
844       else if (strcmp(argv[2], "defaultprefs") == 0)
845         write_prefs(NULL);
846       else if (strcmp(argv[2], "currentprefs") == 0) {
847         read_prefs(&gpf_open_errno, &gpf_read_errno, &gpf_path,
848             &pf_open_errno, &pf_read_errno, &pf_path);
849         write_prefs(NULL);
850       } else {
851         cmdarg_err("Invalid \"%s\" option for -G flag", argv[2]);
852         exit(1);
853       }
854     }
855     exit(0);
856   }
857
858   /* Set the C-language locale to the native environment. */
859   setlocale(LC_ALL, "");
860
861   prefs = read_prefs(&gpf_open_errno, &gpf_read_errno, &gpf_path,
862                      &pf_open_errno, &pf_read_errno, &pf_path);
863   if (gpf_path != NULL) {
864     if (gpf_open_errno != 0) {
865       cmdarg_err("Can't open global preferences file \"%s\": %s.",
866               pf_path, strerror(gpf_open_errno));
867     }
868     if (gpf_read_errno != 0) {
869       cmdarg_err("I/O error reading global preferences file \"%s\": %s.",
870               pf_path, strerror(gpf_read_errno));
871     }
872   }
873   if (pf_path != NULL) {
874     if (pf_open_errno != 0) {
875       cmdarg_err("Can't open your preferences file \"%s\": %s.", pf_path,
876               strerror(pf_open_errno));
877     }
878     if (pf_read_errno != 0) {
879       cmdarg_err("I/O error reading your preferences file \"%s\": %s.",
880               pf_path, strerror(pf_read_errno));
881     }
882     g_free(pf_path);
883     pf_path = NULL;
884   }
885
886   /* Set the name resolution code's flags from the preferences. */
887   g_resolv_flags = prefs->name_resolve;
888
889   /* Read the disabled protocols file. */
890   read_disabled_protos_list(&gdp_path, &gdp_open_errno, &gdp_read_errno,
891                             &dp_path, &dp_open_errno, &dp_read_errno);
892   if (gdp_path != NULL) {
893     if (gdp_open_errno != 0) {
894       cmdarg_err("Could not open global disabled protocols file\n\"%s\": %s.",
895                  gdp_path, strerror(gdp_open_errno));
896     }
897     if (gdp_read_errno != 0) {
898       cmdarg_err("I/O error reading global disabled protocols file\n\"%s\": %s.",
899                  gdp_path, strerror(gdp_read_errno));
900     }
901     g_free(gdp_path);
902   }
903   if (dp_path != NULL) {
904     if (dp_open_errno != 0) {
905       cmdarg_err(
906         "Could not open your disabled protocols file\n\"%s\": %s.", dp_path,
907         strerror(dp_open_errno));
908     }
909     if (dp_read_errno != 0) {
910       cmdarg_err(
911         "I/O error reading your disabled protocols file\n\"%s\": %s.", dp_path,
912         strerror(dp_read_errno));
913     }
914     g_free(dp_path);
915   }
916
917   check_capture_privs();
918
919   init_cap_file(&cfile);
920
921   /* Assemble the compile-time version information string */
922   comp_info_str = g_string_new("Compiled ");
923   get_compiled_version_info(comp_info_str, get_epan_compiled_version_info);
924
925   /* Assemble the run-time version information string */
926   runtime_info_str = g_string_new("Running ");
927   get_runtime_version_info(runtime_info_str, NULL);
928
929   /* Print format defaults to this. */
930   print_format = PR_FMT_TEXT;
931
932   output_fields = output_fields_new();
933
934   /* Now get our args */
935   while ((opt = getopt(argc, argv, optstring)) != -1) {
936     switch (opt) {
937       case 'a':        /* autostop criteria */
938       case 'b':        /* Ringbuffer option */
939       case 'c':        /* Capture x packets */
940       case 'f':        /* capture filter */
941       case 'i':        /* Use interface x */
942       case 'p':        /* Don't capture in promiscuous mode */
943       case 's':        /* Set the snapshot (capture) length */
944       case 'w':        /* Write to capture file x */
945       case 'y':        /* Set the pcap data link type */
946 #ifdef _WIN32
947       case 'B':        /* Buffer size */
948 #endif /* _WIN32 */
949 #ifdef HAVE_LIBPCAP
950         status = capture_opts_add_opt(&capture_opts, opt, optarg, &start_capture);
951         if(status != 0) {
952             exit(status);
953         }
954 #else
955         capture_option_specified = TRUE;
956         arg_error = TRUE;
957 #endif
958         break;
959       case 'd':        /* Decode as rule */
960         if (!add_decode_as(optarg))
961           exit(1);
962         break;
963       case 'D':        /* Print a list of capture devices and exit */
964 #ifdef HAVE_LIBPCAP
965         status = capture_opts_list_interfaces(FALSE);
966         exit(status);
967 #else
968         capture_option_specified = TRUE;
969         arg_error = TRUE;
970 #endif
971         break;
972       case 'e':
973         /* Field entry */
974         output_fields_add(output_fields, optarg);
975         break;
976       case 'E':
977         /* Field option */
978         if(!output_fields_set_option(output_fields, optarg)) {
979           cmdarg_err("\"%s\" is not a valid field output option=value pair.", optarg);
980           output_fields_list_options(stderr);
981           exit(1);
982         }
983         break;
984       case 'F':
985         out_file_type = wtap_short_string_to_file_type(optarg);
986         if (out_file_type < 0) {
987           cmdarg_err("\"%s\" isn't a valid capture file type", optarg);
988           list_capture_types();
989           exit(1);
990         }
991         break;
992       case 'h':        /* Print help and exit */
993         print_usage(TRUE);
994         exit(0);
995         break;
996       case 'l':        /* "Line-buffer" standard output */
997         /* This isn't line-buffering, strictly speaking, it's just
998            flushing the standard output after the information for
999            each packet is printed; however, that should be good
1000            enough for all the purposes to which "-l" is put (and
1001            is probably actually better for "-V", as it does fewer
1002            writes).
1003
1004            See the comment in "process_packet()" for an explanation of
1005            why we do that, and why we don't just use "setvbuf()" to
1006            make the standard output line-buffered (short version: in
1007            Windows, "line-buffered" is the same as "fully-buffered",
1008            and the output buffer is only flushed when it fills up). */
1009         line_buffered = TRUE;
1010         break;
1011       case 'L':        /* Print list of link-layer types and exit */
1012 #ifdef HAVE_LIBPCAP
1013         list_link_layer_types = TRUE;
1014 #else
1015         capture_option_specified = TRUE;
1016         arg_error = TRUE;
1017 #endif
1018         break;
1019       case 'n':        /* No name resolution */
1020         g_resolv_flags = RESOLV_NONE;
1021         break;
1022       case 'N':        /* Select what types of addresses/port #s to resolve */
1023         if (g_resolv_flags == RESOLV_ALL)
1024           g_resolv_flags = RESOLV_NONE;
1025         badopt = string_to_name_resolve(optarg, &g_resolv_flags);
1026         if (badopt != '\0') {
1027           cmdarg_err("-N specifies unknown resolving option '%c';",
1028                      badopt);
1029           cmdarg_err_cont( "           Valid options are 'm', 'n', 't', and 'C'");
1030           exit(1);
1031         }
1032         break;
1033       case 'o':        /* Override preference from command line */
1034         switch (prefs_set_pref(optarg)) {
1035
1036         case PREFS_SET_OK:
1037           break;
1038
1039         case PREFS_SET_SYNTAX_ERR:
1040           cmdarg_err("Invalid -o flag \"%s\"", optarg);
1041           exit(1);
1042           break;
1043
1044         case PREFS_SET_NO_SUCH_PREF:
1045         case PREFS_SET_OBSOLETE:
1046           cmdarg_err("-o flag \"%s\" specifies unknown preference", optarg);
1047           exit(1);
1048           break;
1049         }
1050         break;
1051       case 'q':        /* Quiet */
1052         quiet = TRUE;
1053         break;
1054       case 'r':        /* Read capture file x */
1055         cf_name = g_strdup(optarg);
1056         break;
1057       case 'R':        /* Read file filter */
1058         rfilter = optarg;
1059         break;
1060       case 'S':        /* show packets in real time */
1061         print_packet_info = TRUE;
1062         break;
1063       case 't':        /* Time stamp type */
1064         if (strcmp(optarg, "r") == 0)
1065           timestamp_set_type(TS_RELATIVE);
1066         else if (strcmp(optarg, "a") == 0)
1067           timestamp_set_type(TS_ABSOLUTE);
1068         else if (strcmp(optarg, "ad") == 0)
1069           timestamp_set_type(TS_ABSOLUTE_WITH_DATE);
1070         else if (strcmp(optarg, "d") == 0)
1071           timestamp_set_type(TS_DELTA);
1072         else if (strcmp(optarg, "dd") == 0)
1073           timestamp_set_type(TS_DELTA_DIS);
1074         else if (strcmp(optarg, "e") == 0)
1075           timestamp_set_type(TS_EPOCH);
1076         else {
1077           cmdarg_err("Invalid time stamp type \"%s\"",
1078             optarg);
1079           cmdarg_err_cont("It must be \"r\" for relative, \"a\" for absolute,");
1080           cmdarg_err_cont("\"ad\" for absolute with date, or \"d\" for delta.");
1081           exit(1);
1082         }
1083         break;
1084       case 'T':        /* printing Type */
1085         if (strcmp(optarg, "text") == 0) {
1086           output_action = WRITE_TEXT;
1087           print_format = PR_FMT_TEXT;
1088         } else if (strcmp(optarg, "ps") == 0) {
1089           output_action = WRITE_TEXT;
1090           print_format = PR_FMT_PS;
1091         } else if (strcmp(optarg, "pdml") == 0) {
1092           output_action = WRITE_XML;
1093           verbose = TRUE;
1094         } else if (strcmp(optarg, "psml") == 0) {
1095           output_action = WRITE_XML;
1096           verbose = FALSE;
1097         } else if(strcmp(optarg, "fields") == 0) {
1098           output_action = WRITE_FIELDS;
1099           verbose = TRUE; /* Need full tree info */
1100         } else {
1101           cmdarg_err("Invalid -T parameter.");
1102           cmdarg_err_cont("It must be \"ps\", \"text\", \"pdml\", \"psml\" or \"fields\".");
1103           exit(1);
1104         }
1105         break;
1106       case 'v':        /* Show version and exit */
1107         printf("TShark " VERSION "%s\n"
1108                "\n"
1109                "%s"
1110                "\n"
1111                "%s"
1112                "\n"
1113                "%s",
1114                wireshark_svnversion, get_copyright_info(), comp_info_str->str,
1115                runtime_info_str->str);
1116         exit(0);
1117         break;
1118       case 'V':        /* Verbose */
1119         verbose = TRUE;
1120         break;
1121       case 'x':        /* Print packet data in hex (and ASCII) */
1122           print_hex = TRUE;
1123           break;
1124       case 'X':
1125           break;
1126       case 'z':
1127         /* We won't call the init function for the stat this soon
1128            as it would disallow MATE's fields (which are registered
1129            by the preferences set callback) from being used as
1130            part of a tap filter.  Instead, we just add the argument
1131            to a list of stat arguments. */
1132         if (!process_stat_cmd_arg(optarg)) {
1133           cmdarg_err("invalid -z argument.");
1134           cmdarg_err_cont("  -z argument must be one of :");
1135           list_stat_cmd_args();
1136           exit(1);
1137         }
1138         break;
1139       default:
1140       case '?':        /* Bad flag - print usage message */
1141         switch(optopt) {
1142         case 'F':
1143           list_capture_types();
1144           break;
1145         default:
1146           print_usage(TRUE);
1147         }
1148         exit(1);
1149         break;
1150     }
1151   }
1152
1153   /* If we specified output fields, but not the output field type... */
1154   if(WRITE_FIELDS != output_action && 0 != output_fields_num_fields(output_fields)) {
1155         cmdarg_err("Output fields were specified with \"-e\", "
1156             "but \"-Tfields\" was not specified.");
1157         exit(1);
1158   } else if(WRITE_FIELDS == output_action && 0 == output_fields_num_fields(output_fields)) {
1159         cmdarg_err("\"-Tfields\" was specified, but no fields were "
1160                     "specified with \"-e\".");
1161
1162         exit(1);
1163   }
1164
1165   /* If no capture filter or read filter has been specified, and there are
1166      still command-line arguments, treat them as the tokens of a capture
1167      filter (if no "-r" flag was specified) or a read filter (if a "-r"
1168      flag was specified. */
1169   if (optind < argc) {
1170     if (cf_name != NULL) {
1171       if (rfilter != NULL) {
1172         cmdarg_err("Read filters were specified both with \"-R\" "
1173             "and with additional command-line arguments");
1174         exit(1);
1175       }
1176       rfilter = get_args_as_string(argc, argv, optind);
1177     } else {
1178 #ifdef HAVE_LIBPCAP
1179       if (capture_opts.has_cfilter) {
1180         cmdarg_err("Capture filters were specified both with \"-f\""
1181             " and with additional command-line arguments");
1182         exit(1);
1183       }
1184       capture_opts.has_cfilter = TRUE;
1185       capture_opts.cfilter = get_args_as_string(argc, argv, optind);
1186 #else
1187       capture_option_specified = TRUE;
1188 #endif
1189     }
1190   }
1191
1192 #ifdef HAVE_LIBPCAP
1193   if (!capture_opts.saving_to_file) {
1194     /* We're not saving the capture to a file; if "-q" wasn't specified,
1195        we should print packet information */
1196     if (!quiet)
1197       print_packet_info = TRUE;
1198   } else {
1199     /* We're saving to a file; if we're writing to the standard output.
1200        and we'll also be writing dissected packets to the standard
1201        output, reject the request.  At best, we could redirect that
1202        to the standard error; we *can't* write both to the standard
1203        output and have either of them be useful. */
1204     if (strcmp(capture_opts.save_file, "-") == 0 && print_packet_info) {
1205       cmdarg_err("You can't write both raw packet data and dissected packets"
1206           " to the standard output.");
1207       exit(1);
1208     }
1209   }
1210 #else
1211   /* We're not saving the capture to a file; if "-q" wasn't specified,
1212      we should print packet information */
1213   if (!quiet)
1214     print_packet_info = TRUE;
1215 #endif
1216
1217 #ifndef HAVE_LIBPCAP
1218   if (capture_option_specified)
1219     cmdarg_err("This version of TShark was not built with support for capturing packets.");
1220 #endif
1221   if (arg_error) {
1222     print_usage(FALSE);
1223     exit(1);
1224   }
1225
1226   /* We don't support capture filters when reading from a capture file
1227      (the BPF compiler doesn't support all link-layer types that we
1228      support in capture files we read). */
1229 #ifdef HAVE_LIBPCAP
1230   if (cf_name != NULL) {
1231     if (capture_opts.has_cfilter) {
1232       cmdarg_err("Only read filters, not capture filters, "
1233           "can be specified when reading a capture file.");
1234       exit(1);
1235     }
1236   }
1237 #endif
1238
1239   if (print_hex) {
1240     if (output_action != WRITE_TEXT) {
1241       cmdarg_err("Raw packet hex data can only be printed as text or PostScript");
1242       exit(1);
1243     }
1244   }
1245
1246 #ifdef HAVE_LIBPCAP
1247   if (list_link_layer_types) {
1248     /* We're supposed to list the link-layer types for an interface;
1249        did the user also specify a capture file to be read? */
1250     if (cf_name) {
1251       /* Yes - that's bogus. */
1252       cmdarg_err("You can't specify -L and a capture file to be read.");
1253       exit(1);
1254     }
1255     /* No - did they specify a ring buffer option? */
1256     if (capture_opts.multi_files_on) {
1257       cmdarg_err("Ring buffer requested, but a capture isn't being done.");
1258       exit(1);
1259     }
1260   } else {
1261     if (cf_name) {
1262       /*
1263        * "-r" was specified, so we're reading a capture file.
1264        * Capture options don't apply here.
1265        */
1266       if (capture_opts.multi_files_on) {
1267         cmdarg_err("Multiple capture files requested, but "
1268                    "a capture isn't being done.");
1269         exit(1);
1270       }
1271       if (capture_opts.has_file_duration) {
1272         cmdarg_err("Switching capture files after a time interval was specified, but "
1273                    "a capture isn't being done.");
1274         exit(1);
1275       }
1276       if (capture_opts.has_ring_num_files) {
1277         cmdarg_err("A ring buffer of capture files was specified, but "
1278           "a capture isn't being done.");
1279         exit(1);
1280       }
1281       if (capture_opts.has_autostop_files) {
1282         cmdarg_err("A maximum number of capture files was specified, but "
1283           "a capture isn't being done.");
1284         exit(1);
1285       }
1286
1287       /* Note: TShark now allows the restriction of a _read_ file by packet count
1288        * and byte count as well as a write file. Other autostop options remain valid
1289        * only for a write file.
1290        */
1291       if (capture_opts.has_autostop_duration) {
1292         cmdarg_err("A maximum capture time was specified, but "
1293           "a capture isn't being done.");
1294         exit(1);
1295       }
1296     } else {
1297       /*
1298        * "-r" wasn't specified, so we're doing a live capture.
1299        */
1300       if (capture_opts.saving_to_file) {
1301         /* They specified a "-w" flag, so we'll be saving to a capture file. */
1302
1303         /* When capturing, we only support writing libpcap format. */
1304         if (out_file_type != WTAP_FILE_PCAP) {
1305           cmdarg_err("Live captures can only be saved in libpcap format.");
1306           exit(1);
1307         }
1308         if (capture_opts.multi_files_on) {
1309           /* Multiple-file mode doesn't work under certain conditions:
1310              a) it doesn't work if you're writing to the standard output;
1311              b) it doesn't work if you're writing to a pipe;
1312           */
1313           if (strcmp(capture_opts.save_file, "-") == 0) {
1314             cmdarg_err("Multiple capture files requested, but "
1315               "the capture is being written to the standard output.");
1316             exit(1);
1317           }
1318           if (capture_opts.output_to_pipe) {
1319             cmdarg_err("Multiple capture files requested, but "
1320               "the capture file is a pipe.");
1321             exit(1);
1322           }
1323           if (!capture_opts.has_autostop_filesize &&
1324               !capture_opts.has_file_duration) {
1325             cmdarg_err("Multiple capture files requested, but "
1326               "no maximum capture file size or duration was specified.");
1327             exit(1);
1328           }
1329         }
1330       } else {
1331         /* They didn't specify a "-w" flag, so we won't be saving to a
1332            capture file.  Check for options that only make sense if
1333            we're saving to a file. */
1334         if (capture_opts.has_autostop_filesize) {
1335           cmdarg_err("Maximum capture file size specified, but "
1336            "capture isn't being saved to a file.");
1337           exit(1);
1338         }
1339         if (capture_opts.multi_files_on) {
1340           cmdarg_err("Multiple capture files requested, but "
1341             "the capture isn't being saved to a file.");
1342           exit(1);
1343         }
1344       }
1345     }
1346   }
1347 #endif
1348
1349 #ifdef _WIN32
1350   /* Start windows sockets */
1351   WSAStartup( MAKEWORD( 1, 1 ), &wsaData );
1352 #endif /* _WIN32 */
1353
1354   /* Notify all registered modules that have had any of their preferences
1355      changed either from one of the preferences file or from the command
1356      line that their preferences have changed. */
1357   prefs_apply_all();
1358
1359   /* At this point MATE will have registered its field array so we can
1360      have a tap filter with one of MATE's late-registered fields as part
1361      of the filter.  We can now process all the "-z" arguments. */
1362   start_requested_stats();
1363
1364   /* disabled protocols as per configuration file */
1365   if (gdp_path == NULL && dp_path == NULL) {
1366     set_disabled_protos_list();
1367   }
1368
1369   /* Build the column format array */
1370   col_setup(&cfile.cinfo, prefs->num_cols);
1371   for (i = 0; i < cfile.cinfo.num_cols; i++) {
1372     cfile.cinfo.col_fmt[i] = get_column_format(i);
1373     cfile.cinfo.col_title[i] = g_strdup(get_column_title(i));
1374     cfile.cinfo.fmt_matx[i] = (gboolean *) g_malloc0(sizeof(gboolean) *
1375       NUM_COL_FMTS);
1376     get_column_format_matches(cfile.cinfo.fmt_matx[i], cfile.cinfo.col_fmt[i]);
1377     cfile.cinfo.col_data[i] = NULL;
1378     if (cfile.cinfo.col_fmt[i] == COL_INFO)
1379       cfile.cinfo.col_buf[i] = (gchar *) g_malloc(sizeof(gchar) * COL_MAX_INFO_LEN);
1380     else
1381       cfile.cinfo.col_buf[i] = (gchar *) g_malloc(sizeof(gchar) * COL_MAX_LEN);
1382     cfile.cinfo.col_fence[i] = 0;
1383     cfile.cinfo.col_expr[i] = (gchar *) g_malloc(sizeof(gchar) * COL_MAX_LEN);
1384     cfile.cinfo.col_expr_val[i] = (gchar *) g_malloc(sizeof(gchar) * COL_MAX_LEN);
1385   }
1386
1387   for (i = 0; i < cfile.cinfo.num_cols; i++) {
1388       int j;
1389
1390       for (j = 0; j < NUM_COL_FMTS; j++) {
1391          if (!cfile.cinfo.fmt_matx[i][j])
1392              continue;
1393
1394          if (cfile.cinfo.col_first[j] == -1)
1395              cfile.cinfo.col_first[j] = i;
1396          cfile.cinfo.col_last[j] = i;
1397       }
1398   }
1399
1400 #ifdef HAVE_LIBPCAP
1401   capture_opts_trim_snaplen(&capture_opts, MIN_PACKET_SIZE);
1402   capture_opts_trim_ring_num_files(&capture_opts);
1403 #endif
1404
1405   if (rfilter != NULL) {
1406     if (!dfilter_compile(rfilter, &rfcode)) {
1407       cmdarg_err("%s", dfilter_error_msg);
1408       epan_cleanup();
1409 #ifdef HAVE_PCAP_OPEN_DEAD
1410       {
1411         pcap_t *pc;
1412
1413         pc = pcap_open_dead(DLT_EN10MB, MIN_PACKET_SIZE);
1414         if (pc != NULL) {
1415           if (pcap_compile(pc, &fcode, rfilter, 0, 0) != -1) {
1416             cmdarg_err_cont(
1417               "  Note: That display filter code looks like a valid capture filter;");
1418             cmdarg_err_cont(
1419               "        maybe you mixed them up?");
1420           }
1421           pcap_close(pc);
1422         }
1423       }
1424 #endif
1425       exit(2);
1426     }
1427   }
1428   cfile.rfcode = rfcode;
1429
1430   if (print_packet_info) {
1431     /* If we're printing as text or PostScript, we have
1432        to create a print stream. */
1433     if (output_action == WRITE_TEXT) {
1434       switch (print_format) {
1435
1436       case PR_FMT_TEXT:
1437         print_stream = print_stream_text_stdio_new(stdout);
1438         break;
1439
1440       case PR_FMT_PS:
1441         print_stream = print_stream_ps_stdio_new(stdout);
1442         break;
1443
1444       default:
1445         g_assert_not_reached();
1446       }
1447     }
1448   }
1449
1450   /* We have to dissect each packet if:
1451
1452         we're printing information about each packet;
1453
1454         we're using a read filter on the packets;
1455
1456         we're using any taps. */
1457   do_dissection = print_packet_info || rfcode || have_tap_listeners();
1458
1459   if (cf_name) {
1460     /*
1461      * We're reading a capture file.
1462      */
1463
1464     /*
1465      * Immediately relinquish any special privileges we have; we must not
1466      * be allowed to read any capture files the user running TShark
1467      * can't open.
1468      */
1469     relinquish_special_privs_perm();
1470     print_current_user();
1471
1472     if (cf_open(&cfile, cf_name, FALSE, &err) != CF_OK) {
1473       epan_cleanup();
1474       exit(2);
1475     }
1476
1477     /* Set timestamp precision; there should arguably be a command-line
1478        option to let the user set this. */
1479     switch(wtap_file_tsprecision(cfile.wth)) {
1480     case(WTAP_FILE_TSPREC_SEC):
1481       timestamp_set_precision(TS_PREC_AUTO_SEC);
1482       break;
1483     case(WTAP_FILE_TSPREC_DSEC):
1484       timestamp_set_precision(TS_PREC_AUTO_DSEC);
1485       break;
1486     case(WTAP_FILE_TSPREC_CSEC):
1487       timestamp_set_precision(TS_PREC_AUTO_CSEC);
1488       break;
1489     case(WTAP_FILE_TSPREC_MSEC):
1490       timestamp_set_precision(TS_PREC_AUTO_MSEC);
1491       break;
1492     case(WTAP_FILE_TSPREC_USEC):
1493       timestamp_set_precision(TS_PREC_AUTO_USEC);
1494       break;
1495     case(WTAP_FILE_TSPREC_NSEC):
1496       timestamp_set_precision(TS_PREC_AUTO_NSEC);
1497       break;
1498     default:
1499       g_assert_not_reached();
1500     }
1501
1502     /* Process the packets in the file */
1503 #ifdef HAVE_LIBPCAP
1504     err = load_cap_file(&cfile, capture_opts.save_file, out_file_type,
1505         capture_opts.has_autostop_packets ? capture_opts.autostop_packets : 0,
1506         capture_opts.has_autostop_filesize ? capture_opts.autostop_filesize : 0);
1507 #else
1508     err = load_cap_file(&cfile, NULL, out_file_type, 0, 0);
1509 #endif
1510     if (err != 0) {
1511       epan_cleanup();
1512       exit(2);
1513     }
1514     cf_name[0] = '\0';
1515   } else {
1516     /* No capture file specified, so we're supposed to do a live capture
1517        (or get a list of link-layer types for a live capture device);
1518        do we have support for live captures? */
1519 #ifdef HAVE_LIBPCAP
1520
1521 #ifdef _WIN32
1522     if (!has_wpcap) {
1523       char *detailed_err;
1524
1525       cmdarg_err("WinPcap couldn't be found.");
1526       detailed_err = cant_load_winpcap_err("TShark");
1527       cmdarg_err_cont("%s", detailed_err);
1528       g_free(detailed_err);
1529       exit(2);
1530     }
1531 #endif
1532
1533     /* trim the interface name and exit if that failed */
1534     if (!capture_opts_trim_iface(&capture_opts,
1535         (prefs->capture_device) ? get_if_name(prefs->capture_device) : NULL)) {
1536         exit(2);
1537     }
1538
1539     /* if requested, list the link layer types and exit */
1540     if (list_link_layer_types) {
1541         status = capture_opts_list_link_layer_types(&capture_opts, FALSE);
1542         exit(status);
1543     }
1544
1545     if (print_packet_info) {
1546       if (!write_preamble(NULL)) {
1547         err = errno;
1548         show_print_file_io_error(err);
1549         return err;
1550       }
1551     } else if (!quiet) {
1552       /*
1553        * We're not printing information for each packet, and the user
1554        * didn't ask us not to print a count of packets as they arrive,
1555        * so print that count so the user knows that packets are arriving.
1556        *
1557        * XXX - what if the user wants to do a live capture, doesn't want
1558        * to save it to a file, doesn't want information printed for each
1559        * packet, does want some "-z" statistic, and wants packet counts
1560        * so they know whether they're seeing any packets?
1561        */
1562       print_packet_counts = TRUE;
1563     }
1564
1565     /* For now, assume libpcap gives microsecond precision. */
1566     timestamp_set_precision(TS_PREC_AUTO_USEC);
1567
1568     capture();
1569
1570     if (print_packet_info) {
1571       if (!write_finale()) {
1572         err = errno;
1573         show_print_file_io_error(err);
1574       }
1575     }
1576 #else
1577     /* No - complain. */
1578     cmdarg_err("This version of TShark was not built with support for capturing packets.");
1579     exit(2);
1580 #endif
1581   }
1582
1583   draw_tap_listeners(TRUE);
1584   funnel_dump_all_text_windows();
1585   epan_cleanup();
1586
1587   output_fields_free(output_fields);
1588   output_fields = NULL;
1589
1590   return 0;
1591 }
1592
1593 /*#define USE_BROKEN_G_MAIN_LOOP*/
1594
1595 #ifdef USE_BROKEN_G_MAIN_LOOP
1596   GMainLoop *loop;
1597 #else
1598   gboolean loop_running = FALSE;
1599 #endif
1600   guint32 packet_count = 0;
1601
1602
1603 /* XXX - move to the right position / file */
1604 /* read from a pipe (callback) */
1605 typedef gboolean (*pipe_input_cb_t) (gint source, gpointer user_data);
1606
1607 typedef struct pipe_input_tag {
1608     gint                source;
1609     gpointer            user_data;
1610     int                 *child_process;
1611     pipe_input_cb_t     input_cb;
1612     guint               pipe_input_id;
1613 #ifdef _WIN32
1614     GStaticMutex                callback_running;
1615 #endif
1616 } pipe_input_t;
1617
1618 static pipe_input_t pipe_input;
1619
1620 #ifdef _WIN32
1621 /* The timer has expired, see if there's stuff to read from the pipe,
1622    if so, do the callback */
1623 static gint
1624 pipe_timer_cb(gpointer data)
1625 {
1626   HANDLE handle;
1627   DWORD avail = 0;
1628   gboolean result, result1;
1629   DWORD childstatus;
1630   pipe_input_t *pipe_input = data;
1631   gint iterations = 0;
1632
1633
1634   g_static_mutex_lock (&pipe_input->callback_running);
1635
1636   /* try to read data from the pipe only 5 times, to avoid blocking */
1637   while(iterations < 5) {
1638           /*g_log(NULL, G_LOG_LEVEL_DEBUG, "pipe_timer_cb: new iteration");*/
1639
1640           /* Oddly enough although Named pipes don't work on win9x,
1641                  PeekNamedPipe does !!! */
1642           handle = (HANDLE) _get_osfhandle (pipe_input->source);
1643           result = PeekNamedPipe(handle, NULL, 0, NULL, &avail, NULL);
1644
1645           /* Get the child process exit status */
1646           result1 = GetExitCodeProcess((HANDLE)*(pipe_input->child_process),
1647                                                                    &childstatus);
1648
1649           /* If the Peek returned an error, or there are bytes to be read
1650                  or the childwatcher thread has terminated then call the normal
1651                  callback */
1652           if (!result || avail > 0 || childstatus != STILL_ACTIVE) {
1653
1654                 /*g_log(NULL, G_LOG_LEVEL_DEBUG, "pipe_timer_cb: data avail");*/
1655
1656                 /* And call the real handler */
1657                 if (!pipe_input->input_cb(pipe_input->source, pipe_input->user_data)) {
1658                         g_log(NULL, G_LOG_LEVEL_DEBUG, "pipe_timer_cb: input pipe closed, iterations: %u", iterations);
1659                         /* pipe closed, return false so that the timer is stopped */
1660                         g_static_mutex_unlock (&pipe_input->callback_running);
1661                         return FALSE;
1662                 }
1663           }
1664           else {
1665                 /*g_log(NULL, G_LOG_LEVEL_DEBUG, "pipe_timer_cb: no data avail");*/
1666                 /* No data, stop now */
1667                 break;
1668           }
1669
1670           iterations++;
1671   }
1672
1673         /*g_log(NULL, G_LOG_LEVEL_DEBUG, "pipe_timer_cb: finished with iterations: %u, new timer", iterations);*/
1674
1675         g_static_mutex_unlock (&pipe_input->callback_running);
1676
1677         /* we didn't stopped the timer, so let it run */
1678         return TRUE;
1679 }
1680 #endif
1681
1682
1683 void
1684 pipe_input_set_handler(gint source, gpointer user_data, int *child_process, pipe_input_cb_t input_cb)
1685 {
1686
1687     pipe_input.source                   = source;
1688     pipe_input.child_process            = child_process;
1689     pipe_input.user_data                = user_data;
1690     pipe_input.input_cb                 = input_cb;
1691
1692 #ifdef _WIN32
1693     g_static_mutex_init(&pipe_input.callback_running);
1694     /* Tricky to use pipes in win9x, as no concept of wait.  NT can
1695        do this but that doesn't cover all win32 platforms.  GTK can do
1696        this but doesn't seem to work over processes.  Attempt to do
1697        something similar here, start a timer and check for data on every
1698        timeout. */
1699         /*g_log(NULL, G_LOG_LEVEL_DEBUG, "pipe_input_set_handler: new");*/
1700     pipe_input.pipe_input_id = g_timeout_add(200, pipe_timer_cb, &pipe_input);
1701 #endif
1702 }
1703
1704
1705 #ifdef HAVE_LIBPCAP
1706 static int
1707 capture(void)
1708 {
1709   gboolean ret;
1710 #ifdef USE_TSHARK_SELECT
1711   fd_set readfds;
1712 #endif
1713 #ifndef _WIN32
1714   struct sigaction action, oldaction;
1715 #endif
1716
1717   /*
1718    * XXX - dropping privileges is still required, until code cleanup is done
1719    *
1720    * remove all dependencies to pcap specific code and using only dumpcap is almost done.
1721    * when it's done, we don't need special privileges to run tshark at all,
1722    * therefore we don't need to drop these privileges
1723    * The only thing we might want to keep is a warning if tshark is run as root,
1724    * as it's no longer necessary and potentially dangerous.
1725    *
1726    * THE FOLLOWING IS THE FORMER COMMENT WHICH IS NO LONGER REALLY VALID:
1727    * We've opened the capture device, so we shouldn't need any special
1728    * privileges any more; relinquish those privileges.
1729    *
1730    * XXX - if we have saved set-user-ID support, we should give up those
1731    * privileges immediately, and then reclaim them long enough to get
1732    * a list of network interfaces and to open one, and then give them
1733    * up again, so that stuff we do while processing the argument list,
1734    * reading the user's preferences, loading and starting plugins
1735    * (especially *user* plugins), etc. is done with the user's privileges,
1736    * not special privileges.
1737    */
1738   relinquish_special_privs_perm();
1739   print_current_user();
1740
1741   /* Initialize all data structures used for dissection. */
1742   init_dissection();
1743
1744 #ifdef _WIN32
1745   /* Catch a CTRL+C event and, if we get it, clean up and exit. */
1746   SetConsoleCtrlHandler(capture_cleanup, TRUE);
1747 #else /* _WIN32 */
1748   /* Catch SIGINT and SIGTERM and, if we get either of them, clean up
1749      and exit. */
1750   action.sa_handler = capture_cleanup;
1751   action.sa_flags = 0;
1752   sigemptyset(&action.sa_mask);
1753   sigaction(SIGTERM, &action, NULL);
1754   sigaction(SIGINT, &action, NULL);
1755   sigaction(SIGHUP, NULL, &oldaction);
1756   if (oldaction.sa_handler == SIG_DFL)
1757     sigaction(SIGHUP, &action, NULL);
1758
1759 #ifdef SIGINFO
1760   /* Catch SIGINFO and, if we get it and we're capturing to a file in
1761      quiet mode, report the number of packets we've captured. */
1762   action.sa_handler = report_counts_siginfo;
1763   action.sa_flags = 0;
1764   sigemptyset(&action.sa_mask);
1765   sigaction(SIGINFO, &action, NULL);
1766 #endif /* SIGINFO */
1767 #endif /* _WIN32 */
1768
1769   capture_opts.state = CAPTURE_PREPARING;
1770
1771   /* Let the user know what interface was chosen. */
1772   capture_opts.iface_descr = get_interface_descriptive_name(capture_opts.iface);
1773   fprintf(stderr, "Capturing on %s\n", capture_opts.iface_descr);
1774
1775   ret = sync_pipe_start(&capture_opts);
1776
1777   if (!ret)
1778     return FALSE;
1779
1780     /* the actual capture loop
1781      *
1782      * XXX - glib doesn't seem to provide any event based loop handling.
1783      *
1784      * XXX - for whatever reason,
1785      * calling g_main_loop_new() ends up in 100% cpu load.
1786      *
1787      * But that doesn't matter: in UNIX we can use select() to find an input
1788      * source with something to do.
1789      *
1790      * But that doesn't matter because we're in a CLI (that doesn't need to
1791      * update a GUI or something at the same time) so it's OK if we block
1792      * trying to read from the pipe.
1793      *
1794      * So all the stuff in USE_TSHARK_SELECT could be removed unless I'm
1795      * wrong (but I leave it there in case I am...).
1796      */
1797
1798 #ifdef USE_TSHARK_SELECT
1799   FD_ZERO(&readfds);
1800   FD_SET(pipe_input.source, &readfds);
1801 #endif
1802
1803   loop_running = TRUE;
1804
1805   while (loop_running)
1806   {
1807 #ifdef USE_TSHARK_SELECT
1808     ret = select(pipe_input.source+1, &readfds, NULL, NULL, NULL);
1809
1810     if (ret == -1)
1811     {
1812       perror("select()");
1813       return TRUE;
1814     } else if (ret == 1) {
1815 #endif
1816       /* Call the real handler */
1817       if (!pipe_input.input_cb(pipe_input.source, pipe_input.user_data)) {
1818         g_log(NULL, G_LOG_LEVEL_DEBUG, "input pipe closed");
1819         return FALSE;
1820       }
1821 #ifdef USE_TSHARK_SELECT
1822     }
1823 #endif
1824   }
1825
1826   return TRUE;
1827 }
1828
1829
1830 /* XXX - move the call to main_window_update() out of capture_sync.c */
1831 /* dummy for capture_sync.c to make linker happy */
1832 void main_window_update(void)
1833 {
1834 }
1835
1836 /* XXX - move the call to simple_dialog() out of capture_sync.c */
1837 #include "simple_dialog.h"
1838
1839 /* capture_sync.c want's to tell us an error */
1840 gpointer simple_dialog(ESD_TYPE_E type _U_, gint btn_mask _U_,
1841                                            const gchar *msg_format, ...)
1842 {
1843         va_list ap;
1844
1845         /* XXX - do we need to display buttons and alike? */
1846         va_start(ap, msg_format);
1847         fprintf(stderr, "tshark: ");
1848         vfprintf(stderr, msg_format, ap);
1849         fprintf(stderr, "\n");
1850         va_end(ap);
1851
1852         return NULL;
1853 }
1854
1855
1856 /* capture child detected an error */
1857 void
1858 capture_input_error_message(capture_options *capture_opts _U_, char *error_msg, char *secondary_error_msg)
1859 {
1860         cmdarg_err("%s", error_msg);
1861         cmdarg_err_cont("%s", secondary_error_msg);
1862 }
1863
1864
1865 /* capture child detected an capture filter related error */
1866 void
1867 capture_input_cfilter_error_message(capture_options *capture_opts, char *error_message)
1868 {
1869     dfilter_t   *rfcode = NULL;
1870
1871
1872     if (dfilter_compile(capture_opts->cfilter, &rfcode) && rfcode != NULL) {
1873       cmdarg_err(
1874         "Invalid capture filter: \"%s\"!\n"
1875         "\n"
1876         "That string looks like a valid display filter; however, it isn't a valid\n"
1877         "capture filter (%s).\n"
1878         "\n"
1879         "Note that display filters and capture filters don't have the same syntax,\n"
1880         "so you can't use most display filter expressions as capture filters.\n"
1881         "\n"
1882         "See the User's Guide for a description of the capture filter syntax.",
1883         capture_opts->cfilter, error_message);
1884       dfilter_free(rfcode);
1885     } else {
1886       cmdarg_err(
1887         "Invalid capture filter: \"%s\"!\n"
1888         "\n"
1889         "That string isn't a valid capture filter (%s).\n"
1890         "See the User's Guide for a description of the capture filter syntax.",
1891         capture_opts->cfilter, error_message);
1892     }
1893 }
1894
1895
1896 /* capture child tells us we have a new (or the first) capture file */
1897 gboolean
1898 capture_input_new_file(capture_options *capture_opts, gchar *new_file)
1899 {
1900   gboolean is_tempfile;
1901   int  err;
1902
1903
1904   if(capture_opts->state == CAPTURE_PREPARING) {
1905     g_log(LOG_DOMAIN_CAPTURE, G_LOG_LEVEL_MESSAGE, "Capture started!");
1906   }
1907   g_log(LOG_DOMAIN_CAPTURE, G_LOG_LEVEL_MESSAGE, "File: \"%s\"", new_file);
1908
1909   g_assert(capture_opts->state == CAPTURE_PREPARING || capture_opts->state == CAPTURE_RUNNING);
1910
1911   capture_opts->cf = &cfile;
1912
1913   /* free the old filename */
1914   if(capture_opts->save_file != NULL) {
1915     /* we start a new capture file, close the old one (if we had one before) */
1916     if( ((capture_file *) capture_opts->cf)->state != FILE_CLOSED) {
1917                 if(capture_opts->cf != NULL && ((capture_file *) capture_opts->cf)->wth != NULL) {
1918                         wtap_close(((capture_file *) capture_opts->cf)->wth);
1919                 }
1920     }
1921     g_free(capture_opts->save_file);
1922     is_tempfile = FALSE;
1923   } else {
1924     /* we didn't had a save_file before, must be a tempfile */
1925     is_tempfile = TRUE;
1926   }
1927
1928   /* save the new filename */
1929   capture_opts->save_file = g_strdup(new_file);
1930
1931   /* if we are in real-time mode, open the new file now */
1932   if(do_dissection) {
1933     /* Attempt to open the capture file and set up to read from it. */
1934     switch(cf_open(capture_opts->cf, capture_opts->save_file, is_tempfile, &err)) {
1935     case CF_OK:
1936       break;
1937     case CF_ERROR:
1938       /* Don't unlink (delete) the save file - leave it around,
1939          for debugging purposes. */
1940       g_free(capture_opts->save_file);
1941       capture_opts->save_file = NULL;
1942       return FALSE;
1943       break;
1944     }
1945   }
1946
1947   capture_opts->state = CAPTURE_RUNNING;
1948
1949   return TRUE;
1950 }
1951
1952
1953 /* capture child tells us we have new packets to read */
1954 void
1955 capture_input_new_packets(capture_options *capture_opts, int to_read)
1956 {
1957   gboolean     ret;
1958   int          err;
1959   gchar        *err_info;
1960   gint64       data_offset;
1961   capture_file *cf = capture_opts->cf;
1962
1963
1964 #ifdef SIGINFO
1965   /*
1966    * Prevent a SIGINFO handler from writing to stdout while we're
1967    * doing so; instead, have it just set a flag telling us to print
1968    * that information when we're done.
1969    */
1970   infodelay = TRUE;
1971 #endif /* SIGINFO */
1972
1973   if(do_dissection) {
1974     while (to_read-- && cf->wth) {
1975       ret = wtap_read(cf->wth, &err, &err_info, &data_offset);
1976       if(ret == FALSE) {
1977         /* read from file failed, tell the capture child to stop */
1978         sync_pipe_stop(capture_opts);
1979         wtap_close(cf->wth);
1980         cf->wth = NULL;
1981       } else {
1982         ret = process_packet(cf, data_offset, wtap_phdr(cf->wth),
1983                              wtap_pseudoheader(cf->wth), wtap_buf_ptr(cf->wth));
1984       }
1985       if (ret != FALSE) {
1986         /* packet sucessfully read and gone through the "Read Filter" */
1987         packet_count++;
1988       }
1989     }
1990   } else {
1991     /*
1992      * Dumpcap's doing all the work; we're not doing any dissection.
1993      * Count all the packets it wrote.
1994      */
1995     packet_count += to_read;
1996   }
1997
1998   if (print_packet_counts) {
1999       /* We're printing packet counts. */
2000       if (packet_count != 0) {
2001         fprintf(stderr, "\r%u ", packet_count);
2002         /* stderr could be line buffered */
2003         fflush(stderr);
2004       }
2005   }
2006
2007 #ifdef SIGINFO
2008   /*
2009    * Allow SIGINFO handlers to write.
2010    */
2011   infodelay = FALSE;
2012
2013   /*
2014    * If a SIGINFO handler asked us to write out capture counts, do so.
2015    */
2016   if (infoprint)
2017     report_counts();
2018 #endif /* SIGINFO */
2019 }
2020
2021 static void
2022 report_counts(void)
2023 {
2024   if (!print_packet_counts) {
2025     /* Report the count only if we aren't printing a packet count
2026        as packets arrive. */
2027     fprintf(stderr, "%u packet%s captured\n", packet_count,
2028             plurality(packet_count, "", "s"));
2029   }
2030 #ifdef SIGINFO
2031   infoprint = FALSE; /* we just reported it */
2032 #endif /* SIGINFO */
2033 }
2034
2035 #ifdef SIGINFO
2036 static void
2037 report_counts_siginfo(int signum _U_)
2038 {
2039   int sav_errno = errno;
2040   /* If we've been told to delay printing, just set a flag asking
2041      that we print counts (if we're supposed to), otherwise print
2042      the count of packets captured (if we're supposed to). */
2043   if (infodelay)
2044     infoprint = TRUE;
2045   else
2046     report_counts();
2047   errno = sav_errno;
2048 }
2049 #endif /* SIGINFO */
2050
2051
2052 /* capture child detected any packet drops? */
2053 void
2054 capture_input_drops(capture_options *capture_opts _U_, int dropped)
2055 {
2056         if (print_packet_counts) {
2057         /* We're printing packet counts to stderr.
2058            Send a newline so that we move to the line after the packet count. */
2059           fprintf(stderr, "\n");
2060         }
2061
2062         if(dropped != 0) {
2063                 /* We're printing packet counts to stderr.
2064                    Send a newline so that we move to the line after the packet count. */
2065                   fprintf(stderr, "%u packet%s dropped\n", dropped, plurality(dropped, "", "s"));
2066         }
2067 }
2068
2069
2070 /* capture child closed its side of the pipe, do the required cleanup */
2071 void
2072 capture_input_closed(capture_options *capture_opts)
2073 {
2074   report_counts();
2075
2076   if(capture_opts->cf != NULL && ((capture_file *) capture_opts->cf)->wth != NULL) {
2077     wtap_close(((capture_file *) capture_opts->cf)->wth);
2078   }
2079 #ifdef USE_BROKEN_G_MAIN_LOOP
2080   /*g_main_loop_quit(loop);*/
2081   g_main_quit(loop);
2082 #else
2083   loop_running = FALSE;
2084 #endif
2085 }
2086
2087
2088
2089
2090 #ifdef _WIN32
2091 static BOOL WINAPI
2092 capture_cleanup(DWORD ctrltype _U_)
2093 {
2094   /* CTRL_C_EVENT is sort of like SIGINT, CTRL_BREAK_EVENT is unique to
2095      Windows, CTRL_CLOSE_EVENT is sort of like SIGHUP, CTRL_LOGOFF_EVENT
2096      is also sort of like SIGHUP, and CTRL_SHUTDOWN_EVENT is sort of
2097      like SIGTERM at least when the machine's shutting down.
2098
2099      For now, we handle them all as indications that we should clean up
2100      and quit, just as we handle SIGINT, SIGHUP, and SIGTERM in that
2101      way on UNIX.
2102
2103      However, as handlers run in a new thread, we can't just longjmp
2104      out; we have to set "ld.go" to FALSE, and must return TRUE so that
2105      no other handler - such as one that would terminate the process -
2106      gets called.
2107
2108      XXX - for some reason, typing ^C to TShark, if you run this in
2109      a Cygwin console window in at least some versions of Cygwin,
2110      causes TShark to terminate immediately; this routine gets
2111      called, but the main loop doesn't get a chance to run and
2112      exit cleanly, at least if this is compiled with Microsoft Visual
2113      C++ (i.e., it's a property of the Cygwin console window or Bash;
2114      it happens if TShark is not built with Cygwin - for all I know,
2115      building it with Cygwin may make the problem go away). */
2116
2117   /* tell the capture child to stop */
2118   sync_pipe_stop(&capture_opts);
2119
2120   /* don't stop our own loop already here, otherwise status messages and
2121    * cleanup wouldn't be done properly. The child will indicate the stop of
2122    * everything by calling capture_input_closed() later */
2123
2124   return TRUE;
2125 }
2126 #else
2127 static void
2128 capture_cleanup(int signum _U_)
2129 {
2130   /* tell the capture child to stop */
2131   sync_pipe_stop(&capture_opts);
2132 }
2133 #endif /* _WIN32 */
2134 #endif /* HAVE_LIBPCAP */
2135
2136 static int
2137 load_cap_file(capture_file *cf, char *save_file, int out_file_type,
2138     int max_packet_count, gint64 max_byte_count)
2139 {
2140   gint         linktype;
2141   int          snapshot_length;
2142   wtap_dumper *pdh;
2143   int          err;
2144   gchar        *err_info;
2145   gint64       data_offset;
2146   char         *save_file_string = NULL;
2147
2148   linktype = wtap_file_encap(cf->wth);
2149   if (save_file != NULL) {
2150     /* Get a string that describes what we're writing to */
2151     save_file_string = output_file_description(save_file);
2152
2153     /* Set up to write to the capture file. */
2154     snapshot_length = wtap_snapshot_length(cf->wth);
2155     if (snapshot_length == 0) {
2156       /* Snapshot length of input file not known. */
2157       snapshot_length = WTAP_MAX_PACKET_SIZE;
2158     }
2159     pdh = wtap_dump_open(save_file, out_file_type, linktype, snapshot_length,
2160                          FALSE /* compressed */, &err);
2161
2162     if (pdh == NULL) {
2163       /* We couldn't set up to write to the capture file. */
2164       switch (err) {
2165
2166       case WTAP_ERR_UNSUPPORTED_FILE_TYPE:
2167         cmdarg_err("Capture files can't be written in that format.");
2168         break;
2169
2170       case WTAP_ERR_UNSUPPORTED_ENCAP:
2171       case WTAP_ERR_ENCAP_PER_PACKET_UNSUPPORTED:
2172         cmdarg_err("The capture file being read can't be written in "
2173           "that format.");
2174         break;
2175
2176       case WTAP_ERR_CANT_OPEN:
2177         cmdarg_err("The %s couldn't be created for some "
2178           "unknown reason.", save_file_string);
2179         break;
2180
2181       case WTAP_ERR_SHORT_WRITE:
2182         cmdarg_err("A full header couldn't be written to the %s.",
2183                    save_file_string);
2184         break;
2185
2186       default:
2187         cmdarg_err("The %s could not be created: %s.", save_file_string,
2188                    wtap_strerror(err));
2189         break;
2190       }
2191       goto out;
2192     }
2193   } else {
2194     if (print_packet_info) {
2195       if (!write_preamble(cf)) {
2196         err = errno;
2197         show_print_file_io_error(err);
2198         goto out;
2199       }
2200     }
2201     pdh = NULL;
2202   }
2203   while (wtap_read(cf->wth, &err, &err_info, &data_offset)) {
2204     if (process_packet(cf, data_offset, wtap_phdr(cf->wth),
2205                        wtap_pseudoheader(cf->wth), wtap_buf_ptr(cf->wth))) {
2206       /* Either there's no read filtering or this packet passed the
2207          filter, so, if we're writing to a capture file, write
2208          this packet out. */
2209       if (pdh != NULL) {
2210         if (!wtap_dump(pdh, wtap_phdr(cf->wth),
2211                        wtap_pseudoheader(cf->wth), wtap_buf_ptr(cf->wth),
2212                        &err)) {
2213           /* Error writing to a capture file */
2214           show_capture_file_io_error(save_file, err, FALSE);
2215           wtap_dump_close(pdh, &err);
2216           exit(2);
2217         }
2218       }
2219       /* Stop reading if we have the maximum number of packets;
2220        * note that a zero max_packet_count will never be matched
2221        * (unless we roll over the packet number?)
2222        */
2223       if(max_packet_count == cf->count || (max_byte_count != 0 && data_offset >= max_byte_count)) {
2224         err = 0; /* This is not an error */
2225         break;
2226       }
2227     }
2228   }
2229   if (err != 0) {
2230     /* Print a message noting that the read failed somewhere along the line. */
2231     switch (err) {
2232
2233     case WTAP_ERR_UNSUPPORTED_ENCAP:
2234       cmdarg_err("\"%s\" has a packet with a network type that TShark doesn't support.\n(%s)",
2235                  cf->filename, err_info);
2236       break;
2237
2238     case WTAP_ERR_CANT_READ:
2239       cmdarg_err("An attempt to read from \"%s\" failed for some unknown reason.",
2240                  cf->filename);
2241       break;
2242
2243     case WTAP_ERR_SHORT_READ:
2244       cmdarg_err("\"%s\" appears to have been cut short in the middle of a packet.",
2245                  cf->filename);
2246       break;
2247
2248     case WTAP_ERR_BAD_RECORD:
2249       cmdarg_err("\"%s\" appears to be damaged or corrupt.\n(%s)",
2250                  cf->filename, err_info);
2251       break;
2252
2253     default:
2254       cmdarg_err("An error occurred while reading \"%s\": %s.",
2255                  cf->filename, wtap_strerror(err));
2256       break;
2257     }
2258     if (save_file != NULL) {
2259       /* Now close the capture file. */
2260       if (!wtap_dump_close(pdh, &err))
2261         show_capture_file_io_error(save_file, err, TRUE);
2262     }
2263   } else {
2264     if (save_file != NULL) {
2265       /* Now close the capture file. */
2266       if (!wtap_dump_close(pdh, &err))
2267         show_capture_file_io_error(save_file, err, TRUE);
2268     } else {
2269       if (print_packet_info) {
2270         if (!write_finale()) {
2271           err = errno;
2272           show_print_file_io_error(err);
2273         }
2274       }
2275     }
2276   }
2277
2278 out:
2279   wtap_close(cf->wth);
2280   cf->wth = NULL;
2281
2282   if (save_file_string != NULL)
2283     g_free(save_file_string);
2284
2285   return err;
2286 }
2287
2288 static void
2289 fill_in_fdata(frame_data *fdata, capture_file *cf,
2290               const struct wtap_pkthdr *phdr, gint64 offset)
2291 {
2292   fdata->next = NULL;
2293   fdata->prev = NULL;
2294   fdata->pfd = NULL;
2295   fdata->num = cf->count;
2296   fdata->pkt_len = phdr->len;
2297   cum_bytes += phdr->len;
2298   fdata->cum_bytes  = cum_bytes;
2299   fdata->cap_len = phdr->caplen;
2300   fdata->file_off = offset;
2301   fdata->lnk_t = phdr->pkt_encap;
2302   fdata->abs_ts.secs = phdr->ts.secs;
2303   fdata->abs_ts.nsecs = phdr->ts.nsecs;
2304   fdata->flags.passed_dfilter = 0;
2305   fdata->flags.encoding = CHAR_ASCII;
2306   fdata->flags.visited = 0;
2307   fdata->flags.marked = 0;
2308   fdata->flags.ref_time = 0;
2309   fdata->color_filter = NULL;
2310
2311   /* If we don't have the time stamp of the first packet in the
2312      capture, it's because this is the first packet.  Save the time
2313      stamp of this packet as the time stamp of the first packet. */
2314   if (nstime_is_unset(&first_ts)) {
2315     first_ts = fdata->abs_ts;
2316   }
2317
2318   /* If we don't have the time stamp of the previous captured packet,
2319      it's because this is the first packet.  Save the time
2320      stamp of this packet as the time stamp of the previous captured
2321      packet. */
2322   if (nstime_is_unset(&prev_cap_ts)) {
2323     prev_cap_ts = fdata->abs_ts;
2324   }
2325
2326   /* Get the time elapsed between the first packet and this packet. */
2327   nstime_delta(&fdata->rel_ts, &fdata->abs_ts, &first_ts);
2328
2329   /* If it's greater than the current elapsed time, set the elapsed time
2330      to it (we check for "greater than" so as not to be confused by
2331      time moving backwards). */
2332   if ((gint32)cf->elapsed_time.secs < fdata->rel_ts.secs
2333         || ((gint32)cf->elapsed_time.secs == fdata->rel_ts.secs && (gint32)cf->elapsed_time.nsecs < fdata->rel_ts.nsecs)) {
2334     cf->elapsed_time = fdata->rel_ts;
2335   }
2336
2337   /* Get the time elapsed between the previous displayed packet and
2338      this packet. */
2339   if (nstime_is_unset(&prev_dis_ts))
2340     nstime_set_zero(&fdata->del_dis_ts);
2341   else
2342     nstime_delta(&fdata->del_dis_ts, &fdata->abs_ts, &prev_dis_ts);
2343
2344   /* Get the time elapsed between the previous captured packet and
2345      this packet. */
2346   nstime_delta(&fdata->del_cap_ts, &fdata->abs_ts, &prev_cap_ts);
2347   prev_cap_ts = fdata->abs_ts;
2348 }
2349
2350 /* Free up all data attached to a "frame_data" structure. */
2351 static void
2352 clear_fdata(frame_data *fdata)
2353 {
2354   if (fdata->pfd)
2355     g_slist_free(fdata->pfd);
2356 }
2357
2358 static gboolean
2359 process_packet(capture_file *cf, gint64 offset, const struct wtap_pkthdr *whdr,
2360                union wtap_pseudo_header *pseudo_header, const guchar *pd)
2361 {
2362   frame_data fdata;
2363   gboolean create_proto_tree;
2364   epan_dissect_t *edt;
2365   gboolean passed;
2366
2367   /* Count this packet. */
2368   cf->count++;
2369
2370   /* If we're going to print packet information, or we're going to
2371      run a read filter, or we're going to process taps, set up to
2372      do a dissection and do so. */
2373   if (do_dissection) {
2374     fill_in_fdata(&fdata, cf, whdr, offset);
2375
2376     if (print_packet_info) {
2377       /* Grab any resolved addresses */
2378
2379       if (g_resolv_flags) {
2380         host_name_lookup_process(NULL);
2381       }
2382     }
2383
2384     passed = TRUE;
2385     if (cf->rfcode || verbose || num_tap_filters!=0)
2386       create_proto_tree = TRUE;
2387     else
2388       create_proto_tree = FALSE;
2389     /* The protocol tree will be "visible", i.e., printed, only if we're
2390        printing packet details, which is true if we're printing stuff
2391        ("print_packet_info" is true) and we're in verbose mode ("verbose"
2392        is true). */
2393     edt = epan_dissect_new(create_proto_tree, print_packet_info && verbose);
2394
2395     /* If we're running a read filter, prime the epan_dissect_t with that
2396        filter. */
2397     if (cf->rfcode)
2398       epan_dissect_prime_dfilter(edt, cf->rfcode);
2399
2400     tap_queue_init(edt);
2401
2402     /* We only need the columns if we're printing packet info but we're
2403        *not* verbose; in verbose mode, we print the protocol tree, not
2404        the protocol summary. */
2405     epan_dissect_run(edt, pseudo_header, pd, &fdata,
2406                      (print_packet_info && !verbose) ? &cf->cinfo : NULL);
2407
2408     tap_push_tapped_queue(edt);
2409
2410     /* Run the read filter if we have one. */
2411     if (cf->rfcode)
2412       passed = dfilter_apply_edt(cf->rfcode, edt);
2413     else
2414       passed = TRUE;
2415   } else {
2416     /* We're not running a display filter and we're not printing any
2417        packet information, so we don't need to do a dissection, and all
2418        packets are processed. */
2419     edt = NULL;
2420     passed = TRUE;
2421   }
2422
2423   if (passed) {
2424     /* Keep the time of the current packet if the packet passed
2425        the read filter so that the delta time since last displayed
2426        packet can be calculated */
2427     prev_dis_ts = fdata.abs_ts;
2428
2429     /* Process this packet. */
2430     if (print_packet_info) {
2431       /* We're printing packet information; print the information for
2432          this packet. */
2433       print_packet(cf, edt);
2434
2435       /* The ANSI C standard does not appear to *require* that a line-buffered
2436          stream be flushed to the host environment whenever a newline is
2437          written, it just says that, on such a stream, characters "are
2438          intended to be transmitted to or from the host environment as a
2439          block when a new-line character is encountered".
2440
2441          The Visual C++ 6.0 C implementation doesn't do what is intended;
2442          even if you set a stream to be line-buffered, it still doesn't
2443          flush the buffer at the end of every line.
2444
2445          So, if the "-l" flag was specified, we flush the standard output
2446          at the end of a packet.  This will do the right thing if we're
2447          printing packet summary lines, and, as we print the entire protocol
2448          tree for a single packet without waiting for anything to happen,
2449          it should be as good as line-buffered mode if we're printing
2450          protocol trees.  (The whole reason for the "-l" flag in either
2451          tcpdump or TShark is to allow the output of a live capture to
2452          be piped to a program or script and to have that script see the
2453          information for the packet as soon as it's printed, rather than
2454          having to wait until a standard I/O buffer fills up. */
2455       if (line_buffered)
2456         fflush(stdout);
2457
2458       if (ferror(stdout)) {
2459         show_print_file_io_error(errno);
2460         exit(2);
2461       }
2462     }
2463   }
2464
2465   if (do_dissection) {
2466     epan_dissect_free(edt);
2467     clear_fdata(&fdata);
2468   }
2469   return passed;
2470 }
2471
2472 static void
2473 show_capture_file_io_error(const char *fname, int err, gboolean is_close)
2474 {
2475   char *save_file_string;
2476
2477   save_file_string = output_file_description(fname);
2478
2479   switch (err) {
2480
2481   case ENOSPC:
2482     cmdarg_err("Not all the packets could be written to the %s because there is "
2483                "no space left on the file system.",
2484                save_file_string);
2485     break;
2486
2487 #ifdef EDQUOT
2488   case EDQUOT:
2489     cmdarg_err("Not all the packets could be written to the %s because you are "
2490                "too close to, or over your disk quota.",
2491                save_file_string);
2492   break;
2493 #endif
2494
2495   case WTAP_ERR_CANT_CLOSE:
2496     cmdarg_err("The %s couldn't be closed for some unknown reason.",
2497                save_file_string);
2498     break;
2499
2500   case WTAP_ERR_SHORT_WRITE:
2501     cmdarg_err("Not all the packets could be written to the %s.",
2502                save_file_string);
2503     break;
2504
2505   default:
2506     if (is_close) {
2507       cmdarg_err("The %s could not be closed: %s.", save_file_string,
2508                  wtap_strerror(err));
2509     } else {
2510       cmdarg_err("An error occurred while writing to the %s: %s.",
2511                  save_file_string, wtap_strerror(err));
2512     }
2513     break;
2514   }
2515   g_free(save_file_string);
2516 }
2517
2518 static gboolean
2519 write_preamble(capture_file *cf)
2520 {
2521   switch (output_action) {
2522
2523   case WRITE_TEXT:
2524     return print_preamble(print_stream, cf ? cf->filename : NULL);
2525
2526   case WRITE_XML:
2527     if (verbose)
2528       write_pdml_preamble(stdout);
2529     else
2530       write_psml_preamble(stdout);
2531     return !ferror(stdout);
2532
2533   case WRITE_FIELDS:
2534     write_fields_preamble(output_fields, stdout);
2535     return !ferror(stdout);
2536
2537   default:
2538     g_assert_not_reached();
2539     return FALSE;
2540   }
2541 }
2542
2543 static char *
2544 get_line_buf(size_t len)
2545 {
2546   static char *line_bufp = NULL;
2547   static size_t line_buf_len = 256;
2548   size_t new_line_buf_len;
2549
2550   for (new_line_buf_len = line_buf_len; len > new_line_buf_len;
2551        new_line_buf_len *= 2)
2552     ;
2553   if (line_bufp == NULL) {
2554     line_buf_len = new_line_buf_len;
2555     line_bufp = g_malloc(line_buf_len + 1);
2556   } else {
2557     if (new_line_buf_len > line_buf_len) {
2558       line_buf_len = new_line_buf_len;
2559       line_bufp = g_realloc(line_bufp, line_buf_len + 1);
2560     }
2561   }
2562   return line_bufp;
2563 }
2564
2565 static gboolean
2566 print_columns(capture_file *cf)
2567 {
2568   char *line_bufp;
2569   int i;
2570   size_t buf_offset;
2571   size_t column_len;
2572
2573   line_bufp = get_line_buf(256);
2574   buf_offset = 0;
2575   *line_bufp = '\0';
2576   for (i = 0; i < cf->cinfo.num_cols; i++) {
2577     switch (cf->cinfo.col_fmt[i]) {
2578     case COL_NUMBER:
2579 #ifdef HAVE_LIBPCAP
2580       /*
2581        * Don't print this if we're doing a live capture from a network
2582        * interface - if we're doing a live capture, you won't be
2583        * able to look at the capture in the future (it's not being
2584        * saved anywhere), so the frame numbers are unlikely to be
2585        * useful.
2586        *
2587        * (XXX - it might be nice to be able to save and print at
2588        * the same time, sort of like an "Update list of packets
2589        * in real time" capture in Wireshark.)
2590        */
2591       if (capture_opts.iface != NULL)
2592         continue;
2593 #endif
2594       column_len = strlen(cf->cinfo.col_data[i]);
2595       if (column_len < 3)
2596         column_len = 3;
2597       line_bufp = get_line_buf(buf_offset + column_len);
2598       sprintf(line_bufp + buf_offset, "%3s", cf->cinfo.col_data[i]);
2599       break;
2600
2601     case COL_CLS_TIME:
2602     case COL_REL_TIME:
2603     case COL_ABS_TIME:
2604     case COL_ABS_DATE_TIME: /* XXX - wider */
2605       column_len = strlen(cf->cinfo.col_data[i]);
2606       if (column_len < 10)
2607         column_len = 10;
2608       line_bufp = get_line_buf(buf_offset + column_len);
2609       sprintf(line_bufp + buf_offset, "%10s", cf->cinfo.col_data[i]);
2610       break;
2611
2612     case COL_DEF_SRC:
2613     case COL_RES_SRC:
2614     case COL_UNRES_SRC:
2615     case COL_DEF_DL_SRC:
2616     case COL_RES_DL_SRC:
2617     case COL_UNRES_DL_SRC:
2618     case COL_DEF_NET_SRC:
2619     case COL_RES_NET_SRC:
2620     case COL_UNRES_NET_SRC:
2621       column_len = strlen(cf->cinfo.col_data[i]);
2622       if (column_len < 12)
2623         column_len = 12;
2624       line_bufp = get_line_buf(buf_offset + column_len);
2625       sprintf(line_bufp + buf_offset, "%12s", cf->cinfo.col_data[i]);
2626       break;
2627
2628     case COL_DEF_DST:
2629     case COL_RES_DST:
2630     case COL_UNRES_DST:
2631     case COL_DEF_DL_DST:
2632     case COL_RES_DL_DST:
2633     case COL_UNRES_DL_DST:
2634     case COL_DEF_NET_DST:
2635     case COL_RES_NET_DST:
2636     case COL_UNRES_NET_DST:
2637       column_len = strlen(cf->cinfo.col_data[i]);
2638       if (column_len < 12)
2639         column_len = 12;
2640       line_bufp = get_line_buf(buf_offset + column_len);
2641       sprintf(line_bufp + buf_offset, "%-12s", cf->cinfo.col_data[i]);
2642       break;
2643
2644     default:
2645       column_len = strlen(cf->cinfo.col_data[i]);
2646       line_bufp = get_line_buf(buf_offset + column_len);
2647       strcat(line_bufp + buf_offset, cf->cinfo.col_data[i]);
2648       break;
2649     }
2650     buf_offset += column_len;
2651     if (i != cf->cinfo.num_cols - 1) {
2652       /*
2653        * This isn't the last column, so we need to print a
2654        * separator between this column and the next.
2655        *
2656        * If we printed a network source and are printing a
2657        * network destination of the same type next, separate
2658        * them with "->"; if we printed a network destination
2659        * and are printing a network source of the same type
2660        * next, separate them with "<-"; otherwise separate them
2661        * with a space.
2662        *
2663        * We add enough space to the buffer for " <- " or " -> ",
2664        * even if we're only adding " ".
2665        */
2666       line_bufp = get_line_buf(buf_offset + 4);
2667       switch (cf->cinfo.col_fmt[i]) {
2668
2669       case COL_DEF_SRC:
2670       case COL_RES_SRC:
2671       case COL_UNRES_SRC:
2672         switch (cf->cinfo.col_fmt[i + 1]) {
2673
2674         case COL_DEF_DST:
2675         case COL_RES_DST:
2676         case COL_UNRES_DST:
2677           strcat(line_bufp + buf_offset, " -> ");
2678           buf_offset += 4;
2679           break;
2680
2681         default:
2682           strcat(line_bufp + buf_offset, " ");
2683           buf_offset += 1;
2684           break;
2685         }
2686         break;
2687
2688       case COL_DEF_DL_SRC:
2689       case COL_RES_DL_SRC:
2690       case COL_UNRES_DL_SRC:
2691         switch (cf->cinfo.col_fmt[i + 1]) {
2692
2693         case COL_DEF_DL_DST:
2694         case COL_RES_DL_DST:
2695         case COL_UNRES_DL_DST:
2696           strcat(line_bufp + buf_offset, " -> ");
2697           buf_offset += 4;
2698           break;
2699
2700         default:
2701           strcat(line_bufp + buf_offset, " ");
2702           buf_offset += 1;
2703           break;
2704         }
2705         break;
2706
2707       case COL_DEF_NET_SRC:
2708       case COL_RES_NET_SRC:
2709       case COL_UNRES_NET_SRC:
2710         switch (cf->cinfo.col_fmt[i + 1]) {
2711
2712         case COL_DEF_NET_DST:
2713         case COL_RES_NET_DST:
2714         case COL_UNRES_NET_DST:
2715           strcat(line_bufp + buf_offset, " -> ");
2716           buf_offset += 4;
2717           break;
2718
2719         default:
2720           strcat(line_bufp + buf_offset, " ");
2721           buf_offset += 1;
2722           break;
2723         }
2724         break;
2725
2726       case COL_DEF_DST:
2727       case COL_RES_DST:
2728       case COL_UNRES_DST:
2729         switch (cf->cinfo.col_fmt[i + 1]) {
2730
2731         case COL_DEF_SRC:
2732         case COL_RES_SRC:
2733         case COL_UNRES_SRC:
2734           strcat(line_bufp + buf_offset, " <- ");
2735           buf_offset += 4;
2736           break;
2737
2738         default:
2739           strcat(line_bufp + buf_offset, " ");
2740           buf_offset += 1;
2741           break;
2742         }
2743         break;
2744
2745       case COL_DEF_DL_DST:
2746       case COL_RES_DL_DST:
2747       case COL_UNRES_DL_DST:
2748         switch (cf->cinfo.col_fmt[i + 1]) {
2749
2750         case COL_DEF_DL_SRC:
2751         case COL_RES_DL_SRC:
2752         case COL_UNRES_DL_SRC:
2753           strcat(line_bufp + buf_offset, " <- ");
2754           buf_offset += 4;
2755           break;
2756
2757         default:
2758           strcat(line_bufp + buf_offset, " ");
2759           buf_offset += 1;
2760           break;
2761         }
2762         break;
2763
2764       case COL_DEF_NET_DST:
2765       case COL_RES_NET_DST:
2766       case COL_UNRES_NET_DST:
2767         switch (cf->cinfo.col_fmt[i + 1]) {
2768
2769         case COL_DEF_NET_SRC:
2770         case COL_RES_NET_SRC:
2771         case COL_UNRES_NET_SRC:
2772           strcat(line_bufp + buf_offset, " <- ");
2773           buf_offset += 4;
2774           break;
2775
2776         default:
2777           strcat(line_bufp + buf_offset, " ");
2778           buf_offset += 1;
2779           break;
2780         }
2781         break;
2782
2783       default:
2784         strcat(line_bufp + buf_offset, " ");
2785         buf_offset += 1;
2786         break;
2787       }
2788     }
2789   }
2790   return print_line(print_stream, 0, line_bufp);
2791 }
2792
2793 static gboolean
2794 print_packet(capture_file *cf, epan_dissect_t *edt)
2795 {
2796   print_args_t  print_args;
2797
2798   if (verbose) {
2799     /* Print the information in the protocol tree. */
2800     switch (output_action) {
2801
2802     case WRITE_TEXT:
2803       print_args.to_file = TRUE;
2804       print_args.format = print_format;
2805       print_args.print_summary = !verbose;
2806       print_args.print_hex = verbose && print_hex;
2807       print_args.print_formfeed = FALSE;
2808       print_args.print_dissections = verbose ? print_dissections_expanded : print_dissections_none;
2809
2810       /* init the packet range */
2811       packet_range_init(&print_args.range);
2812
2813       if (!proto_tree_print(&print_args, edt, print_stream))
2814         return FALSE;
2815       if (!print_hex) {
2816         /* "print_hex_data()" will put out a leading blank line, as well
2817          as a trailing one; print one here, to separate the packets,
2818          only if "print_hex_data()" won't be called. */
2819         if (!print_line(print_stream, 0, ""))
2820           return FALSE;
2821       }
2822       break;
2823
2824     case WRITE_XML:
2825       proto_tree_write_pdml(edt, stdout);
2826       printf("\n");
2827       return !ferror(stdout);
2828     case WRITE_FIELDS:
2829       proto_tree_write_fields(output_fields, edt, stdout);
2830       printf("\n");
2831       return !ferror(stdout);
2832     }
2833   } else {
2834     /* Just fill in the columns. */
2835     epan_dissect_fill_in_columns(edt);
2836
2837     /* Now print them. */
2838     switch (output_action) {
2839
2840     case WRITE_TEXT:
2841         if (!print_columns(cf))
2842           return FALSE;
2843         break;
2844
2845     case WRITE_XML:
2846         proto_tree_write_psml(edt, stdout);
2847         return !ferror(stdout);
2848     case WRITE_FIELDS: /*No non-verbose "fields" format */
2849         g_assert_not_reached();
2850         break;
2851     }
2852   }
2853   if (print_hex) {
2854     if (!print_hex_data(print_stream, edt))
2855       return FALSE;
2856     if (!print_line(print_stream, 0, ""))
2857       return FALSE;
2858   }
2859   return TRUE;
2860 }
2861
2862 static gboolean
2863 write_finale(void)
2864 {
2865   switch (output_action) {
2866
2867   case WRITE_TEXT:
2868     return print_finale(print_stream);
2869
2870   case WRITE_XML:
2871     if (verbose)
2872       write_pdml_finale(stdout);
2873     else
2874       write_psml_finale(stdout);
2875     return !ferror(stdout);
2876
2877   case WRITE_FIELDS:
2878     write_fields_finale(output_fields, stdout);
2879     return !ferror(stdout);
2880
2881   default:
2882     g_assert_not_reached();
2883     return FALSE;
2884   }
2885 }
2886
2887 static void
2888 show_print_file_io_error(int err)
2889 {
2890   switch (err) {
2891
2892   case ENOSPC:
2893     cmdarg_err("Not all the packets could be printed because there is "
2894 "no space left on the file system.");
2895     break;
2896
2897 #ifdef EDQUOT
2898   case EDQUOT:
2899     cmdarg_err("Not all the packets could be printed because you are "
2900 "too close to, or over your disk quota.");
2901   break;
2902 #endif
2903
2904   default:
2905     cmdarg_err("An error occurred while printing packets: %s.",
2906       strerror(err));
2907     break;
2908   }
2909 }
2910
2911 static const char *
2912 cf_open_error_message(int err, gchar *err_info, gboolean for_writing,
2913                       int file_type)
2914 {
2915   const char *errmsg;
2916   static char errmsg_errno[1024+1];
2917
2918   if (err < 0) {
2919     /* Wiretap error. */
2920     switch (err) {
2921
2922     case WTAP_ERR_NOT_REGULAR_FILE:
2923       errmsg = "The file \"%s\" is a \"special file\" or socket or other non-regular file.";
2924       break;
2925
2926     case WTAP_ERR_FILE_UNKNOWN_FORMAT:
2927       /* Seen only when opening a capture file for reading. */
2928       errmsg = "The file \"%s\" isn't a capture file in a format TShark understands.";
2929       break;
2930
2931     case WTAP_ERR_UNSUPPORTED:
2932       /* Seen only when opening a capture file for reading. */
2933       g_snprintf(errmsg_errno, sizeof(errmsg_errno),
2934                "The file \"%%s\" isn't a capture file in a format TShark understands.\n"
2935                "(%s)", err_info);
2936       g_free(err_info);
2937       errmsg = errmsg_errno;
2938       break;
2939
2940     case WTAP_ERR_CANT_WRITE_TO_PIPE:
2941       /* Seen only when opening a capture file for writing. */
2942       g_snprintf(errmsg_errno, sizeof(errmsg_errno),
2943                  "The file \"%%s\" is a pipe, and %s capture files can't be "
2944                  "written to a pipe.", wtap_file_type_string(file_type));
2945       errmsg = errmsg_errno;
2946       break;
2947
2948     case WTAP_ERR_UNSUPPORTED_FILE_TYPE:
2949       /* Seen only when opening a capture file for writing. */
2950       errmsg = "TShark doesn't support writing capture files in that format.";
2951       break;
2952
2953     case WTAP_ERR_UNSUPPORTED_ENCAP:
2954       if (for_writing)
2955         errmsg = "TShark can't save this capture in that format.";
2956       else {
2957         g_snprintf(errmsg_errno, sizeof(errmsg_errno),
2958                  "The file \"%%s\" is a capture for a network type that TShark doesn't support.\n"
2959                  "(%s)", err_info);
2960         g_free(err_info);
2961         errmsg = errmsg_errno;
2962       }
2963       break;
2964
2965     case WTAP_ERR_ENCAP_PER_PACKET_UNSUPPORTED:
2966       if (for_writing)
2967         errmsg = "TShark can't save this capture in that format.";
2968       else
2969         errmsg = "The file \"%s\" is a capture for a network type that TShark doesn't support.";
2970       break;
2971
2972     case WTAP_ERR_BAD_RECORD:
2973       /* Seen only when opening a capture file for reading. */
2974       g_snprintf(errmsg_errno, sizeof(errmsg_errno),
2975                "The file \"%%s\" appears to be damaged or corrupt.\n"
2976                "(%s)", err_info);
2977       g_free(err_info);
2978       errmsg = errmsg_errno;
2979       break;
2980
2981     case WTAP_ERR_CANT_OPEN:
2982       if (for_writing)
2983         errmsg = "The file \"%s\" could not be created for some unknown reason.";
2984       else
2985         errmsg = "The file \"%s\" could not be opened for some unknown reason.";
2986       break;
2987
2988     case WTAP_ERR_SHORT_READ:
2989       errmsg = "The file \"%s\" appears to have been cut short"
2990                " in the middle of a packet or other data.";
2991       break;
2992
2993     case WTAP_ERR_SHORT_WRITE:
2994       errmsg = "A full header couldn't be written to the file \"%s\".";
2995       break;
2996
2997     default:
2998       g_snprintf(errmsg_errno, sizeof(errmsg_errno),
2999                  "The file \"%%s\" could not be %s: %s.",
3000                  for_writing ? "created" : "opened",
3001                  wtap_strerror(err));
3002       errmsg = errmsg_errno;
3003       break;
3004     }
3005   } else
3006     errmsg = file_open_error_message(err, for_writing);
3007   return errmsg;
3008 }
3009
3010 /*
3011  * Open/create errors are reported with an console message in TShark.
3012  */
3013 static void
3014 open_failure_message(const char *filename, int err, gboolean for_writing)
3015 {
3016   fprintf(stderr, "tshark: ");
3017   fprintf(stderr, file_open_error_message(err, for_writing), filename);
3018   fprintf(stderr, "\n");
3019 }
3020
3021 cf_status_t
3022 cf_open(capture_file *cf, const char *fname, gboolean is_tempfile, int *err)
3023 {
3024   wtap       *wth;
3025   gchar       *err_info;
3026   char        err_msg[2048+1];
3027
3028   wth = wtap_open_offline(fname, err, &err_info, FALSE);
3029   if (wth == NULL)
3030     goto fail;
3031
3032   /* The open succeeded.  Fill in the information for this file. */
3033
3034   /* Initialize all data structures used for dissection. */
3035   init_dissection();
3036
3037   cf->wth = wth;
3038   cf->f_datalen = 0; /* not used, but set it anyway */
3039
3040   /* Set the file name because we need it to set the follow stream filter.
3041      XXX - is that still true?  We need it for other reasons, though,
3042      in any case. */
3043   cf->filename = g_strdup(fname);
3044
3045   /* Indicate whether it's a permanent or temporary file. */
3046   cf->is_tempfile = is_tempfile;
3047
3048   /* If it's a temporary capture buffer file, mark it as not saved. */
3049   cf->user_saved = !is_tempfile;
3050
3051   cf->cd_t      = wtap_file_type(cf->wth);
3052   cf->count     = 0;
3053   cf->drops_known = FALSE;
3054   cf->drops     = 0;
3055   cf->snap      = wtap_snapshot_length(cf->wth);
3056   if (cf->snap == 0) {
3057     /* Snapshot length not known. */
3058     cf->has_snap = FALSE;
3059     cf->snap = WTAP_MAX_PACKET_SIZE;
3060   } else
3061     cf->has_snap = TRUE;
3062   nstime_set_zero(&cf->elapsed_time);
3063   nstime_set_unset(&first_ts);
3064   nstime_set_unset(&prev_dis_ts);
3065   nstime_set_unset(&prev_cap_ts);
3066
3067   return CF_OK;
3068
3069 fail:
3070   g_snprintf(err_msg, sizeof err_msg,
3071              cf_open_error_message(*err, err_info, FALSE, cf->cd_t), fname);
3072   cmdarg_err("%s", err_msg);
3073   return CF_ERROR;
3074 }
3075
3076
3077 /*
3078  * General errors are reported with an console message in TShark.
3079  */
3080 static void
3081 failure_message(const char *msg_format, va_list ap)
3082 {
3083   fprintf(stderr, "tshark: ");
3084   vfprintf(stderr, msg_format, ap);
3085   fprintf(stderr, "\n");
3086 }
3087
3088 /*
3089  * Read errors are reported with an console message in TShark.
3090  */
3091 static void
3092 read_failure_message(const char *filename, int err)
3093 {
3094   cmdarg_err("An error occurred while reading from the file \"%s\": %s.",
3095           filename, strerror(err));
3096 }
3097
3098 /*
3099  * Report an error in command-line arguments.
3100  */
3101 void
3102 cmdarg_err(const char *fmt, ...)
3103 {
3104   va_list ap;
3105
3106   va_start(ap, fmt);
3107   fprintf(stderr, "tshark: ");
3108   vfprintf(stderr, fmt, ap);
3109   fprintf(stderr, "\n");
3110   va_end(ap);
3111 }
3112
3113 /*
3114  * Report additional information for an error in command-line arguments.
3115  */
3116 void
3117 cmdarg_err_cont(const char *fmt, ...)
3118 {
3119   va_list ap;
3120
3121   va_start(ap, fmt);
3122   vfprintf(stderr, fmt, ap);
3123   fprintf(stderr, "\n");
3124   va_end(ap);
3125 }
3126
3127