We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fd644c5 commit cc50d8eCopy full SHA for cc50d8e
src/gm.erl
@@ -515,7 +515,7 @@ group_members(Server) ->
515
init([GroupName, Module, Args]) ->
516
{MegaSecs, Secs, MicroSecs} = now(),
517
random:seed(MegaSecs, Secs, MicroSecs),
518
- Self = {rabbit_guid:guid(), self()},
+ Self = make_member(self()),
519
gen_server2:cast(self(), join),
520
{ok, #state { self = Self,
521
left = {Self, undefined},
@@ -1241,6 +1241,8 @@ prepare_members_state(MembersState) ->
1241
build_members_state(MembersStateList) ->
1242
?DICT:from_list(MembersStateList).
1243
1244
+make_member(Pid) -> {rabbit_guid:guid(), Pid}.
1245
+
1246
get_pid({_Guid, Pid}) -> Pid.
1247
1248
get_pids(Ids) -> [Pid || {_Guid, Pid} <- Ids].
0 commit comments