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

chore(mnesia): explicitly specify the copy type for table

This commit is contained in:
JianBo He 2021-01-13 18:33:41 +08:00 committed by JianBo He
parent 76fc6225d3
commit f2190dd5b5
6 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_rule_engine/src/emqx_rule_registry.erl
View File

@ -133,11 +133,11 @@ mnesia(copy) ->
%% Copy rule table %% Copy rule table
ok = ekka_mnesia:copy_table(?RULE_TAB, disc_copies), ok = ekka_mnesia:copy_table(?RULE_TAB, disc_copies),
%% Copy rule action table %% Copy rule action table
ok = ekka_mnesia:copy_table(?ACTION_TAB), ok = ekka_mnesia:copy_table(?ACTION_TAB, ram_copies),
%% Copy resource table %% Copy resource table
ok = ekka_mnesia:copy_table(?RES_TAB, disc_copies), ok = ekka_mnesia:copy_table(?RES_TAB, disc_copies),
%% Copy resource type table %% Copy resource type table
ok = ekka_mnesia:copy_table(?RES_TYPE_TAB). ok = ekka_mnesia:copy_table(?RES_TYPE_TAB, ram_copies).
dump() -> dump() ->
io:format("Rules: ~p~n" io:format("Rules: ~p~n"

2
src/emqx_cm_registry.erl
View File

@ -108,7 +108,7 @@ init([]) ->
{attributes, record_info(fields, channel)}, {attributes, record_info(fields, channel)},
{storage_properties, [{ets, [{read_concurrency, true}, {storage_properties, [{ets, [{read_concurrency, true},
{write_concurrency, true}]}]}]), {write_concurrency, true}]}]}]),
ok = ekka_mnesia:copy_table(?TAB), ok = ekka_mnesia:copy_table(?TAB, ram_copies),
ok = ekka:monitor(membership), ok = ekka:monitor(membership),
{ok, #{}}. {ok, #{}}.

2
src/emqx_router.erl
View File

@ -83,7 +83,7 @@ mnesia(boot) ->
{storage_properties, [{ets, [{read_concurrency, true}, {storage_properties, [{ets, [{read_concurrency, true},
{write_concurrency, true}]}]}]); {write_concurrency, true}]}]}]);
mnesia(copy) -> mnesia(copy) ->
ok = ekka_mnesia:copy_table(?ROUTE_TAB). ok = ekka_mnesia:copy_table(?ROUTE_TAB, ram_copies).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Start a router %% Start a router

2
src/emqx_router_helper.erl
View File

@ -68,7 +68,7 @@ mnesia(boot) ->
{storage_properties, [{ets, [{read_concurrency, true}]}]}]); {storage_properties, [{ets, [{read_concurrency, true}]}]}]);
mnesia(copy) -> mnesia(copy) ->
ok = ekka_mnesia:copy_table(?ROUTING_NODE). ok = ekka_mnesia:copy_table(?ROUTING_NODE, ram_copies).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% API %% API

2
src/emqx_shared_sub.erl
View File

@ -84,7 +84,7 @@ mnesia(boot) ->
{attributes, record_info(fields, emqx_shared_subscription)}]); {attributes, record_info(fields, emqx_shared_subscription)}]);
mnesia(copy) -> mnesia(copy) ->
ok = ekka_mnesia:copy_table(?TAB). ok = ekka_mnesia:copy_table(?TAB, ram_copies).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% API %% API

4
src/emqx_trie.erl
View File

@ -69,9 +69,9 @@ mnesia(boot) ->
mnesia(copy) -> mnesia(copy) ->
%% Copy trie table %% Copy trie table
ok = ekka_mnesia:copy_table(?TRIE_TAB), ok = ekka_mnesia:copy_table(?TRIE_TAB, ram_copies),
%% Copy trie_node table %% Copy trie_node table
ok = ekka_mnesia:copy_table(?TRIE_NODE_TAB). ok = ekka_mnesia:copy_table(?TRIE_NODE_TAB, ram_copies).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Trie APIs %% Trie APIs