diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2013-07-22 14:12:28 +0100 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2013-07-22 14:12:28 +0100 |
commit | b5c1ad8e30b663a73ce2e9945f9c367a2c4b1782 (patch) | |
tree | f0d6aa5f46f4cbcaf18f24c4f32bdbb84df9a921 | |
parent | 5424a13ea86566789b3fb72096c9776cc37a1bd5 (diff) | |
parent | f314d73b87ec497bf91c95abfdb545b189853361 (diff) | |
download | rabbitmq-server-b5c1ad8e30b663a73ce2e9945f9c367a2c4b1782.tar.gz |
Merge bug 25671
-rw-r--r-- | src/gm.erl | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -1053,7 +1053,7 @@ prune_or_create_group(Self, GroupName, TxnFun) -> fun () -> GroupNew = #gm_group { name = GroupName, members = [Self], - version = ?VERSION_START }, + version = get_version(Self) }, case mnesia:read({?GROUP_TABLE, GroupName}) of [] -> mnesia:write(GroupNew), @@ -1294,6 +1294,8 @@ remove_erased_members(MembersState, View) -> MembersState1) end, blank_member_state(), all_known_members(View)). +get_version({Version, _Pid}) -> Version. + get_pid({_Version, Pid}) -> Pid. get_pids(Ids) -> [Pid || {_Version, Pid} <- Ids]. |