yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(rule): fix rpc timeout extend the RPC timeout interval

This commit is contained in:
Turtle 2021-09-14 21:50:20 +08:00 committed by turtleDeng
parent 80421651d7
commit 9f843d618d
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_rule_engine/include/rule_engine.hrl
View File

@ -158,7 +158,7 @@
-define(CLUSTER_CALL(Func, Args), ?CLUSTER_CALL(Func, Args, ok)). -define(CLUSTER_CALL(Func, Args), ?CLUSTER_CALL(Func, Args, ok)).
-define(CLUSTER_CALL(Func, Args, ResParttern), -define(CLUSTER_CALL(Func, Args, ResParttern),
fun() -> case rpc:multicall(ekka_mnesia:running_nodes(), ?MODULE, Func, Args, 5000) of fun() -> case rpc:multicall(ekka_mnesia:running_nodes(), ?MODULE, Func, Args, 30000) of
{ResL, []} -> {ResL, []} ->
case lists:filter(fun(ResParttern) -> false; (_) -> true end, ResL) of case lists:filter(fun(ResParttern) -> false; (_) -> true end, ResL) of
[] -> ResL; [] -> ResL;

4
apps/emqx_rule_engine/src/emqx_rule_engine.appup.src
View File

@ -22,9 +22,11 @@
{"4.3.3", {"4.3.3",
[ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []}
, {load_module, emqx_rule_actions, brutal_purge, soft_purge, []} , {load_module, emqx_rule_actions, brutal_purge, soft_purge, []}
, {load_module, emqx_rule_registry, brutal_purge, soft_purge, []}
]}, ]},
{"4.3.4", {"4.3.4",
[ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []}
, {load_module, emqx_rule_registry, brutal_purge, soft_purge, []}
]}, ]},
{<<".*">>, []} {<<".*">>, []}
], ],
@ -51,9 +53,11 @@
{"4.3.3", {"4.3.3",
[ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []}
, {load_module, emqx_rule_actions, brutal_purge, soft_purge, []} , {load_module, emqx_rule_actions, brutal_purge, soft_purge, []}
, {load_module, emqx_rule_registry, brutal_purge, soft_purge, []}
]}, ]},
{"4.3.4", {"4.3.4",
[ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []}
, {load_module, emqx_rule_registry, brutal_purge, soft_purge, []}
]}, ]},
{<<".*">>, []} {<<".*">>, []}
] ]