From 5117d88b7a876de3c03e4ae63dd8ca9b81550300 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Sun, 30 Aug 2015 10:23:26 +0800 Subject: [PATCH] warning --- src/emqttd_client.erl | 6 +++--- src/emqttd_session.erl | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/emqttd_client.erl b/src/emqttd_client.erl index bffb9232f..f78422ac6 100644 --- a/src/emqttd_client.erl +++ b/src/emqttd_client.erl @@ -110,9 +110,9 @@ handle_info(timeout, State) -> stop({shutdown, timeout}, State); handle_info({stop, duplicate_id, _NewPid}, State=#state{proto_state = ProtoState, - conn_name=ConnName}) -> - lager:error("Shutdown for duplicate clientid: ~s, conn:~s", - [emqttd_protocol:clientid(ProtoState), ConnName]), + conn_name = ConnName}) -> + lager:warning("Shutdown for duplicate clientid: ~s, conn:~s", + [emqttd_protocol:clientid(ProtoState), ConnName]), stop({shutdown, duplicate_id}, State); handle_info({deliver, Message}, State = #state{proto_state = ProtoState}) -> diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index db68b368d..9a29ce5da 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -571,7 +571,7 @@ kick(_ClientId, _ClientPid, undefined) -> kick(_ClientId, ClientPid, ClientPid) -> ok; kick(ClientId, ClientPid, OldClientPid) -> - lager:error("Session '~s' is duplicated: pid=~p, oldpid=~p", [ClientId, ClientPid, OldClientPid]), + lager:warning("Session '~s' is duplicated: pid=~p, oldpid=~p", [ClientId, ClientPid, OldClientPid]), unlink(OldClientPid), OldClientPid ! {stop, duplicate_id, ClientPid}.