From 94a596556095be2dd588035a3f81ef005dd97126 Mon Sep 17 00:00:00 2001 From: Shawn <506895667@qq.com> Date: Thu, 30 Dec 2021 23:46:50 +0800 Subject: [PATCH] fix(rule): dead lock when update configs for rules --- apps/emqx_machine/test/emqx_machine_SUITE.erl | 2 +- apps/emqx_rule_engine/src/emqx_rule_engine.erl | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqx_machine/test/emqx_machine_SUITE.erl b/apps/emqx_machine/test/emqx_machine_SUITE.erl index 03d9e6ba9..a760d2f5f 100644 --- a/apps/emqx_machine/test/emqx_machine_SUITE.erl +++ b/apps/emqx_machine/test/emqx_machine_SUITE.erl @@ -43,7 +43,7 @@ init_per_suite(Config) -> %% application:unload(emqx_authz), - emqx_common_test_helpers:start_apps([]), + emqx_common_test_helpers:start_apps([emqx_conf]), Config. end_per_suite(_Config) -> diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl index 5316ca5ef..6a579cbb0 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl @@ -187,11 +187,11 @@ init([]) -> {ok, #{}}. handle_call({insert_rule, Rule}, _From, State) -> - _ = emqx_plugin_libs_rule:cluster_call(?MODULE, do_insert_rule, [Rule]), + do_insert_rule(Rule), {reply, ok, State}; handle_call({delete_rule, Rule}, _From, State) -> - _ = emqx_plugin_libs_rule:cluster_call(?MODULE, do_delete_rule, [Rule]), + do_delete_rule(Rule), {reply, ok, State}; handle_call(Req, _From, State) ->