anchor.diff:  -define(VBUCKET_POLL_INTERVAL, 100).
   -define(TIMEOUT, 30000).
   -define(CONNECTED_TIMEOUT, 5000).
  +%% half-second is definitely 'slow' for any definition of slow
  +-define(SLOW_CALL_THRESHOLD_MICROS, 500000).
   
   %% gen_server API
   -export([start_link/1]).
  
positive.code:                             Acc
                      end, false),
      {reply, Reply, State};
  handle_call({delete_vbucket, VBucket}, _From, #state{sock=Sock} = State) ->
      case mc_client_binary:delete_vbucket(Sock, VBucket) of
          ok ->
              {reply, ok, State};
  
negative.code:                         binary_to_existing_atom(V, latin1)} | Acc]
                end, []),
      {reply, Reply, State};
  do_handle_call(connected, _From, #state{status=Status} = State) ->
      {reply, Status =:= connected, State};
  do_handle_call(flush, _From, State) ->
      Reply = mc_client_binary:flush(State#state.sock),
      {reply, Reply, State};
  do_handle_call({set_flush_param, Key, Value}, _From, State) ->
      Reply = mc_client_binary:set_flush_param(State#state.sock, Key, Value),
      {reply, Reply, State};
  do_handle_call({set_vbucket, VBucket, VBState}, _From,
              #state{sock=Sock} = State) ->
      %% This happens asynchronously, so there's no guarantee the
      %% vbucket will be in the requested state when it returns.
      Reply = mc_client_binary:set_vbucket(Sock, VBucket, VBState),
      {reply, Reply, State};
  do_handle_call({stats, Key}, _From, State) ->
      Reply = mc_client_binary:stats(
                State#state.sock, Key,
                fun (K, V, Acc) ->
                        [{K, V} | Acc]
                end, []),
      {reply, Reply, State};
  do_handle_call(topkeys, _From, State) ->
      Reply = mc_client_binary:stats(
                State#state.sock, <<"topkeys">>,
                fun (K, V, Acc) ->
  