From 4488e9e591592a27dd95797ba43497d0cf2d5b12 Mon Sep 17 00:00:00 2001 From: Ilya Averyanov Date: Wed, 23 Aug 2023 12:13:13 +0300 Subject: [PATCH] chore(ft): stop hook chain when doing actual handling --- apps/emqx_ft/src/emqx_ft.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqx_ft/src/emqx_ft.erl b/apps/emqx_ft/src/emqx_ft.erl index 6a98c51f0..41020e76f 100644 --- a/apps/emqx_ft/src/emqx_ft.erl +++ b/apps/emqx_ft/src/emqx_ft.erl @@ -166,7 +166,7 @@ on_channel_unregistered(ChannelPid) -> on_client_timeout(_TRef, ?FT_EVENT({MRef, PacketId}), Acc) -> _ = erlang:demonitor(MRef, [flush]), _ = 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) -> {ok, Acc}. @@ -174,7 +174,7 @@ on_process_down(MRef, _Pid, Reason, Acc) -> case emqx_ft_async_reply:take_by_mref(MRef) of {ok, PacketId, 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 -> {ok, Acc} end.