Changeset 9e48735

Timestamp:

09/10/15 14:16:59 (6 years ago)

Author:

Shane Alcock <salcock@…>

Branches:

4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes

Children:

c3cb9f9

Parents:

49b0537

Message:

Add max threads option to parallel tracertstats

Default is 4 threads.

File:

• tools/tracertstats/tracertstats_parallel.c (modified) (5 diffs)

tools/tracertstats/tracertstats_parallel.c

@@ -67 +67 @@
 
 int merge_inputs = 0;
+int threadcount = 4;
 
 struct filter_t {
@@ -262 +263 @@
         trace_set_combiner(trace, &combiner_ordered, (libtrace_generic_t){0});
         trace_set_tracetime(trace, true);
+        trace_set_perpkt_threads(trace, threadcount);
 
         //trace_set_hasher(trace, HASHER_CUSTOM, &bad_hash, NULL);
@@ -299 +301 @@
         "-i --interval=seconds  Duration of reporting interval in seconds\n"
         "-c --count=packets     Exit after count packets received\n"
+        "-t --threads=max       Create 'max' processing threads (default: 4)\n"
         "-o --output-format=txt|csv|html|png Reporting output format\n"
         "-f --filter=bpf        Apply BPF filter. Can be specified multiple times\n"
@@ -319 +322 @@
                         { "libtrace-help",      0, 0, 'H' },
                         { "merge-inputs",       0, 0, 'm' },
+                        { "threads",            1, 0, 't' },
                         { NULL,                 0, 0, 0   },
                 };
 
-                int c=getopt_long(argc, argv, "c:f:i:o:Hm",
+                int c=getopt_long(argc, argv, "c:f:i:o:t:Hm",
                                 long_options, &option_index);
 
@@ -337 +341 @@
                                 filters[filter_count-1].bytes=0;
                                 break;
+                        case 't':
+                                threadcount = atoi(optarg);
+                                if (threadcount <= 0)
+                                        threadcount = 1;
+                                break;
                         case 'i':
                                 packet_interval=atof(optarg);