kanoi 10 years ago
parent
commit
f3d3c11869
  1. 15
      src/connector.c

15
src/connector.c

@ -351,10 +351,17 @@ reparse:
json_object_set_new_nocheck(val, "address", json_string(client->address_name)); json_object_set_new_nocheck(val, "address", json_string(client->address_name));
json_object_set_new_nocheck(val, "server", json_integer(client->server)); json_object_set_new_nocheck(val, "server", json_integer(client->server));
s = json_dumps(val, 0); s = json_dumps(val, 0);
if (ckp->passthrough)
send_proc(ckp->generator, s); ck_rlock(&cdata->lock);
else /* Do not send messages of clients we've already dropped */
send_proc(ckp->stratifier, s); 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); free(s);
json_decref(val); json_decref(val);
} }

Loading…
Cancel
Save