From f368692c493d67e759988f99305b8db8dac01a33 Mon Sep 17 00:00:00 2001 From: Con Kolivas Date: Sat, 27 Feb 2016 09:25:43 +1100 Subject: [PATCH] Reinstate "Further thread the next two biggest CPU users" This reverts commit 96aa070652fa8a2438445c5aebc40df33f3b7fe5. --- src/stratifier.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/stratifier.c b/src/stratifier.c index f55825a1..3ad4914a 100644 --- a/src/stratifier.c +++ b/src/stratifier.c @@ -7586,11 +7586,11 @@ void *stratifier(void *arg) * are CPUs */ threads = sysconf(_SC_NPROCESSORS_ONLN) / 2 ? : 1; sdata->sshareq = create_ckmsgqs(ckp, "sprocessor", &sshare_process, threads); - sdata->ssends = create_ckmsgq(ckp, "ssender", &ssend_process); + sdata->ssends = create_ckmsgqs(ckp, "ssender", &ssend_process, threads); sdata->sauthq = create_ckmsgq(ckp, "authoriser", &sauth_process); sdata->stxnq = create_ckmsgq(ckp, "stxnq", &send_transactions); sdata->srecvs = create_ckmsgqs(ckp, "sreceiver", &srecv_process, threads); - sdata->ckdbq = create_ckmsgq(ckp, "ckdbqueue", &ckdbq_process); + sdata->ckdbq = create_ckmsgqs(ckp, "ckdbqueue", &ckdbq_process, threads); create_pthread(&pth_heartbeat, ckdb_heartbeat, ckp); read_poolstats(ckp);