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

Stop emqx_ws

This commit is contained in:
turtled 2018-08-08 18:42:11 +08:00
parent 4d9e03a803
commit b5a1960b63
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/emqx_ws.erl
View File

@ -32,7 +32,7 @@
-export([websocket_handle/2]). -export([websocket_handle/2]).
-export([websocket_info/2]). -export([websocket_info/2]).
init(Req0, State) -> init(Req0, _State) ->
case cowboy_req:parse_header(<<"sec-websocket-protocol">>, Req0) of case cowboy_req:parse_header(<<"sec-websocket-protocol">>, Req0) of
undefined -> undefined ->
{cowboy_websocket, Req0, #wsocket_state{}}; {cowboy_websocket, Req0, #wsocket_state{}};
@ -90,7 +90,8 @@ websocket_handle({binary, Data}, State = #wsocket_state{client_pid = ClientPid,
websocket_info({binary, Data}, State) -> websocket_info({binary, Data}, State) ->
{reply, {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}; {stop, State};
websocket_info(_Info, State) -> websocket_info(_Info, State) ->