anchor.diff:      {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]),
  +    lager:error("Client(~s): unexpected request - ~p", [emqttd_net:format(Peername), Req]),
       {reply, {error, unsupported_request}, State}.    
   
   handle_cast({subscribe, TopicTable}, State) ->
  
positive.code:                                conn_name   = ConnStr}) ->
      case Parser(Bytes) of
      {more, NewParser} ->
          {noreply, control_throttle(State #state{parser = NewParser}), hibernate};
      {ok, Packet, Rest} ->
          received_stats(Packet),
          case emqttd_protocol:received(Packet, ProtoState) of
          {ok, ProtoState1} ->
              received(Rest, State#state{parser = emqttd_parser:new(PacketOpts),
  
negative.code: handle_info({keepalive, check}, State = #state{peername = Peername, keepalive = KeepAlive}) ->
      case emqttd_keepalive:check(KeepAlive) of
      {ok, KeepAlive1} ->
          noreply(State#state{keepalive = KeepAlive1});
      {error, timeout} ->
          lager:debug("Client(~s): Keepalive Timeout!", [emqttd_net:format(Peername)]),
          stop({shutdown, keepalive_timeout}, State#state{keepalive = undefined});
      {error, Error} ->
          lager:debug("Client(~s): Keepalive Error: ~p!", [emqttd_net:format(Peername), Error]),
          stop({shutdown, keepalive_error}, State#state{keepalive = undefined})
      end;
  
  