Hiredis update removes the need for this.

master
Nicolas Favre-Felix 14 years ago
parent 96643bf89c
commit b62630d31d

@ -40,7 +40,6 @@ struct pubsub_client {
struct evhttp_request *rq;
};
void __redisAsyncDisconnect(redisAsyncContext *ac);
void on_http_disconnect(struct evhttp_connection *evcon, void *ctx) {
struct pubsub_client *ps = ctx;

@ -44,14 +44,8 @@ json_reply(redisAsyncContext *c, void *r, void *privdata) {
evhttp_add_header(cmd->rq->output_headers, "Content-Type", "application/json");
if(cmd_is_subscribe(cmd)) {
redisCallback cb;
free_cmd = 0;
/* reinstall callback */
cb.fn = json_reply;
cb.privdata = privdata;
__redisPushCallback(&c->replies, &cb);
/* start streaming */
if(cmd->started_responding == 0) {
cmd->started_responding = 1;

Loading…
Cancel
Save