Streams: increment dirty counter for XGROUP SETID/DESTROY.

See issue #5005 comments.
This commit is contained in:
antirez 2018-06-12 09:27:32 +02:00
parent cec404f099
commit 923e63e5ec

View File

@ -1614,11 +1614,13 @@ NULL
}
cg->last_id = id;
addReply(c,shared.ok);
server.dirty++;
} else if (!strcasecmp(opt,"DESTROY") && c->argc == 4) {
if (cg) {
raxRemove(s->cgroups,(unsigned char*)grpname,sdslen(grpname),NULL);
streamFreeCG(cg);
addReply(c,shared.cone);
server.dirty++;
} else {
addReply(c,shared.czero);
}