From 258dd100f503e388fc40ce87898a1cc94c732fc8 Mon Sep 17 00:00:00 2001 From: JianBo He Date: Tue, 13 Jul 2021 11:00:11 +0800 Subject: [PATCH] fix(cm): add a timeout to rpc_call function An infinite wait will leave the client process waiting for a return and cause the client to go to a dead state --- src/emqx_cm.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqx_cm.erl b/src/emqx_cm.erl index 6eb375aba..61982f569 100644 --- a/src/emqx_cm.erl +++ b/src/emqx_cm.erl @@ -376,7 +376,7 @@ lookup_channels(local, ClientId) -> %% @private rpc_call(Node, Fun, Args) -> - case rpc:call(Node, ?MODULE, Fun, Args) of + case rpc:call(Node, ?MODULE, Fun, Args, 2 * ?T_TAKEOVER) of {badrpc, Reason} -> error(Reason); Res -> Res end.