diff --git a/src/connector.c b/src/connector.c index f47e30b0..f1679362 100644 --- a/src/connector.c +++ b/src/connector.c @@ -352,15 +352,15 @@ reparse: json_object_set_new_nocheck(val, "server", json_integer(client->server)); s = json_dumps(val, 0); - ck_rlock(&cdata->lock); - /* Do not send messages of clients we've already dropped */ + /* Do not send messages of clients we've already dropped. We + * do this unlocked as the occasional false negative can be + * filtered by the stratifier. */ if (likely(client->fd != -1)) { if (ckp->passthrough) send_proc(ckp->generator, s); else send_proc(ckp->stratifier, s); } - ck_runlock(&cdata->lock); free(s); json_decref(val);