diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-08-03 15:52:38 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-08-03 15:52:38 +0200 |
| commit | e587e9a8ef328a1d9d74150ae6c7f86c08d15e65 (patch) | |
| tree | 68c2a185b360d67eaf99f774969a3e43fe7a0146 | |
| parent | 8687e73c7e7e3f89e267749d39077bdd4ed8eef5 (diff) | |
| download | rabbitmq-server-git-e587e9a8ef328a1d9d74150ae6c7f86c08d15e65.tar.gz | |
Make process liveness check remote if necessary
References #5412
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_manager.erl | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl index 15db2a05a2..08aca486aa 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl @@ -350,7 +350,7 @@ handle_call({lookup_member, VirtualHost, Stream}, _From, State) -> false; ({P, _Role}) when is_pid(P) -> - is_process_alive(P); + process_alive(P); (_) -> false end, @@ -875,7 +875,12 @@ process_alive(Pid) -> CurrentNode -> is_process_alive(Pid); OtherNode -> - rpc:call(OtherNode, erlang, is_process_alive, [Pid], 10000) + case rpc:call(OtherNode, erlang, is_process_alive, [Pid], 10000) of + B when is_boolean(B) -> + B; + _ -> + false + end end. is_stream_queue(Q) -> |