diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-04-21 13:35:51 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-04-21 13:35:51 +0100 |
| commit | 7e06dab05bf2ef18c5c3691be52c1566a021ed6b (patch) | |
| tree | d41838f5c7312935bc161681b7f62bab1120d274 | |
| parent | 7feb36559aaf72e90c9f675a10c2d060fae693e6 (diff) | |
| download | rabbitmq-server-git-7e06dab05bf2ef18c5c3691be52c1566a021ed6b.tar.gz | |
cosmetic: consistency
| -rw-r--r-- | src/gm.erl | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/src/gm.erl b/src/gm.erl index 4e6efa93b4..504ed8bfdc 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -1106,17 +1106,18 @@ prune_or_create_group(Self, GroupName, TxnFun) -> record_dead_member_in_group(Member, GroupName, TxnFun) -> TxnFun( - fun () -> Group = #gm_group { members = Members, version = Ver } = - read_group(GroupName), - case lists:splitwith( - fun (Member1) -> Member1 =/= Member end, Members) of - {_Members1, []} -> %% not found - already recorded dead - Group; - {Members1, [Member | Members2]} -> - Members3 = Members1 ++ [{dead, Member} | Members2], - write_group(Group #gm_group { members = Members3, - version = Ver + 1 }) - end + fun () -> + Group = #gm_group { members = Members, version = Ver } = + read_group(GroupName), + case lists:splitwith( + fun (Member1) -> Member1 =/= Member end, Members) of + {_Members1, []} -> %% not found - already recorded dead + Group; + {Members1, [Member | Members2]} -> + Members3 = Members1 ++ [{dead, Member} | Members2], + write_group(Group #gm_group { members = Members3, + version = Ver + 1 }) + end end). record_new_member_in_group(NewMember, Left, GroupName, TxnFun) -> |