From fa84a2595ba53b661d10b56841f8e12fae6cd621 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Sat, 10 Oct 2015 13:30:50 +0800 Subject: [PATCH] critical -> error --- src/emqttd_broker.erl | 2 +- src/emqttd_sm.erl | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/emqttd_broker.erl b/src/emqttd_broker.erl index 5a21eb451..19dd6237a 100644 --- a/src/emqttd_broker.erl +++ b/src/emqttd_broker.erl @@ -257,7 +257,7 @@ handle_call({unhook, Hook, Name}, _From, State) -> {reply, Reply, State}; handle_call(Req, _From, State) -> - lager:critical("Unexpected request: ~p", [Req]), + lager:error("Unexpected request: ~p", [Req]), {reply, {error, badreq}, State}. handle_cast(_Msg, State) -> diff --git a/src/emqttd_sm.erl b/src/emqttd_sm.erl index aeada1bc6..e40bde20f 100644 --- a/src/emqttd_sm.erl +++ b/src/emqttd_sm.erl @@ -187,7 +187,7 @@ handle_call(_Request, _From, State) -> {reply, ok, State}. handle_cast(Msg, State) -> - lager:critical("Unexpected Msg: ~p", [Msg]), + lager:error("Unexpected Msg: ~p", [Msg]), {noreply, State}. handle_info({'DOWN', _MRef, process, DownPid, _Reason}, State) -> @@ -198,7 +198,7 @@ handle_info({'DOWN', _MRef, process, DownPid, _Reason}, State) -> {noreply, State}; handle_info(Info, State) -> - lager:critical("Unexpected Info: ~p", [Info]), + lager:error("Unexpected Info: ~p", [Info]), {noreply, State}. terminate(_Reason, #state{id = Id}) -> @@ -220,7 +220,7 @@ create_session(CleanSess, ClientId, ClientPid) -> case insert_session(Session) of {aborted, {conflict, ConflictPid}} -> %% Conflict with othe node? - lager:critical("Session(~s): Conflict with ~p!", [ClientId, ConflictPid]), + lager:error("Session(~s): Conflict with ~p!", [ClientId, ConflictPid]), {error, conflict}; {atomic, ok} -> erlang:monitor(process, SessPid), @@ -256,11 +256,11 @@ resume_session(Session = #mqtt_session{client_id = ClientId, sess_pid = SessPid} ok -> {ok, SessPid}; {badrpc, nodedown} -> - lager:critical("Session(~s): Died for node ~s down!", [ClientId, Node]), + lager:error("Session(~s): Died for node ~s down!", [ClientId, Node]), remove_session(Session), {error, session_nodedown}; {badrpc, Reason} -> - lager:critical("Session(~s): Failed to resume from node ~s for ~p", + lager:error("Session(~s): Failed to resume from node ~s for ~p", [ClientId, Node, Reason]), {error, Reason} end.