Changeset f0e8bd6 for lib/trace_parallel.c
- Timestamp:
- 08/19/14 19:36:48 (7 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:
- 50b1bee
- Parents:
- 5b4d121
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
lib/trace_parallel.c
r5b4d121 rf0e8bd6 1510 1510 libtrace->config.hasher_queue_size = 1000; 1511 1511 1512 if (libtrace-> perpkt_thread_count<= 0) {1512 if (libtrace->config.perpkt_threads <= 0) { 1513 1513 // TODO add BSD support 1514 1514 libtrace->perpkt_thread_count = sysconf(_SC_NPROCESSORS_ONLN); … … 1516 1516 // Lets just use one 1517 1517 libtrace->perpkt_thread_count = 1; 1518 } else { 1519 libtrace->perpkt_thread_count = libtrace->config.perpkt_threads; 1518 1520 } 1519 1521 … … 2065 2067 2066 2068 libtrace_result_set_key_value(&res, key, value); 2069 2067 2070 /* 2068 2071 if (count == 1) … … 2074 2077 printf("My vector size is %d\n", libtrace_deque_get_size(&t->deque)); 2075 2078 count = (count+1)%1000;*/ 2079 2076 2080 if (libtrace->reporter_flags & (REDUCE_SEQUENTIAL | REDUCE_ORDERED)) { 2077 2081 if (libtrace_deque_get_size(&t->deque) >= libtrace->config.reporter_thold) { … … 2140 2144 while ((live_count == libtrace->perpkt_thread_count) || (live_count && 2141 2145 ((flags & REDUCE_SEQUENTIAL && min_key == libtrace->expected_key) || 2142 libtrace->state == STATE_JOINED))) {2146 trace_finished(libtrace)))) { 2143 2147 /* Get the minimum queue and then do stuff */ 2144 2148 libtrace_result_t r; … … 2224 2228 return trace_set_hasher(libtrace, (enum hasher_types) *((int *) value), NULL, NULL); 2225 2229 case TRACE_OPTION_SET_PERPKT_THREAD_COUNT: 2226 libtrace-> perpkt_thread_count= *((int *) value);2230 libtrace->config.perpkt_threads = *((int *) value); 2227 2231 return 1; 2228 2232 case TRACE_DROP_OUT_OF_ORDER:
Note: See TracChangeset
for help on using the changeset viewer.