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

fix(sessds): Use mria:async_dirty instead of transaction

This commit is contained in:
ieQu1 2024-01-13 05:07:16 +01:00
parent f5b9bd30aa
commit ebe2339810
1 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
apps/emqx/src/emqx_persistent_session_ds_state.erl
View File

@ -550,17 +550,23 @@ kv_pmap_delete(Table, SessionId, Key) ->
%% %%
transaction(Fun) -> transaction(Fun) ->
case mnesia:is_transaction() of mria:async_dirty(?DS_MRIA_SHARD, Fun).
true ->
Fun();
false ->
{atomic, Res} = mria:transaction(?DS_MRIA_SHARD, Fun),
Res
end.
ro_transaction(Fun) -> ro_transaction(Fun) ->
{atomic, Res} = mria:ro_transaction(?DS_MRIA_SHARD, Fun), mria:async_dirty(?DS_MRIA_SHARD, Fun).
Res.
%% transaction(Fun) ->
%% case mnesia:is_transaction() of
%% true ->
%% Fun();
%% false ->
%% {atomic, Res} = mria:transaction(?DS_MRIA_SHARD, Fun),
%% Res
%% end.
%% ro_transaction(Fun) ->
%% {atomic, Res} = mria:ro_transaction(?DS_MRIA_SHARD, Fun),
%% Res.
-compile({inline, check_sequence/1}). -compile({inline, check_sequence/1}).