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

feat(emqx-sn): Add tables to the SN shard

This commit is contained in:
k32 2021-08-16 15:42:20 +02:00
parent af902df040
commit ca0fb214a7
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_gateway/src/mqttsn/emqx_sn_registry.erl
View File

@ -149,9 +149,11 @@ init([InstaId, PredefTopics]) ->
{ram_copies, [node()]}, {ram_copies, [node()]},
{record_name, emqx_sn_registry}, {record_name, emqx_sn_registry},
{attributes, record_info(fields, emqx_sn_registry)}, {attributes, record_info(fields, emqx_sn_registry)},
{storage_properties, [{ets, [{read_concurrency, true}]}]} {storage_properties, [{ets, [{read_concurrency, true}]}]},
{rlog_shard, ?SN_SHARD}
]), ]),
ok = ekka_mnesia:copy_table(Tab, ram_copies), ok = ekka_mnesia:copy_table(Tab, ram_copies),
ok = ekka_rlog:wait_for_shards([?SN_SHARD], infinity),
% FIXME: % FIXME:
%ok = ekka_rlog:wait_for_shards([?CM_SHARD], infinity), %ok = ekka_rlog:wait_for_shards([?CM_SHARD], infinity),
MaxPredefId = lists:foldl( MaxPredefId = lists:foldl(