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 | cc50d8ebff3e74965674330aff0e83df0f2076f4 (patch) | |
| tree | cff4022f909f5da7845638c0ecefa5c4d73f0fe9 | |
| parent | fd644c5abe649c7b89d57fdd3387643cbd953964 (diff) | |
| download | rabbitmq-server-git-cc50d8ebff3e74965674330aff0e83df0f2076f4.tar.gz | |
Separate member construction function
| -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 17aca83032..d1bd80b907 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -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]. |