diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-03-06 22:54:36 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-03-06 22:54:36 +0300 |
| commit | 9a2a05c0e91907a56f20fb1f3c8535717852be4a (patch) | |
| tree | 5d8c0a62b136b578e0a8830f5f8a77a5a8321c1a | |
| parent | 1835d7227ca0f10957c518645889102c8ea393ef (diff) | |
| download | rabbitmq-server-git-9a2a05c0e91907a56f20fb1f3c8535717852be4a.tar.gz | |
Switch to rabbit_misc:is_process_alive/1
| -rw-r--r-- | src/rabbit_core_metrics_gc.erl | 19 |
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. |
