summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--deps/rabbit/src/rabbit_node_monitor.erl11
1 files changed, 7 insertions, 4 deletions
diff --git a/deps/rabbit/src/rabbit_node_monitor.erl b/deps/rabbit/src/rabbit_node_monitor.erl
index 4de4e4f1ca..bc2bc64e2e 100644
--- a/deps/rabbit/src/rabbit_node_monitor.erl
+++ b/deps/rabbit/src/rabbit_node_monitor.erl
@@ -366,7 +366,7 @@ init([]) ->
{ok, ensure_keepalive_timer(#state{monitors = Monitors,
subscribers = pmon:new(),
partitions = [],
- guid = rabbit_guid:gen(),
+ guid = erlang:system_info(creation),
node_guids = maps:new(),
autoheal = rabbit_autoheal:init()})}.
@@ -435,15 +435,18 @@ handle_cast({check_partial_partition, Node, Rep, NodeGUID, MyGUID, RepGUID},
maps:find(Node, GUIDs) =:= {ok, NodeGUID} of
true -> spawn_link( %%[1]
fun () ->
- case rpc:call(Node, rabbit, is_running, []) of
+ case rpc:call(Node, erlang, system_info, [creation]) of
{badrpc, _} -> ok;
- _ ->
+ NodeGUID ->
rabbit_log:warning("Received a 'DOWN' message"
" from ~p but still can"
" communicate with it ",
[Node]),
cast(Rep, {partial_partition,
- Node, node(), RepGUID})
+ Node, node(), RepGUID});
+ _ ->
+ rabbit_log:warning("Looks like ~p has been restarted.", [Node]),
+ ok
end
end);
false -> ok