diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2023-03-21 16:51:29 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-03-21 16:51:29 +0100 |
| commit | b652e8c886b63d9d48ca0633f4dfda78bdc1a54a (patch) | |
| tree | 02679a60a4736a330683e38b2d69d3a175bdb740 | |
| parent | 7fb32b6ae0aac1e5346ee51f197f381b01a9284a (diff) | |
| parent | 22516aad2f32488910a4410356f67847c243c9fe (diff) | |
| download | rabbitmq-server-git-b652e8c886b63d9d48ca0633f4dfda78bdc1a54a.tar.gz | |
Merge pull request #7686 from rabbitmq/call-rabbit_mnesia-for-partition-handling-specific-code
rabbit_node_monitor: Use `rabbit_mnesia` in partition handling-specific code
| -rw-r--r-- | deps/rabbit/src/rabbit_node_monitor.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_node_monitor.erl b/deps/rabbit/src/rabbit_node_monitor.erl index d469830c9b..dff0e97509 100644 --- a/deps/rabbit/src/rabbit_node_monitor.erl +++ b/deps/rabbit/src/rabbit_node_monitor.erl @@ -470,7 +470,7 @@ handle_cast({announce_guid, Node, GUID}, State = #state{node_guids = GUIDs}) -> handle_cast({check_partial_partition, Node, Rep, NodeGUID, MyGUID, RepGUID}, State = #state{guid = MyGUID, node_guids = GUIDs}) -> - case lists:member(Node, rabbit_nodes:list_reachable()) andalso + case lists:member(Node, rabbit_mnesia:cluster_nodes(running)) andalso maps:find(Node, GUIDs) =:= {ok, NodeGUID} of true -> spawn_link( %%[1] fun () -> @@ -623,7 +623,7 @@ handle_info({nodedown, Node, Info}, State = #state{guid = MyGUID, Node, node(), DownGUID, CheckGUID, MyGUID}) end, _ = case maps:find(Node, GUIDs) of - {ok, DownGUID} -> Alive = rabbit_nodes:list_reachable() + {ok, DownGUID} -> Alive = rabbit_mnesia:cluster_nodes(running) -- [node(), Node], [case maps:find(N, GUIDs) of {ok, CheckGUID} -> Check(N, CheckGUID, DownGUID); |