diff options
author | Emile Joubert <emile@rabbitmq.com> | 2011-12-09 16:17:06 +0000 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2011-12-09 16:17:06 +0000 |
commit | 93dc0426c2677e2456378100afd4d62a6b0b78e4 (patch) | |
tree | cff4022f909f5da7845638c0ecefa5c4d73f0fe9 | |
parent | 8042f5f31ada2fdbbbcd8cd0d63db413a6fea200 (diff) | |
download | rabbitmq-server-93dc0426c2677e2456378100afd4d62a6b0b78e4.tar.gz |
Separate member construction function
-rw-r--r-- | src/gm.erl | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -515,7 +515,7 @@ group_members(Server) -> init([GroupName, Module, Args]) -> {MegaSecs, Secs, MicroSecs} = now(), random:seed(MegaSecs, Secs, MicroSecs), - Self = {rabbit_guid:guid(), self()}, + Self = make_member(self()), gen_server2:cast(self(), join), {ok, #state { self = Self, left = {Self, undefined}, @@ -1241,6 +1241,8 @@ prepare_members_state(MembersState) -> build_members_state(MembersStateList) -> ?DICT:from_list(MembersStateList). +make_member(Pid) -> {rabbit_guid:guid(), Pid}. + get_pid({_Guid, Pid}) -> Pid. get_pids(Ids) -> [Pid || {_Guid, Pid} <- Ids]. |