diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2020-02-23 19:13:09 +0530 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2020-03-05 16:30:04 +0100 |
| commit | 4f0f799c96f656eb67e13b1e212773a264450c5c (patch) | |
| tree | 9281d9d6358a4f95f1981d05a557ed1b4386b2b0 | |
| parent | 0c1273c3896c85beed8d84e03f4dc2300975c1f2 (diff) | |
| download | redis-4f0f799c96f656eb67e13b1e212773a264450c5c.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
| -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 ad3e60408..3ee629ee2 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -842,7 +842,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]); @@ -869,7 +869,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]); |