Changeset f051c1b for tools/tracertstats/tracertstats_parallel.c
- Timestamp:
- 08/12/14 14:14:50 (8 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:
- 0862c20
- Parents:
- f9a70ca
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
tools/tracertstats/tracertstats_parallel.c
rb13b939 rf051c1b 209 209 // Publish and make a new one new 210 210 //fprintf(stderr, "Publishing result %"PRIu64"\n", last_ts); 211 trace_publish_result(trace, (uint64_t) last_ts, results);212 trace_post_re duce(trace);211 trace_publish_result(trace, t, (uint64_t) last_ts, results, RESULT_NORMAL); 212 trace_post_reporter(trace); 213 213 results = calloc(1, sizeof(result_t) + sizeof(statistic_t) * filter_count); 214 214 last_ts++; … … 234 234 // printf ("%d.%06d READ #%"PRIu64"\n", tv.tv_sec, tv.tv_usec, trace_packet_get(packet)); 235 235 switch (mesg->code) { 236 case MESSAGE_START ED:236 case MESSAGE_STARTING: 237 237 results = calloc(1, sizeof(result_t) + sizeof(statistic_t) * filter_count); 238 238 break; 239 case MESSAGE_STOPP ED:239 case MESSAGE_STOPPING: 240 240 // Should we always post this? 241 241 if (results->total.count) { 242 trace_publish_result(trace, (uint64_t) last_ts, results);243 trace_post_re duce(trace);242 trace_publish_result(trace, t, (uint64_t) last_ts, results, RESULT_NORMAL); 243 trace_post_reporter(trace); 244 244 results = NULL; 245 245 } … … 260 260 if (next_update_time <= mesg->additional.uint64) { 261 261 //fprintf(stderr, "Got a tick and publishing early!!\n"); 262 trace_publish_result(trace, (uint64_t) last_ts, results);263 trace_post_re duce(trace);262 trace_publish_result(trace, t, (uint64_t) last_ts, results, RESULT_NORMAL); 263 trace_post_reporter(trace); 264 264 results = calloc(1, sizeof(result_t) + sizeof(statistic_t) * filter_count); 265 265 last_ts++;
Note: See TracChangeset
for help on using the changeset viewer.