From 3a43d2b41f81b62fac5758fde53c34a764370644 Mon Sep 17 00:00:00 2001 From: Feng Date: Thu, 30 Jun 2016 23:24:02 +0800 Subject: [PATCH] WSLOG --- src/emqttd_ws.erl | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/emqttd_ws.erl b/src/emqttd_ws.erl index fc482b365..60371457f 100644 --- a/src/emqttd_ws.erl +++ b/src/emqttd_ws.erl @@ -21,7 +21,7 @@ %% WebSocket Loop State -record(wsocket_state, {peer, client_pid, packet_opts, parser_fun}). --define(LOG(Level, Peer, Format, Args), +-define(WSLOG(Level, Peer, Format, Args), lager:Level("WsClient(~s): " ++ Format, [Peer | Args])). %%-------------------------------------------------------------------- @@ -54,7 +54,7 @@ ws_loop([<<>>], State, _ReplyChannel) -> State; ws_loop(Data, State = #wsocket_state{peer = Peer, client_pid = ClientPid, parser_fun = ParserFun}, ReplyChannel) -> - ?LOG(debug, Peer, "RECV ~p", [Data]), + ?WSLOG(debug, Peer, "RECV ~p", [Data]), case catch ParserFun(iolist_to_binary(Data)) of {more, NewParser} -> State#wsocket_state{parser_fun = NewParser}; @@ -62,11 +62,11 @@ ws_loop(Data, State = #wsocket_state{peer = Peer, client_pid = ClientPid, gen_server:cast(ClientPid, {received, Packet}), ws_loop(Rest, reset_parser(State), ReplyChannel); {error, Error} -> - ?LOG(error, Peer, "Frame error: ~p", [Error]), + ?WSLOG(error, Peer, "Frame error: ~p", [Error]), exit({shutdown, Error}); {'EXIT', Reason} -> - ?LOG(error, Peer, "Frame error: ~p", [Reason]), - ?LOG(error, Peer, "Error data: ~p", [Data]), + ?WSLOG(error, Peer, "Frame error: ~p", [Reason]), + ?WSLOG(error, Peer, "Error data: ~p", [Data]), exit({shutdown, parser_error}) end.