diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-10-26 18:07:16 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-10-26 18:07:16 +0300 |
| commit | 7cb4835a7f3bee6c42d3469a14b7acd0bbe9ea56 (patch) | |
| tree | e9d8e55ddabc9e18d108f250a469d7b8b1f17823 /src/gm.erl | |
| parent | ed1ef0aa2b545f64cbde5ef018c6386f90a9bc19 (diff) | |
| parent | e0866b7c2ecb50c13bd137eb3d5600816f9ad96d (diff) | |
| download | rabbitmq-server-git-7cb4835a7f3bee6c42d3469a14b7acd0bbe9ea56.tar.gz | |
Merge branch 'stable' into rabbitmq-server-960
Diffstat (limited to 'src/gm.erl')
| -rw-r--r-- | src/gm.erl | 19 |
1 files changed, 14 insertions, 5 deletions
diff --git a/src/gm.erl b/src/gm.erl index 74e19ee6fd..41aa01f04d 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -1175,11 +1175,20 @@ record_new_member_in_group(NewMember, Left, GroupName, TxnFun) -> try Group = #gm_group { members = Members, version = Ver } = check_membership(Left, read_group(GroupName)), - {Prefix, [Left | Suffix]} = - lists:splitwith(fun (M) -> M =/= Left end, Members), - write_group(Group #gm_group { - members = Prefix ++ [Left, NewMember | Suffix], - version = Ver + 1 }) + case lists:member(NewMember, Members) of + true -> + %% This avois duplicates during partial partitions, + %% as inconsistent views might happen during them + rabbit_log:warning("(~p) GM avoiding duplicate of ~p", + [self(), NewMember]), + Group; + false -> + {Prefix, [Left | Suffix]} = + lists:splitwith(fun (M) -> M =/= Left end, Members), + write_group(Group #gm_group { + members = Prefix ++ [Left, NewMember | Suffix], + version = Ver + 1 }) + end catch lost_membership -> %% The transaction must not be abruptly crashed, but |