From ad716e29c03ecce28467b83ab352038fb77933b3 Mon Sep 17 00:00:00 2001 From: antirez Date: Tue, 20 Mar 2018 11:13:41 +0100 Subject: [PATCH] CG: Fix propagate() arg count in streamPropagateXCLAIM(). --- src/t_stream.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/t_stream.c b/src/t_stream.c index d2afa6a7..39ab2f88 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -699,7 +699,7 @@ void streamPropagateXCLAIM(client *c, robj *key, robj *group, robj *id, streamNA argv[8] = createStringObject("RETRYCOUNT",10); argv[9] = createStringObjectFromLongLong(nack->delivery_count); argv[10] = createStringObject("FORCE",5); - propagate(server.xclaimCommand,c->db->id,argv,10,PROPAGATE_AOF|PROPAGATE_REPL); + propagate(server.xclaimCommand,c->db->id,argv,11,PROPAGATE_AOF|PROPAGATE_REPL); decrRefCount(argv[0]); decrRefCount(argv[3]); decrRefCount(argv[4]);