Explorar el Código

feat(router): Mark CM_SHARD and ROUTE_SHARD as dirty

k32 hace 4 años
padre
commit
78c762479f
Se han modificado 2 ficheros con 2 adiciones y 0 borrados
  1. 1 0
      apps/emqx/src/emqx_cm_registry.erl
  2. 1 0
      apps/emqx/src/emqx_router.erl

+ 1 - 0
apps/emqx/src/emqx_cm_registry.erl

@@ -100,6 +100,7 @@ record(ClientId, ChanPid) ->
 %%--------------------------------------------------------------------
 
 init([]) ->
+    mria_config:set_dirty_shard(?CM_SHARD, true),
     ok = mria:create_table(?TAB, [
                 {type, bag},
                 {rlog_shard, ?CM_SHARD},

+ 1 - 0
apps/emqx/src/emqx_router.erl

@@ -73,6 +73,7 @@
 %%--------------------------------------------------------------------
 
 mnesia(boot) ->
+    mria_config:set_dirty_shard(?ROUTE_SHARD, true),
     ok = mria:create_table(?ROUTE_TAB, [
                 {type, bag},
                 {rlog_shard, ?ROUTE_SHARD},