anchor.diff:  
   -include("ns_common.hrl").
   
  +-define(CHECK_INTERVAL, 10000).
   -define(VBUCKET_POLL_INTERVAL, 100).
   
   %% gen_server API
  
positive.code:     ensure_bucket(Sock, Bucket),
      wait_for_warmup(Sock),
      register(server(Bucket), self()),
      gen_server:enter_loop(?MODULE, [], #state{sock=Sock, bucket=Bucket}).
  
  
  
negative.code:         {memcached_error, einval, _} ->
              timer:send_after(?VBUCKET_POLL_INTERVAL, {reap, VBucket, From})
      end,
      {noreply, State};
  handle_info({wait_for_vbucket, VBucket, VBState, Callback},
              #state{sock=Sock} = State) ->
      wait_for_vbucket(Sock, VBucket, VBState, Callback),
      {noreply, State};
  handle_info(Msg, State) ->
      ?log_info("handle_info(~p, ~p)", [Msg, State]),
  