summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2017-03-06 22:54:36 +0300
committerMichael Klishin <michael@clojurewerkz.org>2017-03-22 23:38:00 +0300
commit407472039f08f8e5ffe8316cead1ae13b6e6a805 (patch)
tree9ee7ab5ecd17c289add84a7a2c494307f0f453d7
parent22a636849f541a7080a779bedaf8551f95d87b2d (diff)
downloadrabbitmq-server-git-407472039f08f8e5ffe8316cead1ae13b6e6a805.tar.gz
Switch to rabbit_misc:is_process_alive/1
-rw-r--r--src/rabbit_core_metrics_gc.erl19
1 files changed, 2 insertions, 17 deletions
diff --git a/src/rabbit_core_metrics_gc.erl b/src/rabbit_core_metrics_gc.erl
index c2f9b1c271..99a8058bde 100644
--- a/src/rabbit_core_metrics_gc.erl
+++ b/src/rabbit_core_metrics_gc.erl
@@ -103,7 +103,7 @@ gc_process(Table) ->
end, none, Table).
gc_process(Pid, Table, Key) ->
- case is_process_alive_in_cluster(Pid) of
+ case rabbit_misc:is_process_alive(Pid) of
true ->
none;
false ->
@@ -151,7 +151,7 @@ gc_process_and_entity(Table, GbSet) ->
end, none, Table).
gc_process_and_entity(Id, Pid, Table, Key, GbSet) ->
- case is_process_alive_in_cluster(Pid) orelse gb_sets:is_member(Id, GbSet) of
+ case rabbit_misc:is_process_alive(Pid) orelse gb_sets:is_member(Id, GbSet) of
true ->
none;
false ->
@@ -166,18 +166,3 @@ gc_process_and_entities(Table, QueueGbSet, ExchangeGbSet) ->
gc_entity(Q, Table, Key, QueueGbSet),
gc_entity(X, Table, Key, ExchangeGbSet)
end, none, Table).
-
-is_process_alive_in_cluster(Pid) ->
- Local = node(),
- case node(Pid) of
- Local ->
- is_process_alive(Pid);
- Remote ->
- case rabbit_misc:rpc_call(Remote, erlang, is_process_alive, [Pid]) of
- Bool when is_boolean(Bool) ->
- Bool;
- {badrpc, _} ->
- %% If the node is unreachable, the process might be dead
- false
- end
- end.