From f33217c0491df404c33248a7e316d9fcdad8ac5e Mon Sep 17 00:00:00 2001 From: turtled Date: Tue, 31 Dec 2019 09:06:58 +0800 Subject: [PATCH] Fix unexpected timeout --- src/emqx_channel.erl | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/emqx_channel.erl b/src/emqx_channel.erl index 2dec4d98a..1be58cdb4 100644 --- a/src/emqx_channel.erl +++ b/src/emqx_channel.erl @@ -786,6 +786,9 @@ handle_info(Info, Channel) -> -> {ok, channel()} | {ok, replies(), channel()} | {shutdown, Reason :: term(), channel()}). +handle_timeout(_TRef, {keepalive, _StatVal}, + Channel = #channel{keepalive = undefined}) -> + {ok, Channel}; handle_timeout(_TRef, {keepalive, StatVal}, Channel = #channel{keepalive = Keepalive}) -> case emqx_keepalive:check(StatVal, Keepalive) of