anchor.diff:  
   % ------------------------------------------
   
  -a2x_forward(Addr, Out, Cmd, CmdArgs) ->
  -    a2x_forward(Addr, Out, Cmd, CmdArgs, undefined).
  -
  -a2x_forward(Addr, Out, Cmd, CmdArgs, ResponseFilter) ->
  +forward(Addr, Out, Cmd, CmdArgs) ->
  +    forward(Addr, Out, Cmd, CmdArgs, undefined).
  +
  +forward(Addr, Out, Cmd, CmdArgs, ResponseFilter) ->
       Kind = mc_addr:kind(Addr),
       ResponseFun =
           fun (Head, Body) ->
               case ((not is_function(ResponseFilter)) orelse
                     (ResponseFilter(Head, Body))) of
  -                true  -> a2x_send_response_from(Kind, Out, Head, Body);
  +                true  -> send_response(Kind, Out, Head, Body);
                   false -> false
               end
           end,
  
positive.code: cmd(delete, #session_proxy{bucket = Bucket} = Session,
      _InSock, Out, [Key]) ->
      {Key, Addr} = mc_bucket:choose_addr(Bucket, Key),
      {ok, Monitor} = a2x_forward(Addr, Out, delete, #mc_entry{key = Key}),
      case await_ok(1) of
          1 -> true;
          _ -> mc_ascii:send(Out, <<"ERROR\r\n">>)
  
negative.code: forward_arith(Cmd, #session_proxy{bucket = Bucket} = Session,
                _InSock, Out, [Key, Amount]) ->
      {Key, Addr} = mc_bucket:choose_addr(Bucket, Key),
      {ok, Monitor} = forward(Addr, Out, Cmd,
                              #mc_entry{key = Key, data = Amount}),
      case await_ok(1) of
          1 -> true;
          _ -> mc_ascii:send(Out, <<"ERROR\r\n">>)
  