fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-30 22:31:03 +00:00
Code Issues Projects Releases Wiki Activity

RESP3: Use new aggregate reply API in slowlog.c.

Browse Source
This commit is contained in:
antirez 2018-11-26 16:20:01 +01:00
parent feb6b31832
commit f07f3d729f
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/multi.c
View File

@ -159,7 +159,7 @@ void execCommand(client *c) {
orig_argv = c->argv; orig_argv = c->argv;
orig_argc = c->argc; orig_argc = c->argc;
orig_cmd = c->cmd; orig_cmd = c->cmd;
addReplyMultiBulkLen(c,c->mstate.count); addReplyArrayLen(c,c->mstate.count);
for (j = 0; j < c->mstate.count; j++) { for (j = 0; j < c->mstate.count; j++) {
c->argc = c->mstate.commands[j].argc; c->argc = c->mstate.commands[j].argc;
c->argv = c->mstate.commands[j].argv; c->argv = c->mstate.commands[j].argv;

8
src/slowlog.c
View File

@ -169,23 +169,23 @@ NULL
return; return;
listRewind(server.slowlog,&li); listRewind(server.slowlog,&li);
totentries = addDeferredMultiBulkLength(c); totentries = addReplyDeferredLen(c);
while(count-- && (ln = listNext(&li))) { while(count-- && (ln = listNext(&li))) {
int j; int j;
se = ln->value; se = ln->value;
addReplyMultiBulkLen(c,6); addReplyArrayLen(c,6);
addReplyLongLong(c,se->id); addReplyLongLong(c,se->id);
addReplyLongLong(c,se->time); addReplyLongLong(c,se->time);
addReplyLongLong(c,se->duration); addReplyLongLong(c,se->duration);
addReplyMultiBulkLen(c,se->argc); addReplyArrayLen(c,se->argc);
for (j = 0; j < se->argc; j++) for (j = 0; j < se->argc; j++)
addReplyBulk(c,se->argv[j]); addReplyBulk(c,se->argv[j]);
addReplyBulkCBuffer(c,se->peerid,sdslen(se->peerid)); addReplyBulkCBuffer(c,se->peerid,sdslen(se->peerid));
addReplyBulkCBuffer(c,se->cname,sdslen(se->cname)); addReplyBulkCBuffer(c,se->cname,sdslen(se->cname));
sent++; sent++;
} }
setDeferredMultiBulkLength(c,totentries,sent); setDeferredArrayLen(c,totentries,sent);
} else { } else {
addReplySubcommandSyntaxError(c); addReplySubcommandSyntaxError(c);
} }