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 | acadfd306b8f369fa26dca615dd224c4c04aae9c (patch) | |
tree | 5528748e8d4d56cd8be5c7798a244614fdc15da6 | |
parent | 81b86fc6f048e0f9d45e56f2a615e2700469c323 (diff) | |
parent | adbaa72127d98a20df743e0f25ea34b3e7f1ee3e (diff) | |
download | rabbitmq-server-acadfd306b8f369fa26dca615dd224c4c04aae9c.tar.gz |
Merge bug26172
-rw-r--r-- | src/gm.erl | 3 |
1 files changed, 2 insertions, 1 deletions
@@ -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 = |