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

Merge pull request #12027 from ieQu1/dev/ds-meta-persist-shard 

fix(ds): Persist shard table
This commit is contained in:
ieQu1 2023-11-28 14:33:57 +01:00 committed by GitHub
parent 26e59f9508 05e47254e2
commit 8a065ba6d0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqx_durable_storage/src/emqx_ds_replication_layer_meta.erl
View File

@ -192,9 +192,9 @@ sites() ->
{ok, node()} | {error, no_leader_for_shard}. {ok, node()} | {error, no_leader_for_shard}.
shard_leader(DB, Shard) -> shard_leader(DB, Shard) ->
case mnesia:dirty_read(?SHARD_TAB, {DB, Shard}) of case mnesia:dirty_read(?SHARD_TAB, {DB, Shard}) of
[#?SHARD_TAB{leader = Leader}] -> [#?SHARD_TAB{leader = Leader}] when Leader =/= undefined ->
{ok, Leader}; {ok, Leader};
[] -> _ ->
{error, no_leader_for_shard} {error, no_leader_for_shard}
end. end.
@ -314,7 +314,7 @@ ensure_tables() ->
{rlog_shard, ?SHARD}, {rlog_shard, ?SHARD},
{majority, Majority}, {majority, Majority},
{type, ordered_set}, {type, ordered_set},
{storage, ram_copies}, {storage, disc_copies},
{record_name, ?SHARD_TAB}, {record_name, ?SHARD_TAB},
{attributes, record_info(fields, ?SHARD_TAB)} {attributes, record_info(fields, ?SHARD_TAB)}
]), ]),