Skip to content

Commit aa89617

Browse files
author
Alexandru Scvortov
committed
refactor
The sets thing is probably slower, but it isn't run that often.
1 parent 0222895 commit aa89617

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

src/rabbit_mnesia.erl

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -772,8 +772,9 @@ on_node_down(Node) ->
772772
end.
773773

774774
is_only_disc_node(Node, _MnesiaRunning = true) ->
775-
OfflineDiscNodes = nodes_of_type(disc_copies) -- running_clustered_nodes(),
776-
[Node] =:= nodes_of_type(disc_copies) -- OfflineDiscNodes;
775+
RunningSet = sets:from_list(running_clustered_nodes()),
776+
DiscSet = sets:from_list(nodes_of_type(disc_copies)),
777+
[Node] =:= sets:to_list(sets:intersection(RunningSet, DiscSet));
777778
is_only_disc_node(Node, false) ->
778779
start_mnesia(),
779780
Res = is_only_disc_node(Node, true),

src/rabbit_node_monitor.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ handle_call(_Request, _From, State) ->
6767

6868
handle_cast({rabbit_running_on, Node}, State) ->
6969
rabbit_log:info("rabbit on ~p up~n", [Node]),
70+
erlang:monitor(process, {rabbit, Node}),
7071
ok = handle_live_rabbit(Node),
7172
{noreply, State};
7273
handle_cast(_Msg, State) ->
@@ -97,6 +98,5 @@ handle_dead_rabbit(Node) ->
9798
ok = rabbit_mnesia:on_node_down(Node).
9899

99100
handle_live_rabbit(Node) ->
100-
erlang:monitor(process, {rabbit, Node}),
101101
ok = rabbit_alarm:on_node_up(Node),
102102
ok = rabbit_mnesia:on_node_up(Node).

0 commit comments

Comments
 (0)