|
|
@ -6551,12 +6551,11 @@ int stratifier(proc_instance_t *pi) |
|
|
|
/* Create 1/4 as many stratum processing threads as there are CPUs */ |
|
|
|
/* Create 1/4 as many stratum processing threads as there are CPUs */ |
|
|
|
if (ckp->node) |
|
|
|
if (ckp->node) |
|
|
|
threads = 1; |
|
|
|
threads = 1; |
|
|
|
else { |
|
|
|
else |
|
|
|
sdata->ssends = create_ckmsgq(ckp, "ssender", &ssend_process); |
|
|
|
|
|
|
|
threads = threads / 2 ? : 1; |
|
|
|
threads = threads / 2 ? : 1; |
|
|
|
|
|
|
|
sdata->ssends = create_ckmsgq(ckp, "ssender", &ssend_process); |
|
|
|
sdata->sauthq = create_ckmsgq(ckp, "authoriser", &sauth_process); |
|
|
|
sdata->sauthq = create_ckmsgq(ckp, "authoriser", &sauth_process); |
|
|
|
sdata->stxnq = create_ckmsgq(ckp, "stxnq", &send_transactions); |
|
|
|
sdata->stxnq = create_ckmsgq(ckp, "stxnq", &send_transactions); |
|
|
|
} |
|
|
|
|
|
|
|
sdata->srecvs = create_ckmsgqs(ckp, "sreceiver", &srecv_process, threads); |
|
|
|
sdata->srecvs = create_ckmsgqs(ckp, "sreceiver", &srecv_process, threads); |
|
|
|
if (!CKP_STANDALONE(ckp)) { |
|
|
|
if (!CKP_STANDALONE(ckp)) { |
|
|
|
sdata->ckdbq = create_ckmsgq(ckp, "ckdbqueue", &ckdbq_process); |
|
|
|
sdata->ckdbq = create_ckmsgq(ckp, "ckdbqueue", &ckdbq_process); |
|
|
|