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

fix: TopicFilter may modified by `client.subscribe` hook

This commit is contained in:
JimMoen 2023-10-25 17:12:28 +08:00
parent 802a36c670
commit afec6fa2f6
No known key found for this signature in database
GPG Key ID: 87A520B4F76BA86D
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx/src/emqx_channel.erl
View File

@ -796,19 +796,19 @@ do_gen_reason_codes(Acc, [], []) ->
lists:reverse(Acc); lists:reverse(Acc);
do_gen_reason_codes( do_gen_reason_codes(
Acc, Acc,
[{_TF, ?RC_SUCCESS} | RestCheckedTF], [{_, ?RC_SUCCESS} | RestTF],
[{_TF, NRC} | RestTFWithNRC] [{_, NRC} | RestWithNRC]
) -> ) ->
%% will passing through `process_subscribe/2` %% will passing through `process_subscribe/2`
%% use NRC to override IintialRC %% use NRC to override IintialRC
do_gen_reason_codes([NRC | Acc], RestCheckedTF, RestTFWithNRC); do_gen_reason_codes([NRC | Acc], RestTF, RestWithNRC);
do_gen_reason_codes( do_gen_reason_codes(
Acc, Acc,
[{_TF, InitialRC} | RestChecked], [{_, InitialRC} | Rest],
RestTFWithNRC RestWithNRC
) -> ) ->
%% InitialRC is not `RC_SUCCESS`, use it. %% InitialRC is not `RC_SUCCESS`, use it.
do_gen_reason_codes([InitialRC | Acc], RestChecked, RestTFWithNRC). do_gen_reason_codes([InitialRC | Acc], Rest, RestWithNRC).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Process Unsubscribe %% Process Unsubscribe