diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-05-12 16:36:56 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-05-12 16:36:56 +0100 |
| commit | 46c70debcbaebd19c291939e34aeb9f9480e7af1 (patch) | |
| tree | 82222e3c72b7bd5ad3ec3ae1a54caa64f26ce83a /src | |
| parent | 6b927367091d058247aa4d0f4c2ec93a5cb8999d (diff) | |
| parent | 194b3ea47e3c9d2c485fee583f9ac7f19710ae6c (diff) | |
| download | rabbitmq-server-git-46c70debcbaebd19c291939e34aeb9f9480e7af1.tar.gz | |
stable to default
Diffstat (limited to 'src')
| -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 = |