anchor.diff:                                         end),
                            State#state{cmds=gb_trees:delete(Tag, Cmds)};
                        none ->
  -                         ?LOG_WARNING(churn_buffer, "Unknown Cmd Tag: ~p", [Tag]),
  +                         lager:warning("Unknown Cmd Tag: ~p", [Tag]),
                            State
                    end).
   
  
positive.code:                         gb_trees:values(Cmds))),
      churn_buffer(State);
  churn_buffer(#state{cmds=Cmds} = State, [<<"+">> | Response]) ->
      % ?LOG_DEBUG("+: ~p", [Response]),
      ok = lists:foreach(
             fun(Cmd) ->
                     dispatch(Cmd, {'+', Response})
             end, gb_trees:values(Cmds)),
      churn_buffer(State);
  churn_buffer(#state{cmds=Cmds} = State, [Tag | Response]) ->
      % ?LOG_DEBUG("Tag: ~p, Rest: ~p", [Tag, Response]),
      churn_buffer(case gb_trees:lookup(Tag, Cmds) of
                       {value, Cmd} ->
                           ok = dispatch(Cmd, case Response of
  
negative.code: 
  -define(CALL_TIMEOUT, 5000).
  
  
  %% Types
  -type socket() :: ssl:sslsocket() | gen_tcp:socket().
  