Commit 2cadef46 authored by antirez's avatar antirez
Browse files

Streams: increment dirty counter for XGROUP SETID/DESTROY.

See issue #5005 comments.
parent 093ec57d
...@@ -1614,11 +1614,13 @@ NULL ...@@ -1614,11 +1614,13 @@ NULL
} }
cg->last_id = id; cg->last_id = id;
addReply(c,shared.ok); addReply(c,shared.ok);
server.dirty++;
} else if (!strcasecmp(opt,"DESTROY") && c->argc == 4) { } else if (!strcasecmp(opt,"DESTROY") && c->argc == 4) {
if (cg) { if (cg) {
raxRemove(s->cgroups,(unsigned char*)grpname,sdslen(grpname),NULL); raxRemove(s->cgroups,(unsigned char*)grpname,sdslen(grpname),NULL);
streamFreeCG(cg); streamFreeCG(cg);
addReply(c,shared.cone); addReply(c,shared.cone);
server.dirty++;
} else { } else {
addReply(c,shared.czero); addReply(c,shared.czero);
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment