From 65ccf7ce42b261c617bab27d3b67403e87674702 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Mon, 5 Jul 2021 14:02:23 +0300 Subject: [PATCH] Mirrored supervisor: make it easier to keep track of group membership changes in the logs. Referenes #3148. --- deps/rabbit_common/src/mirrored_supervisor.erl | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/deps/rabbit_common/src/mirrored_supervisor.erl b/deps/rabbit_common/src/mirrored_supervisor.erl index 5b92c9ab48a8..36b8bbf33a4d 100644 --- a/deps/rabbit_common/src/mirrored_supervisor.erl +++ b/deps/rabbit_common/src/mirrored_supervisor.erl @@ -278,7 +278,10 @@ handle_call({init, Overall}, _From, initial_childspecs = ChildSpecs}) -> process_flag(trap_exit, true), ok = pg:join(Group, Overall), + rabbit_log:debug("Mirrored supervisor: initializing, joined group ~p", [Group]), Rest = pg:get_members(Group) -- [Overall], + Nodes = [node(M) || M <- Rest], + rabbit_log:debug("Mirrored supervisor: known group ~p members: ~p on nodes ~p", [Group, Rest, Nodes]), case Rest of [] -> TxFun(fun() -> delete_all(Group) end); _ -> ok @@ -420,6 +423,7 @@ delete(Group, Id) -> ok = mnesia:delete({?TABLE, {Group, Id}}). start(Delegate, ChildSpec) -> + rabbit_log:debug("Mirrored supervisor: asked to start with delegate: ~p, child spec: ~p", [Delegate, ChildSpec]), apply(?SUPERVISOR, start_child, [Delegate, ChildSpec]). stop(Group, TxFun, Delegate, Id) ->