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 | 57dfe7ff58313476d5b786f4bde3e0e3ab4b9fc3 (patch) | |
| tree | f0d6aa5f46f4cbcaf18f24c4f32bdbb84df9a921 /src | |
| parent | 5319f96acdc71838d89bd763f369697aed8ed50b (diff) | |
| parent | 1ecba3019d48b1d9dd51bf65086c1a62662afce4 (diff) | |
| download | rabbitmq-server-git-57dfe7ff58313476d5b786f4bde3e0e3ab4b9fc3.tar.gz | |
Merge bug 25671
Diffstat (limited to 'src')
| -rw-r--r-- | src/gm.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl index 3f0909e865..28ebfd4767 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -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]. |