anchor.diff:          {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]),
  
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: 
  -include("ns_common.hrl").
  
  -define(CHECK_INTERVAL, 10000).
  -define(VBUCKET_POLL_INTERVAL, 100).
  
  %% gen_server API
  