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

fix(sessds): try to ensure iterators are closed on destroy

This commit is contained in:
Andrew Mayorov 2023-09-20 12:56:30 +04:00
parent 21e82b9534
commit 3945f08f8f
No known key found for this signature in database
GPG Key ID: 2837C62ACFBFED5D
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqx/src/emqx_persistent_session_ds.erl
View File

@ -132,8 +132,12 @@ open_session(ClientID, Conf) ->
-spec destroy(session() | clientinfo()) -> ok. -spec destroy(session() | clientinfo()) -> ok.
destroy(#{id := ClientID}) -> destroy(#{id := ClientID}) ->
emqx_ds:session_drop(ClientID); destroy_session(ClientID);
destroy(#{clientid := ClientID}) -> destroy(#{clientid := ClientID}) ->
destroy_session(ClientID).
destroy_session(ClientID) ->
_ = ensure_all_iterators_closed(ClientID),
emqx_ds:session_drop(ClientID). emqx_ds:session_drop(ClientID).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------