diff options
author | Emile Joubert <emile@rabbitmq.com> | 2013-07-19 13:40:45 +0100 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2013-07-19 13:40:45 +0100 |
commit | f314d73b87ec497bf91c95abfdb545b189853361 (patch) | |
tree | f0d6aa5f46f4cbcaf18f24c4f32bdbb84df9a921 | |
parent | 5424a13ea86566789b3fb72096c9776cc37a1bd5 (diff) | |
download | rabbitmq-server-bug25671.tar.gz |
Don't roll over to a lower GM view version than we have ourselvesbug25671
-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]. |