From b5a1960b6342bfaa9eacc6dba081f366deb7c56c Mon Sep 17 00:00:00 2001 From: turtled Date: Wed, 8 Aug 2018 18:42:11 +0800 Subject: [PATCH] Stop emqx_ws --- src/emqx_ws.erl | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/emqx_ws.erl b/src/emqx_ws.erl index b84c603af..d7f6dc6e8 100644 --- a/src/emqx_ws.erl +++ b/src/emqx_ws.erl @@ -32,7 +32,7 @@ -export([websocket_handle/2]). -export([websocket_info/2]). -init(Req0, State) -> +init(Req0, _State) -> case cowboy_req:parse_header(<<"sec-websocket-protocol">>, Req0) of undefined -> {cowboy_websocket, Req0, #wsocket_state{}}; @@ -90,7 +90,8 @@ websocket_handle({binary, Data}, State = #wsocket_state{client_pid = ClientPid, websocket_info({binary, Data}, State) -> {reply, {binary, Data}, State}; -websocket_info({'EXIT', _Pid, {shutdown, kick}}, State) -> +websocket_info({'EXIT', Pid, Reason}, State = #wsocket_state{client_pid = Pid}) -> + ?WSLOG(debug, "EXIT: ~p", [Reason], State), {stop, State}; websocket_info(_Info, State) ->