diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-10-19 14:19:48 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-10-19 14:19:48 +0100 |
| commit | abed65a0a313901c1fd75ab2ce5dde697a167cc2 (patch) | |
| tree | 934648554d571231d71ff54f556d5576eaeb5347 /src/gm.erl | |
| parent | d59eed2f4b2e1d6e0ddce2007b1f1e8afca93c43 (diff) | |
| download | rabbitmq-server-git-abed65a0a313901c1fd75ab2ce5dde697a167cc2.tar.gz | |
Cosmetic
Diffstat (limited to 'src/gm.erl')
| -rw-r--r-- | src/gm.erl | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/src/gm.erl b/src/gm.erl index 43cca49527..b18ae8ceb2 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -1015,9 +1015,8 @@ join_group(Self, GroupName, #gm_group { members = Members } = Group, TxnFun) -> fun () -> join_group( Self, GroupName, - record_dead_member_in_group(Left, - GroupName, - TxnFun), + record_dead_member_in_group( + Left, GroupName, TxnFun), TxnFun) end, try @@ -1045,20 +1044,21 @@ read_group(GroupName) -> prune_or_create_group(Self, GroupName, TxnFun) -> Group = TxnFun( - fun () -> GroupNew = #gm_group { name = GroupName, - members = [Self], - version = ?VERSION_START }, - case mnesia:read({?GROUP_TABLE, GroupName}) of - [] -> - mnesia:write(GroupNew), - GroupNew; - [Group1 = #gm_group { members = Members }] -> - case lists:any(fun is_member_alive/1, Members) of - true -> Group1; - false -> mnesia:write(GroupNew), - GroupNew - end - end + fun () -> + GroupNew = #gm_group { name = GroupName, + members = [Self], + version = ?VERSION_START }, + case mnesia:read({?GROUP_TABLE, GroupName}) of + [] -> + mnesia:write(GroupNew), + GroupNew; + [Group1 = #gm_group { members = Members }] -> + case lists:any(fun is_member_alive/1, Members) of + true -> Group1; + false -> mnesia:write(GroupNew), + GroupNew + end + end end), Group. |