diff options
author | antirez <antirez@gmail.com> | 2018-11-26 16:20:01 +0100 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2018-12-21 11:42:51 +0100 |
commit | 81be5d2ce656bc6f58a73a278c011058650e7025 (patch) | |
tree | 5f700687fd4f01673c2a9c49606437bcfc015695 | |
parent | d64f16c30ec32445fec2d73f11932f1b1f410a44 (diff) | |
download | redis-81be5d2ce656bc6f58a73a278c011058650e7025.tar.gz |
RESP3: Use new aggregate reply API in slowlog.c.
-rw-r--r-- | src/multi.c | 2 | ||||
-rw-r--r-- | src/slowlog.c | 8 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/multi.c b/src/multi.c index d7f7d4ae8..84a7bb86a 100644 --- a/src/multi.c +++ b/src/multi.c @@ -159,7 +159,7 @@ void execCommand(client *c) { orig_argv = c->argv; orig_argc = c->argc; orig_cmd = c->cmd; - addReplyMultiBulkLen(c,c->mstate.count); + addReplyArrayLen(c,c->mstate.count); for (j = 0; j < c->mstate.count; j++) { c->argc = c->mstate.commands[j].argc; c->argv = c->mstate.commands[j].argv; diff --git a/src/slowlog.c b/src/slowlog.c index 8e183fca4..1d715e39b 100644 --- a/src/slowlog.c +++ b/src/slowlog.c @@ -169,23 +169,23 @@ NULL return; listRewind(server.slowlog,&li); - totentries = addDeferredMultiBulkLength(c); + totentries = addReplyDeferredLen(c); while(count-- && (ln = listNext(&li))) { int j; se = ln->value; - addReplyMultiBulkLen(c,6); + addReplyArrayLen(c,6); addReplyLongLong(c,se->id); addReplyLongLong(c,se->time); addReplyLongLong(c,se->duration); - addReplyMultiBulkLen(c,se->argc); + addReplyArrayLen(c,se->argc); for (j = 0; j < se->argc; j++) addReplyBulk(c,se->argv[j]); addReplyBulkCBuffer(c,se->peerid,sdslen(se->peerid)); addReplyBulkCBuffer(c,se->cname,sdslen(se->cname)); sent++; } - setDeferredMultiBulkLength(c,totentries,sent); + setDeferredArrayLen(c,totentries,sent); } else { addReplySubcommandSyntaxError(c); } |