Changes in / [9e7c502:9b9c279]
- Location:
- lib
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
lib/combiner_ordered.c
r21c0d70 r733c8b4 51 51 c->last_ts_tick = peeked->key; 52 52 53 /* Tick doesn't match packet order */ 54 if (!trace_is_parallel(trace)) { 55 /* Pass straight to reporter */ 56 libtrace_generic_t gt = {.res = peeked}; 57 ASSERT_RET (libtrace_deque_pop_front(v, (void *) peeked), == 1); 58 send_message(trace, &trace->reporter_thread, 59 MESSAGE_RESULT, gt, 60 &trace->reporter_thread); 61 return 0; 62 } 63 /* Tick matches packet order */ 64 *key = peeked->key; 65 return 1; 53 /* Pass straight to reporter */ 54 libtrace_generic_t gt = {.res = peeked}; 55 ASSERT_RET (libtrace_deque_pop_front(v, (void *) peeked), == 1); 56 send_message(trace, &trace->reporter_thread, 57 MESSAGE_RESULT, gt, 58 &trace->reporter_thread); 59 return 0; 66 60 67 61 } else { … … 157 151 158 152 ASSERT_RET (libtrace_deque_pop_front(&queues[min_queue], (void *) &r), == 1); 153 154 //printf("%lu %lu %lu %lu %d\n", key[0], key[1], key[2], key[3], min_queue); 159 155 160 156 send_message(trace, &trace->reporter_thread, -
lib/trace.c
rb24d186 rb24d186 136 136 static void trace_init(void) 137 137 { 138 struct timeval tv; 139 gettimeofday(&tv, NULL); 140 srand(tv.tv_sec); 141 138 142 if (!formats_list) { 139 143 duck_constructor();
Note: See TracChangeset
for help on using the changeset viewer.