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

chore(ft): stop hook chain when doing actual handling

This commit is contained in:
Ilya Averyanov 2023-08-23 12:13:13 +03:00
parent 39a48179ea
commit 4488e9e591
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_ft/src/emqx_ft.erl
View File

@ -166,7 +166,7 @@ on_channel_unregistered(ChannelPid) ->
on_client_timeout(_TRef, ?FT_EVENT({MRef, PacketId}), Acc) -> on_client_timeout(_TRef, ?FT_EVENT({MRef, PacketId}), Acc) ->
_ = erlang:demonitor(MRef, [flush]), _ = erlang:demonitor(MRef, [flush]),
_ = emqx_ft_async_reply:take_by_mref(MRef), _ = emqx_ft_async_reply:take_by_mref(MRef),
{ok, [?REPLY_OUTGOING(?PUBACK_PACKET(PacketId, ?RC_UNSPECIFIED_ERROR)) | Acc]}; {stop, [?REPLY_OUTGOING(?PUBACK_PACKET(PacketId, ?RC_UNSPECIFIED_ERROR)) | Acc]};
on_client_timeout(_TRef, _Event, Acc) -> on_client_timeout(_TRef, _Event, Acc) ->
{ok, Acc}. {ok, Acc}.
@ -174,7 +174,7 @@ on_process_down(MRef, _Pid, Reason, Acc) ->
case emqx_ft_async_reply:take_by_mref(MRef) of case emqx_ft_async_reply:take_by_mref(MRef) of
{ok, PacketId, TRef} -> {ok, PacketId, TRef} ->
_ = emqx_utils:cancel_timer(TRef), _ = emqx_utils:cancel_timer(TRef),
{ok, [?REPLY_OUTGOING(?PUBACK_PACKET(PacketId, reason_to_rc(Reason))) | Acc]}; {stop, [?REPLY_OUTGOING(?PUBACK_PACKET(PacketId, reason_to_rc(Reason))) | Acc]};
not_found -> not_found ->
{ok, Acc} {ok, Acc}
end. end.