Lines Matching refs:context
85 redisContext *context; member
127 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in freeClient()
128 aeDeleteFileEvent(config.el,c->context->fd,AE_READABLE); in freeClient()
129 redisFree(c->context); in freeClient()
150 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in resetClient()
151 aeDeleteFileEvent(config.el,c->context->fd,AE_READABLE); in resetClient()
152 aeCreateFileEvent(config.el,c->context->fd,AE_WRITABLE,writeHandler,c); in resetClient()
201 if (redisBufferRead(c->context) != REDIS_OK) { in readHandler()
202 fprintf(stderr,"Error: %s\n",c->context->errstr); in readHandler()
206 if (redisGetReply(c->context,&reply) != REDIS_OK) { in readHandler()
207 fprintf(stderr,"Error: %s\n",c->context->errstr); in readHandler()
280 ssize_t nwritten = write(c->context->fd,ptr,sdslen(c->obuf)-c->written); in writeHandler()
289 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in writeHandler()
290 aeCreateFileEvent(config.el,c->context->fd,AE_READABLE,readHandler,c); in writeHandler()
321 c->context = redisConnectNonBlock(config.hostip,config.hostport); in createClient()
323 c->context = redisConnectUnixNonBlock(config.hostsocket); in createClient()
325 if (c->context->err) { in createClient()
328 fprintf(stderr,"%s:%d: %s\n",config.hostip,config.hostport,c->context->errstr); in createClient()
330 fprintf(stderr,"%s: %s\n",config.hostsocket,c->context->errstr); in createClient()
334 c->context->reader->maxbuf = 0; in createClient()
407 aeCreateFileEvent(config.el,c->context->fd,AE_WRITABLE,writeHandler,c); in createClient()