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 | b7733c51eaa10f9858142ccb71e38f10a93eb825 (patch) | |
tree | d41838f5c7312935bc161681b7f62bab1120d274 | |
parent | fadf56dcf15f3fb74200cb2f35aa2bc81c3fc06f (diff) | |
download | rabbitmq-server-b7733c51eaa10f9858142ccb71e38f10a93eb825.tar.gz |
cosmetic: consistency
-rw-r--r-- | src/gm.erl | 23 |
1 files changed, 12 insertions, 11 deletions
@@ -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) -> |