diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2016-09-11 09:50:56 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2016-09-12 10:09:27 +0100 |
| commit | acc39e857742cfb2ebbeb6675fd233913edf9552 (patch) | |
| tree | 02983b4aef1d851bee39efc249165eb79e457ee7 /src/gm.erl | |
| parent | 3b0f2762cb1c526b1b4d293abfa35adabca62305 (diff) | |
| download | rabbitmq-server-git-acc39e857742cfb2ebbeb6675fd233913edf9552.tar.gz | |
Handle not found outside of verify
Diffstat (limited to 'src/gm.erl')
| -rw-r--r-- | src/gm.erl | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl index 008a29151e..c6d73b6cdd 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -1137,7 +1137,7 @@ record_dead_member_in_group(Self, Member, GroupName, TxnFun, Verify) -> true -> check_membership(Self, read_group(GroupName)); false -> - read_group(GroupName) + check_group(read_group(GroupName)) end, case lists:splitwith( fun (Member1) -> Member1 =/= Member end, Members) of @@ -1615,3 +1615,8 @@ check_membership(GroupName) -> {error, not_found} -> throw(lost_membership) end. + +check_group({error, not_found}) -> + throw(lost_membership); +check_group(Any) -> + Any. |