caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 08:38:27 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #5136 from 0xtonyxia/fix-xread-id-parse

Browse Source 
Fix xreadgroup with '$' ID.
This commit is contained in:
Salvatore Sanfilippo 2018-07-17 17:50:31 +02:00 committed by GitHub
commit 4bff45c7a6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/t_stream.c
View File

@ -1351,6 +1351,11 @@ void xreadCommand(client *c) {
} }
if (strcmp(c->argv[i]->ptr,"$") == 0) { if (strcmp(c->argv[i]->ptr,"$") == 0) {
if (xreadgroup) {
addReplyError(c,"The $ ID can be specified only when calling "
"XREAD without GROUP option.");
goto cleanup;
}
if (o) { if (o) {
stream *s = o->ptr; stream *s = o->ptr;
ids[id_idx] = s->last_id; ids[id_idx] = s->last_id;
@ -1360,7 +1365,7 @@ void xreadCommand(client *c) {
} }
continue; continue;
} else if (strcmp(c->argv[i]->ptr,">") == 0) { } else if (strcmp(c->argv[i]->ptr,">") == 0) {
if (!xreadgroup || groupname == NULL) { if (!xreadgroup) {
addReplyError(c,"The > ID can be specified only when calling " addReplyError(c,"The > ID can be specified only when calling "
"XREADGROUP using the GROUP <group> " "XREADGROUP using the GROUP <group> "
"<consumer> option."); "<consumer> option.");