From 1c2376ce40661950b125dc031795b760945dfe16 Mon Sep 17 00:00:00 2001 From: Con Kolivas Date: Wed, 6 Jan 2016 18:00:10 +1100 Subject: [PATCH] Stats break without the ckmsgqs in node mode --- src/stratifier.c | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/stratifier.c b/src/stratifier.c index e574735a..93cd4333 100644 --- a/src/stratifier.c +++ b/src/stratifier.c @@ -6551,12 +6551,11 @@ int stratifier(proc_instance_t *pi) /* Create 1/4 as many stratum processing threads as there are CPUs */ if (ckp->node) threads = 1; - else { - sdata->ssends = create_ckmsgq(ckp, "ssender", &ssend_process); + else threads = threads / 2 ? : 1; - sdata->sauthq = create_ckmsgq(ckp, "authoriser", &sauth_process); - sdata->stxnq = create_ckmsgq(ckp, "stxnq", &send_transactions); - } + sdata->ssends = create_ckmsgq(ckp, "ssender", &ssend_process); + 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); if (!CKP_STANDALONE(ckp)) { sdata->ckdbq = create_ckmsgq(ckp, "ckdbqueue", &ckdbq_process);