summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2014-04-21 13:35:51 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2014-04-21 13:35:51 +0100
commitb7733c51eaa10f9858142ccb71e38f10a93eb825 (patch)
treed41838f5c7312935bc161681b7f62bab1120d274
parentfadf56dcf15f3fb74200cb2f35aa2bc81c3fc06f (diff)
downloadrabbitmq-server-b7733c51eaa10f9858142ccb71e38f10a93eb825.tar.gz
cosmetic: consistency
-rw-r--r--src/gm.erl23
1 files changed, 12 insertions, 11 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 4e6efa93..504ed8bf 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) ->