diff --git a/apps/emqx_rule_engine/src/emqx_rule_registry.erl b/apps/emqx_rule_engine/src/emqx_rule_registry.erl index 1ef5406cd..fcbcb1e20 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_registry.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_registry.erl @@ -133,11 +133,11 @@ mnesia(copy) -> %% Copy rule table ok = ekka_mnesia:copy_table(?RULE_TAB, disc_copies), %% Copy rule action table - ok = ekka_mnesia:copy_table(?ACTION_TAB), + ok = ekka_mnesia:copy_table(?ACTION_TAB, ram_copies), %% Copy resource table ok = ekka_mnesia:copy_table(?RES_TAB, disc_copies), %% Copy resource type table - ok = ekka_mnesia:copy_table(?RES_TYPE_TAB). + ok = ekka_mnesia:copy_table(?RES_TYPE_TAB, ram_copies). dump() -> io:format("Rules: ~p~n" diff --git a/src/emqx_cm_registry.erl b/src/emqx_cm_registry.erl index 6609d70f4..f3b1518cb 100644 --- a/src/emqx_cm_registry.erl +++ b/src/emqx_cm_registry.erl @@ -108,7 +108,7 @@ init([]) -> {attributes, record_info(fields, channel)}, {storage_properties, [{ets, [{read_concurrency, true}, {write_concurrency, true}]}]}]), - ok = ekka_mnesia:copy_table(?TAB), + ok = ekka_mnesia:copy_table(?TAB, ram_copies), ok = ekka:monitor(membership), {ok, #{}}. diff --git a/src/emqx_router.erl b/src/emqx_router.erl index cc358758f..754124298 100644 --- a/src/emqx_router.erl +++ b/src/emqx_router.erl @@ -83,7 +83,7 @@ mnesia(boot) -> {storage_properties, [{ets, [{read_concurrency, true}, {write_concurrency, true}]}]}]); mnesia(copy) -> - ok = ekka_mnesia:copy_table(?ROUTE_TAB). + ok = ekka_mnesia:copy_table(?ROUTE_TAB, ram_copies). %%-------------------------------------------------------------------- %% Start a router diff --git a/src/emqx_router_helper.erl b/src/emqx_router_helper.erl index ba5cc5543..bff7e52cc 100644 --- a/src/emqx_router_helper.erl +++ b/src/emqx_router_helper.erl @@ -68,7 +68,7 @@ mnesia(boot) -> {storage_properties, [{ets, [{read_concurrency, true}]}]}]); mnesia(copy) -> - ok = ekka_mnesia:copy_table(?ROUTING_NODE). + ok = ekka_mnesia:copy_table(?ROUTING_NODE, ram_copies). %%-------------------------------------------------------------------- %% API diff --git a/src/emqx_shared_sub.erl b/src/emqx_shared_sub.erl index 17476199b..3add6dadc 100644 --- a/src/emqx_shared_sub.erl +++ b/src/emqx_shared_sub.erl @@ -84,7 +84,7 @@ mnesia(boot) -> {attributes, record_info(fields, emqx_shared_subscription)}]); mnesia(copy) -> - ok = ekka_mnesia:copy_table(?TAB). + ok = ekka_mnesia:copy_table(?TAB, ram_copies). %%-------------------------------------------------------------------- %% API diff --git a/src/emqx_trie.erl b/src/emqx_trie.erl index 4189c0270..d3a22e0b2 100644 --- a/src/emqx_trie.erl +++ b/src/emqx_trie.erl @@ -69,9 +69,9 @@ mnesia(boot) -> mnesia(copy) -> %% Copy trie table - ok = ekka_mnesia:copy_table(?TRIE_TAB), + ok = ekka_mnesia:copy_table(?TRIE_TAB, ram_copies), %% Copy trie_node table - ok = ekka_mnesia:copy_table(?TRIE_NODE_TAB). + ok = ekka_mnesia:copy_table(?TRIE_NODE_TAB, ram_copies). %%-------------------------------------------------------------------- %% Trie APIs