You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by ch...@apache.org on 2023/12/14 20:25:13 UTC
(couchdb) 01/01: Error on unexpected rexi_call messages
This is an automated email from the ASF dual-hosted git repository.
chewbranca pushed a commit to branch fix-rexi-mon-links
in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit 732cc757779d0340d65faa32b0a18ea6cfc63951
Author: Russell Branca <ch...@apache.org>
AuthorDate: Thu Dec 14 12:25:00 2023 -0800
Error on unexpected rexi_call messages
---
src/mem3/src/mem3_rpc.erl | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/src/mem3/src/mem3_rpc.erl b/src/mem3/src/mem3_rpc.erl
index 60c24e1d4..963e3c188 100644
--- a/src/mem3/src/mem3_rpc.erl
+++ b/src/mem3/src/mem3_rpc.erl
@@ -377,6 +377,7 @@ rexi_call(Node, MFA) ->
rexi_call(Node, MFA, Timeout) ->
Mon = rexi_monitor:start([rexi_utils:server_pid(Node)]),
Ref = rexi:cast(Node, self(), MFA, [sync]),
+ io:format("REXI_CALL MON_REF: {~p, ~p}~n", [Mon, Ref]),
try
receive
{Ref, {ok, Reply}} ->
@@ -384,7 +385,9 @@ rexi_call(Node, MFA, Timeout) ->
{Ref, Error} ->
erlang:error(Error);
{rexi_DOWN, Mon, _, Reason} ->
- erlang:error({rexi_DOWN, {Node, Reason}})
+ erlang:error({rexi_DOWN, {Node, Reason}});
+ Other ->
+ {error, {unexpected_msg, Other}}
after Timeout ->
erlang:error(timeout)
end