diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2020-02-23 19:13:09 +0530 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2020-02-27 18:02:30 +0100 |
| commit | 4d12c37c54d81a89ccbbea3c23f783477fb97c51 (patch) | |
| tree | 689509324e358300116613400022148157a67b0c | |
| parent | 12626ce9bb58bbc9f32d7ae94e343a827bd81663 (diff) | |
| download | redis-4d12c37c54d81a89ccbbea3c23f783477fb97c51.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 900fa3a17..e1efc6bca 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]); |