anchor.diff:  %     cmd_update(Sock, RecvCallback, Entry, ?PREPEND);
   
   % cmd(incr, Sock, RecvCallback, Entry) ->
  -%     send_recv(Sock, RecvCallback, Entry, ?INCREMENT);
  +%     send_recv(Sock, RecvCallback, Entry, ?INCREMENT, <<"OK">>);
   % cmd(decr, Sock, RecvCallback, Entry) ->
  -%     send_recv(Sock, RecvCallback, Entry, ?DECREMENT);
  +%     send_recv(Sock, RecvCallback, Entry, ?DECREMENT, <<"OK">>);
   
   cmd(delete, Sock, RecvCallback, Entry) ->
  -    send_recv(Sock, RecvCallback, #mc_header{opcode = ?DELETE}, Entry);
  +    send_recv(Sock, RecvCallback, #mc_header{opcode = ?DELETE}, Entry,
  +              <<"DELETED">>);
   
   cmd(flush_all, Sock, RecvCallback, Entry) ->
  -    send_recv(Sock, RecvCallback, #mc_header{opcode = ?FLUSH}, Entry);
  +    send_recv(Sock, RecvCallback, #mc_header{opcode = ?FLUSH}, Entry, <<"OK">>);
   
   cmd(Opcode, Sock, RecvCallback, Entry) ->
       % Dispatch to cmd_binary() in case the caller was
  
positive.code: -compile(export_all).
  
  % cmd(version, Sock, RecvCallback, Entry) ->
  %     send_recv(Sock, RecvCallback, #mc_header{opcode = ?VERSION}, Entry);
  
  cmd(get, Sock, RecvCallback, #mc_entry{keys = Keys}) ->
      ok = send(Sock,
  
negative.code:     {ok, Sock} = gen_tcp:connect("localhost", 11211,
                                   [binary, {packet, 0}, {active, false}]),
      (fun () ->
          {ok, works} = send_recv(Sock, nil,
                                  #mc_header{opcode = ?NOOP}, #mc_entry{},
                                  works)
      end)(),
  
      test_flush(Sock),
  
      ok = gen_tcp:close(Sock).
  
  test_flush(Sock) ->
      {ok, works} = send_recv(Sock, nil,
                              #mc_header{opcode = ?FLUSH}, #mc_entry{}, works).
  
      % (fun () ->
      %     {ok, RB1} = send_recv(Sock, <<"get ", Key/binary, "\r\n">>, nil),
      %     ?assertMatch(RB1, <<"END">>)
      % end)(),
  
  set_test() ->
      {ok, Sock} = gen_tcp:connect("localhost", 11211,
                                   [binary, {packet, 0}, {active, false}]),
      set_test_sock(Sock, <<"aaa">>),
      ok = gen_tcp:close(Sock).
  
  set_test_sock(Sock, Key) ->
      test_flush(Sock),
  
      (fun () ->
          {ok, RB} = cmd(set, Sock, nil,
                         #mc_entry{key = Key,
                                   data = <<"AAA">>}),
          ?assertMatch(RB, <<"STORED">>)
  
          % get_test_match(Sock, Key, <<"AAA">>)
      end)().
  