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

chore: close keepalive timeout channel

This commit is contained in:
JianBo He 2022-08-09 11:04:51 +08:00
parent 7d3ea85ef3
commit 8186e9e47a
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_exproto/src/emqx_exproto_channel.erl
View File

@ -275,7 +275,9 @@ handle_timeout(_TRef, {keepalive, StatVal},
{error, timeout} -> {error, timeout} ->
Req = #{type => 'KEEPALIVE'}, Req = #{type => 'KEEPALIVE'},
NChannel = clean_timer(alive_timer, Channel), NChannel = clean_timer(alive_timer, Channel),
{ok, try_dispatch(on_timer_timeout, wrap(Req), NChannel)} %% close connection if keepalive timeout
Replies = [{event, disconnected}, {close, normal}],
{ok, Replies, try_dispatch(on_timer_timeout, wrap(Req), NChannel)}
end; end;
handle_timeout(_TRef, force_close, Channel = #channel{closed_reason = Reason}) -> handle_timeout(_TRef, force_close, Channel = #channel{closed_reason = Reason}) ->