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:     unhandled.
  
  
  handle_info({wait_for_vbucket, VBucket, VBState, Callback},
              #state{sock=Sock} = State) ->
      wait_for_vbucket(Sock, VBucket, VBState, Callback),
      {noreply, State};
  handle_info({reap, VBucket, From}, State) ->
      case mc_client_binary:delete_vbucket(State#state.sock, VBucket) of
  
negative.code:     ensure_bucket(Sock, Bucket),
      wait_for_warmup(Sock),
      register(server(Bucket), self()),
      timer:send_interval(?CHECK_INTERVAL, check_config),
      gen_server:enter_loop(?MODULE, [], #state{sock=Sock, bucket=Bucket}).
  
  
  