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

fix client

This commit is contained in:
erylee 2013-09-17 11:25:27 +08:00
parent fd711f3fbc
commit 3e3dfe3fa2
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/emqtt_client.erl
View File

@ -151,7 +151,7 @@ handle_info({inet_reply, _Sock, {error, Reason}}, State) ->
handle_info(keep_alive_timeout, #state{keep_alive=KeepAlive}=State) -> handle_info(keep_alive_timeout, #state{keep_alive=KeepAlive}=State) ->
case emqtt_keep_alive:state(KeepAlive) of case emqtt_keep_alive:state(KeepAlive) of
idle -> idle ->
?INFO("keep alive timeout: ~p", [State#state.conn_name]), ?INFO("keep_alive timeout: ~p", [State#state.conn_name]),
{stop, normal, State}; {stop, normal, State};
active -> active ->
KeepAlive1 = emqtt_keep_alive:reset(KeepAlive), KeepAlive1 = emqtt_keep_alive:reset(KeepAlive),
@ -351,6 +351,7 @@ process_request(?UNSUBSCRIBE,
{ok, State}; {ok, State};
process_request(?PINGREQ, #mqtt_frame{}, #state{socket=Sock, keep_alive=KeepAlive}=State) -> process_request(?PINGREQ, #mqtt_frame{}, #state{socket=Sock, keep_alive=KeepAlive}=State) ->
%?INFO("PINGREQ...",[]),
%Keep alive timer %Keep alive timer
KeepAlive1 = emqtt_keep_alive:reset(KeepAlive), KeepAlive1 = emqtt_keep_alive:reset(KeepAlive),
send_frame(Sock, #mqtt_frame{fixed = #mqtt_frame_fixed{ type = ?PINGRESP }}), send_frame(Sock, #mqtt_frame{fixed = #mqtt_frame_fixed{ type = ?PINGRESP }}),