From 3e3dfe3fa23f09d2624b2b3d2b9d4191998ba0c5 Mon Sep 17 00:00:00 2001 From: erylee Date: Tue, 17 Sep 2013 11:25:27 +0800 Subject: [PATCH] fix client --- src/emqtt_client.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/emqtt_client.erl b/src/emqtt_client.erl index d079e8fb6..e05c438f0 100644 --- a/src/emqtt_client.erl +++ b/src/emqtt_client.erl @@ -151,7 +151,7 @@ handle_info({inet_reply, _Sock, {error, Reason}}, State) -> handle_info(keep_alive_timeout, #state{keep_alive=KeepAlive}=State) -> case emqtt_keep_alive:state(KeepAlive) of idle -> - ?INFO("keep alive timeout: ~p", [State#state.conn_name]), + ?INFO("keep_alive timeout: ~p", [State#state.conn_name]), {stop, normal, State}; active -> KeepAlive1 = emqtt_keep_alive:reset(KeepAlive), @@ -351,6 +351,7 @@ process_request(?UNSUBSCRIBE, {ok, State}; process_request(?PINGREQ, #mqtt_frame{}, #state{socket=Sock, keep_alive=KeepAlive}=State) -> + %?INFO("PINGREQ...",[]), %Keep alive timer KeepAlive1 = emqtt_keep_alive:reset(KeepAlive), send_frame(Sock, #mqtt_frame{fixed = #mqtt_frame_fixed{ type = ?PINGRESP }}),