summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorantirez <antirez@gmail.com>2018-11-26 16:20:01 +0100
committerantirez <antirez@gmail.com>2018-12-21 11:42:51 +0100
commit81be5d2ce656bc6f58a73a278c011058650e7025 (patch)
tree5f700687fd4f01673c2a9c49606437bcfc015695
parentd64f16c30ec32445fec2d73f11932f1b1f410a44 (diff)
downloadredis-81be5d2ce656bc6f58a73a278c011058650e7025.tar.gz
RESP3: Use new aggregate reply API in slowlog.c.
-rw-r--r--src/multi.c2
-rw-r--r--src/slowlog.c8
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);
}