anchor.diff:      network_error(Reason, State);
   
   handle_info({inet_reply, _Sock, {error, Reason}}, State = #state{peername = Peername}) ->
  -    lager:error("Client ~s: unexpected inet_reply '~p'", [emqttd_net:format(Peername), Reason]),
  +    lager:error("Client(~s): unexpected inet_reply '~p'", [emqttd_net:format(Peername), Reason]),
       {noreply, State};
   
   handle_info({keepalive, start, TimeoutSec}, State = #state{transport = Transport, socket = Socket, peername = Peername}) ->
  -    lager:debug("Client ~s: Start KeepAlive with ~p seconds", [emqttd_net:format(Peername), TimeoutSec]),
  +    lager:debug("Client(~s): Start KeepAlive with ~p seconds",
  +                  [emqttd_net:format(Peername), TimeoutSec]),
       StatFun = fun() ->
               case Transport:getstat(Socket, [recv_oct]) of
                   {ok, [{recv_oct, RecvOct}]} -> {ok, RecvOct};
  
positive.code:     {stop, {shutdown, kick}, ok, State};
  
  handle_call(Req, _From, State = #state{peername = Peername}) ->
      lager:error("Client ~s: unexpected request - ~p", [emqttd_net:format(Peername), Req]),
      {reply, {error, unsupported_request}, State}.    
  
  handle_cast({subscribe, TopicTable}, State) ->
  
negative.code:                                conn_name   = ConnStr}) ->
      case Parser(Bytes) of
      {more, NewParser} ->
          noreply(control_throttle(State#state{parser = NewParser}));
      {ok, Packet, Rest} ->
          emqttd_metrics:received(Packet),
          case emqttd_protocol:received(Packet, ProtoState) of
          {ok, ProtoState1} ->
              received(Rest, State#state{parser = emqttd_parser:new(PacketOpts),
  