diff options
| author | Salvatore Sanfilippo <antirez@gmail.com> | 2020-02-27 09:59:51 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-02-27 09:59:51 +0100 |
| commit | 049969971e78ecfc87456cbacf389858d8cbf14b (patch) | |
| tree | c0ea100653ffede1580edb92878122cec507053b | |
| parent | d2c5f80e2ebbc532e82a20411a0d62ca309a013e (diff) | |
| parent | a6c7e61e61a253e5cddd4cf919e63da321d4afe8 (diff) | |
| download | redis-049969971e78ecfc87456cbacf389858d8cbf14b.tar.gz | |
Merge pull request #6921 from guybe7/fix_xclaim_propagate
XREADGROUP should propagate XCALIM/SETID in MULTI/EXEC
| -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]); |