summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2011-12-09 16:17:06 +0000
committerEmile Joubert <emile@rabbitmq.com>2011-12-09 16:17:06 +0000
commit93dc0426c2677e2456378100afd4d62a6b0b78e4 (patch)
treecff4022f909f5da7845638c0ecefa5c4d73f0fe9
parent8042f5f31ada2fdbbbcd8cd0d63db413a6fea200 (diff)
downloadrabbitmq-server-93dc0426c2677e2456378100afd4d62a6b0b78e4.tar.gz
Separate member construction function
-rw-r--r--src/gm.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 17aca830..d1bd80b9 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].