From 2deed75c26f843c0fa593c481cd860ba7b3f91aa Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Sun, 11 Jan 2015 00:34:27 +0800 Subject: [PATCH] dump keepalive --- apps/emqtt/src/emqtt_client.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqtt/src/emqtt_client.erl b/apps/emqtt/src/emqtt_client.erl index eccfa8f3d..390f66926 100644 --- a/apps/emqtt/src/emqtt_client.erl +++ b/apps/emqtt/src/emqtt_client.erl @@ -115,14 +115,14 @@ handle_info({inet_reply, _Sock, {error, Reason}}, State) -> {noreply, State}; handle_info({keepalive, start, TimeoutSec}, State = #state{socket = Socket}) -> - lager:info("~s keepalive started: ~p", [State#state.peer_name, TimeoutSec]), + lager:info("Client: ~s: Start KeepAlive with ~p seconds", [State#state.peer_name, TimeoutSec]), KeepAlive = emqtt_keepalive:new(Socket, TimeoutSec, {keepalive, timeout}), {noreply, State#state{ keepalive = KeepAlive }}; handle_info({keepalive, timeout}, State = #state { keepalive = KeepAlive }) -> case emqtt_keepalive:resume(KeepAlive) of timeout -> - lager:info("~s keepalive timeout!", [State#state.peer_name]), + lager:info("Client ~s: Keepalive Timeout!", [State#state.peer_name]), {stop, normal, State}; {resumed, KeepAlive1} -> lager:info("~s keepalive resumed.", [State#state.peer_name]),