Browse Source

perf(mnesia): unify the copy types of all nodes

JianBo He 5 năm trước cách đây
mục cha
commit
2a029b71c9

+ 1 - 1
apps/emqx_dashboard/src/emqx_dashboard_admin.erl

@@ -65,7 +65,7 @@ mnesia(boot) ->
                 {storage_properties, [{ets, [{read_concurrency, true},
                                              {write_concurrency, true}]}]}]);
 mnesia(copy) ->
-    ok = ekka_mnesia:copy_table(mqtt_admin).
+    ok = ekka_mnesia:copy_table(mqtt_admin, disc_copies).
 
 %%--------------------------------------------------------------------
 %% API

+ 1 - 1
apps/emqx_retainer/src/emqx_retainer.erl

@@ -138,7 +138,7 @@ init([Env]) ->
                 {record_name, retained},
                 {attributes, record_info(fields, retained)},
                 {storage_properties, StoreProps}]),
-    ok = ekka_mnesia:copy_table(?TAB),
+    ok = ekka_mnesia:copy_table(?TAB, Copies),
     case mnesia:table_info(?TAB, storage_type) of
         Copies -> ok;
         _Other ->

+ 2 - 2
apps/emqx_rule_engine/src/emqx_rule_registry.erl

@@ -131,11 +131,11 @@ mnesia(boot) ->
 
 mnesia(copy) ->
     %% Copy rule table
-    ok = ekka_mnesia:copy_table(?RULE_TAB),
+    ok = ekka_mnesia:copy_table(?RULE_TAB, disc_copies),
     %% Copy rule action table
     ok = ekka_mnesia:copy_table(?ACTION_TAB),
     %% Copy resource table
-    ok = ekka_mnesia:copy_table(?RES_TAB),
+    ok = ekka_mnesia:copy_table(?RES_TAB, disc_copies),
     %% Copy resource type table
     ok = ekka_mnesia:copy_table(?RES_TYPE_TAB).
 

+ 2 - 2
src/emqx_alarm.erl

@@ -112,8 +112,8 @@ mnesia(boot) ->
               {record_name, deactivated_alarm},
               {attributes, record_info(fields, deactivated_alarm)}]);
 mnesia(copy) ->
-    ok = ekka_mnesia:copy_table(?ACTIVATED_ALARM),
-    ok = ekka_mnesia:copy_table(?DEACTIVATED_ALARM).
+    ok = ekka_mnesia:copy_table(?ACTIVATED_ALARM, disc_copies),
+    ok = ekka_mnesia:copy_table(?DEACTIVATED_ALARM, disc_copies).
 
 %%--------------------------------------------------------------------
 %% API

+ 1 - 1
src/emqx_banned.erl

@@ -62,7 +62,7 @@ mnesia(boot) ->
                 {storage_properties, [{ets, [{read_concurrency, true}]}]}]);
 
 mnesia(copy) ->
-    ok = ekka_mnesia:copy_table(?BANNED_TAB).
+    ok = ekka_mnesia:copy_table(?BANNED_TAB, disc_copies).
 
 %% @doc Start the banned server.
 -spec(start_link() -> startlink_ret()).