From 233da29f4da7360f691fc491b03278c8d56fe7de Mon Sep 17 00:00:00 2001
From: antirez <antirez@gmail.com>
Date: Tue, 20 Mar 2018 17:53:45 +0100
Subject: [PATCH] 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.
---
 src/t_stream.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/t_stream.c b/src/t_stream.c
index 37f08572..daf9509d 100644
--- a/src/t_stream.c
+++ b/src/t_stream.c
@@ -1559,6 +1559,7 @@ void xackCommand(client *c) {
             raxRemove(nack->consumer->pel,buf,sizeof(buf),NULL);
             streamFreeNACK(nack);
             acknowledged++;
+            server.dirty++;
         }
     }
     addReplyLongLong(c,acknowledged);