Changeset d994324 for tools/tracestats
- Timestamp:
- 09/17/14 13:45:29 (6 years ago)
- 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:
- 9e429e8
- Parents:
- 2498008
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
tools/tracestats/tracestats_parallel.c
r2498008 rd994324 57 57 #include "data-struct/vector.h" 58 58 #include "data-struct/message_queue.h" 59 #include "combiners.h" 59 60 #include <pthread.h> 60 61 … … 130 131 switch (mesg->code) { 131 132 case MESSAGE_STOPPING: 132 trace_publish_result(trace, t, 0, results, RESULT_NORMAL); // Only ever using a single key 0133 trace_publish_result(trace, t, 0, (libtrace_generic_types_t){.ptr = results}, RESULT_NORMAL); // Only ever using a single key 0 133 134 fprintf(stderr, "Thread published resuslts WOWW\n"); 134 135 break; … … 158 159 /* Get the results from each core and sum 'em up */ 159 160 assert(libtrace_result_get_key(result) == 0); 160 statistics_t * res = libtrace_result_get_value(result) ;161 statistics_t * res = libtrace_result_get_value(result).ptr; 161 162 count += res[0].count; 162 163 bytes += res[0].bytes; … … 223 224 //option = 10000; 224 225 //trace_set_hasher(trace, HASHER_CUSTOM, &rand_hash, NULL); 225 option = 2;226 226 //trace_parallel_config(trace, TRACE_OPTION_SET_PERPKT_THREAD_COUNT, &option); 227 227 trace_parallel_config(trace, TRACE_OPTION_SET_CONFIG, &uc); 228 trace_ parallel_config(trace, TRACE_OPTION_ORDERED, &uc);228 trace_set_combiner(trace, &combiner_ordered, (libtrace_generic_types_t){0}); 229 229 230 230 //trace_parallel_config(trace, TRACE_OPTION_SET_MAPPER_BUFFER_SIZE, &option);
Note: See TracChangeset
for help on using the changeset viewer.