summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-05-12 16:36:56 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-05-12 16:36:56 +0100
commit2a7f38273d835e4b4f96f1a7b46bf393185eb63b (patch)
tree82222e3c72b7bd5ad3ec3ae1a54caa64f26ce83a
parentfe2d1f059667245fab1420f7d56003dff8ec5395 (diff)
parentadbaa72127d98a20df743e0f25ea34b3e7f1ee3e (diff)
downloadrabbitmq-server-2a7f38273d835e4b4f96f1a7b46bf393185eb63b.tar.gz
stable to default
-rw-r--r--src/gm.erl3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 0c0ac349..fb59b9cb 100644
--- a/src/gm.erl
+++ b/src/gm.erl
@@ -1036,7 +1036,8 @@ join_group(Self, GroupName, #gm_group { members = Members } = Group, TxnFun) ->
case lists:filter(fun is_member_alive/1, Members) of
[] ->
join_group(Self, GroupName,
- prune_or_create_group(Self, GroupName, TxnFun));
+ prune_or_create_group(Self, GroupName, TxnFun),
+ TxnFun);
Alive ->
Left = lists:nth(random:uniform(length(Alive)), Alive),
Handler =