summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-05-13 15:13:43 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-05-13 15:13:43 +0100
commitacadfd306b8f369fa26dca615dd224c4c04aae9c (patch)
tree5528748e8d4d56cd8be5c7798a244614fdc15da6
parent81b86fc6f048e0f9d45e56f2a615e2700469c323 (diff)
parentadbaa72127d98a20df743e0f25ea34b3e7f1ee3e (diff)
downloadrabbitmq-server-acadfd306b8f369fa26dca615dd224c4c04aae9c.tar.gz
Merge bug26172
-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 =