diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-05-13 15:13:43 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-05-13 15:13:43 +0100 |
| commit | e7b8269891eadfde6e94def99572d2f26afc4990 (patch) | |
| tree | 5528748e8d4d56cd8be5c7798a244614fdc15da6 | |
| parent | 30429a73e4ab47ed32203290d46fb2e2ce4fa4ba (diff) | |
| parent | 194b3ea47e3c9d2c485fee583f9ac7f19710ae6c (diff) | |
| download | rabbitmq-server-git-e7b8269891eadfde6e94def99572d2f26afc4990.tar.gz | |
Merge bug26172
| -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 = |