CG: propagate XACK by incrementing server.dirty.

This should be more than enough, even if in case of partial IDs that are
not found, we send all the IDs to the slave/AOF, but this is definitely
a corner case without bad effects if not some wasted space.
This commit is contained in:
antirez 2018-03-20 17:53:45 +01:00
parent 0f2c6b6a18
commit 233da29f4d

View File

@ -1559,6 +1559,7 @@ void xackCommand(client *c) {
raxRemove(nack->consumer->pel,buf,sizeof(buf),NULL);
streamFreeNACK(nack);
acknowledged++;
server.dirty++;
}
}
addReplyLongLong(c,acknowledged);