anchor.diff:          X2 when is_binary(X2) ->
               ?log_info("Changing dbname of ~p from ~s to ~s", [Bucket, X2,
                                                                 DBDirBin]),
  -            mc_client_binary:delete_bucket(Sock,
  -                                           Bucket),
  -            ensure_bucket(Sock, Bucket)
  +            %% Just exit; this will delete and recreate the bucket
  +            exit(normal)
       end;
   ensure_bucket_config(Sock, _Bucket, memcached, _MaxSize) ->
       %% TODO: change max size of memcached bucket also
  
positive.code:             #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]),
      {noreply, State}.
  
  
  terminate(Reason, State) ->
      if
          Reason == normal; Reason == shutdown ->
              ?log_info("Deleting bucket ~p", [State#state.bucket]),
              try
                  mc_client_binary:delete_bucket(State#state.sock,
                                                 State#state.bucket)
              catch
                  E:R ->
                      ?log_error("Failed to delete bucket ~p: ~p",
                                 [State#state.bucket, {E, R}])
              end;
          true -> ok
      end,
      catch gen_tcp:close(State#state.sock),
      ok.
  
  
  
negative.code:     proc_lib:init_ack({ok, self()}),
      Sock = connect(),
      StartTime = now(),
      ok = ensure_bucket(Sock, Bucket),
      wait_for_warmup(Sock),
      ns_log:log(?MODULE, 1, "Bucket ~p loaded on node ~p in ~p seconds.",
                 [Bucket, node(), timer:now_diff(now(), StartTime) div 1000000]),
  