diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2020-02-23 19:13:09 +0530 |
|---|---|---|
| committer | Guy Benoish <guy.benoish@redislabs.com> | 2020-02-23 19:13:15 +0530 |
| commit | a6c7e61e61a253e5cddd4cf919e63da321d4afe8 (patch) | |
| tree | b47a71f6880d6d1549ec732b30d333bdeb9f0aa1 /src/t_stream.c | |
| parent | df45fed050d6822dc86796b0089aaf1b56c7830e (diff) | |
| download | redis-a6c7e61e61a253e5cddd4cf919e63da321d4afe8.tar.gz | |
XREADGROUP should propagate XCALIM/SETID in MULTI/EXEC
Use built-in alsoPropagate mechanism that wraps commands
in MULTI/EXEC before sending them to replica/AOF
Diffstat (limited to 'src/t_stream.c')
| -rw-r--r-- | src/t_stream.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 0f0f97a1d..fcfc5ca71 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -848,7 +848,7 @@ void streamPropagateXCLAIM(client *c, robj *key, streamCG *group, robj *groupnam argv[11] = createStringObject("JUSTID",6); argv[12] = createStringObject("LASTID",6); argv[13] = createObjectFromStreamID(&group->last_id); - propagate(server.xclaimCommand,c->db->id,argv,14,PROPAGATE_AOF|PROPAGATE_REPL); + alsoPropagate(server.xclaimCommand,c->db->id,argv,14,PROPAGATE_AOF|PROPAGATE_REPL); decrRefCount(argv[0]); decrRefCount(argv[3]); decrRefCount(argv[4]); @@ -875,7 +875,7 @@ void streamPropagateGroupID(client *c, robj *key, streamCG *group, robj *groupna argv[2] = key; argv[3] = groupname; argv[4] = createObjectFromStreamID(&group->last_id); - propagate(server.xgroupCommand,c->db->id,argv,5,PROPAGATE_AOF|PROPAGATE_REPL); + alsoPropagate(server.xgroupCommand,c->db->id,argv,5,PROPAGATE_AOF|PROPAGATE_REPL); decrRefCount(argv[0]); decrRefCount(argv[1]); decrRefCount(argv[4]); |