gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

XINFO STREAM FULL should have a default COUNT of 10

Browse Source
This commit is contained in:
Guy Benoish 2020-04-28 17:58:25 +03:00 committed by antirez
parent 606134f9de
commit aab74b7151
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/t_stream.c
View File

@ -2493,7 +2493,7 @@ void xtrimCommand(client *c) {
* Handles the variants of XINFO STREAM */ * Handles the variants of XINFO STREAM */
void xinfoReplyWithStreamInfo(client *c, stream *s) { void xinfoReplyWithStreamInfo(client *c, stream *s) {
int full = 1; int full = 1;
long long count = 0; long long count = 10; /* Default COUNT is 10 so we don't block the server */
robj **optv = c->argv + 3; /* Options start after XINFO STREAM <key> */ robj **optv = c->argv + 3; /* Options start after XINFO STREAM <key> */
int optc = c->argc - 3; int optc = c->argc - 3;
@ -2521,7 +2521,7 @@ void xinfoReplyWithStreamInfo(client *c, stream *s) {
} }
if (getLongLongFromObjectOrReply(c,optv[2],&count,NULL) == C_ERR) if (getLongLongFromObjectOrReply(c,optv[2],&count,NULL) == C_ERR)
return; return;
if (count < 0) count = 0; if (count < 0) count = 10;
} }
} }
@ -2682,6 +2682,10 @@ void xinfoCommand(client *c) {
"CONSUMERS <key> <groupname> -- Show consumer groups of group <groupname>.", "CONSUMERS <key> <groupname> -- Show consumer groups of group <groupname>.",
"GROUPS <key> -- Show the stream consumer groups.", "GROUPS <key> -- Show the stream consumer groups.",
"STREAM <key> [FULL [COUNT <count>]] -- Show information about the stream.", "STREAM <key> [FULL [COUNT <count>]] -- Show information about the stream.",
" FULL will return the full state of the stream,",
" including all entries, groups, consumers and PELs.",
" It's possible to show only the first stream/PEL entries",
" by using the COUNT modifier (Default is 10)",
"HELP -- Print this help.", "HELP -- Print this help.",
NULL NULL
}; };