diff --git a/src/stratifier.c b/src/stratifier.c index ae482593..88c84285 100644 --- a/src/stratifier.c +++ b/src/stratifier.c @@ -2657,6 +2657,11 @@ static void stratum_broadcast(sdata_t *sdata, json_t *val, const int msg_type) return; } + if (ckp->node) { + json_decref(val); + return; + } + /* Use this locking as an opportunity to test other clients. */ ck_rlock(&ckp_sdata->instance_lock); HASH_ITER(hh, ckp_sdata->stratum_instances, client, tmp) {