root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Don't get confused due to changing our own scratch!

This commit is contained in:
Simon MacMullen 2012-05-17 17:55:12 +01:00
parent d972b8f282
commit 20d8d6c0a0
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
deps/rabbitmq_federation/src/rabbit_federation_link_sup_sup.erl vendored
View File

@ -31,10 +31,10 @@ start_link() ->
mirrored_supervisor:start_link({local, ?SUPERVISOR}, mirrored_supervisor:start_link({local, ?SUPERVISOR},
?SUPERVISOR, ?MODULE, []). ?SUPERVISOR, ?MODULE, []).
start_child(Id, Args) -> start_child(X, Args) ->
{ok, _Pid} = mirrored_supervisor:start_child( {ok, _Pid} = mirrored_supervisor:start_child(
?SUPERVISOR, ?SUPERVISOR,
{Id, {rabbit_federation_link_sup, start_link, [Args]}, {id(X), {rabbit_federation_link_sup, start_link, [Args]},
transient, ?MAX_WAIT, supervisor, transient, ?MAX_WAIT, supervisor,
[rabbit_federation_link_sup]}). [rabbit_federation_link_sup]}).
@ -43,11 +43,14 @@ adjust(Reason) ->
{Id, Pid, _, _} <- mirrored_supervisor:which_children(?SUPERVISOR)], {Id, Pid, _, _} <- mirrored_supervisor:which_children(?SUPERVISOR)],
ok. ok.
stop_child(Id) -> stop_child(X) ->
ok = mirrored_supervisor:terminate_child(?SUPERVISOR, Id), ok = mirrored_supervisor:terminate_child(?SUPERVISOR, id(X)),
ok = mirrored_supervisor:delete_child(?SUPERVISOR, Id). ok = mirrored_supervisor:delete_child(?SUPERVISOR, id(X)).
%%---------------------------------------------------------------------------- %%----------------------------------------------------------------------------
init([]) -> init([]) ->
{ok, {{one_for_one, 3, 10}, []}}. {ok, {{one_for_one, 3, 10}, []}}.
id(X) ->
X#exchange{scratches = undefined}.