Commit 30a9f8f2 authored by Pieter Noordhuis's avatar Pieter Noordhuis
Browse files

Use existing function to append to the output buffer

parent ef995acc
...@@ -33,6 +33,9 @@ ...@@ -33,6 +33,9 @@
#include "sds.h" #include "sds.h"
#include "util.h" #include "util.h"
/* Forward declaration of function in hiredis.c */
void __redisAppendCommand(redisContext *c, char *cmd, size_t len);
static redisAsyncContext *redisAsyncInitialize(redisContext *c) { static redisAsyncContext *redisAsyncInitialize(redisContext *c) {
redisAsyncContext *ac = realloc(c,sizeof(redisAsyncContext)); redisAsyncContext *ac = realloc(c,sizeof(redisAsyncContext));
/* Set all bytes in the async part of the context to 0 */ /* Set all bytes in the async part of the context to 0 */
...@@ -231,7 +234,7 @@ static int __redisAsyncCommand(redisAsyncContext *ac, redisCallbackFn *fn, void ...@@ -231,7 +234,7 @@ static int __redisAsyncCommand(redisAsyncContext *ac, redisCallbackFn *fn, void
/* Don't accept new commands when the connection is lazily closed. */ /* Don't accept new commands when the connection is lazily closed. */
if (c->flags & REDIS_DISCONNECTING) return REDIS_ERR; if (c->flags & REDIS_DISCONNECTING) return REDIS_ERR;
c->obuf = sdscatlen(c->obuf,cmd,len); __redisAppendCommand(c,cmd,len);
/* Store callback */ /* Store callback */
cb.fn = fn; cb.fn = fn;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment