From 07b9cfa722c46a9f345fe1060173f7a4f53fe6f7 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Tue, 26 May 2015 13:21:55 +0800 Subject: [PATCH] shutdown... --- apps/emqttd/src/emqttd_client.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apps/emqttd/src/emqttd_client.erl b/apps/emqttd/src/emqttd_client.erl index 433f81393..2605b42a7 100644 --- a/apps/emqttd/src/emqttd_client.erl +++ b/apps/emqttd/src/emqttd_client.erl @@ -161,15 +161,15 @@ handle_info(Info, State = #state{peername = Peername}) -> {stop, {badinfo, Info}, State}. terminate(Reason, #state{peername = Peername, keepalive = KeepAlive, proto_state = ProtoState}) -> - lager:debug("Client ~s: ~p terminated, reason: ~p~n", [emqttd_net:format(Peername), self(), Reason]), + lager:info("Client ~s: ~p terminated, reason: ~p~n", [emqttd_net:format(Peername), self(), Reason]), notify(disconnected, Reason, ProtoState), emqttd_keepalive:cancel(KeepAlive), case {ProtoState, Reason} of {undefined, _} -> ok; {_, {shutdown, Error}} -> emqttd_protocol:shutdown(Error, ProtoState); - {_, _} -> - ok + {_, Reason} -> + emqttd_protocol:shutdown(Reason, ProtoState) end. code_change(_OldVsn, State, _Extra) ->