Commit acf43028 authored by Pedro Gonnet's avatar Pedro Gonnet
Browse files

more local queue selection.


Former-commit-id: 1d4a50edf9497409fa0ff166b7252dbadd01e0d5
parent a83dabf4
......@@ -477,7 +477,7 @@ void *runner_main ( void *data ) {
/* Set some convenient local data. */
keep = e->policy & engine_policy_keep;
myq = &e->queues[ threadID % e->nr_queues ];
myq = &e->queues[ threadID * e->nr_queues / e->nr_threads ];
tpq = ceil( ((double)e->nr_threads) / e->nr_queues );
#ifdef TIMER
stalled = 0;
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment