diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-05-12 16:36:45 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-05-12 16:36:45 +0100 |
| commit | 194b3ea47e3c9d2c485fee583f9ac7f19710ae6c (patch) | |
| tree | df2f3c316f00988e08c30e6479c409f8636175a3 | |
| parent | 57bc69b6895cf0f6aca14082386e01666ceef48f (diff) | |
| parent | 6a456b6c791c65d4701f716abd9889dbf82db143 (diff) | |
| download | rabbitmq-server-git-194b3ea47e3c9d2c485fee583f9ac7f19710ae6c.tar.gz | |
Merge bug 26173
| -rw-r--r-- | src/gm.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl index 0c0ac349b0..fb59b9cb0b 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 = |