fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-06 09:41:02 +00:00
Code Issues Projects Releases Wiki Activity

Fix XGROUP CREATE MKSTREAM handling of .

Browse Source
This commit is contained in:
antirez 2018-10-17 12:10:52 +02:00
parent 2e3d403349
commit 492fd5c011
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/t_stream.c
View File

@ -1751,14 +1751,19 @@ NULL
if (!strcasecmp(opt,"CREATE") && (c->argc == 5 || c->argc == 6)) { if (!strcasecmp(opt,"CREATE") && (c->argc == 5 || c->argc == 6)) {
streamID id; streamID id;
if (!strcmp(c->argv[4]->ptr,"$")) { if (!strcmp(c->argv[4]->ptr,"$")) {
id = s->last_id; if (s) {
id = s->last_id;
} else {
id.ms = 0;
id.seq = 0;
}
} else if (streamParseStrictIDOrReply(c,c->argv[4],&id,0) != C_OK) { } else if (streamParseStrictIDOrReply(c,c->argv[4],&id,0) != C_OK) {
return; return;
} }
/* Handle the MKSTREAM option now that the command can no longer fail. */ /* Handle the MKSTREAM option now that the command can no longer fail. */
if (s == NULL && mkstream) { if (s == NULL && mkstream) {
robj *o = createStreamObject(); o = createStreamObject();
dbAdd(c->db,c->argv[2],o); dbAdd(c->db,c->argv[2],o);
s = o->ptr; s = o->ptr;
} }