anchor.diff:                NodePids = [{Node, proc_lib:spawn_link(
                                      fun () ->
                                              {ok, TRef} = timer2:kill_after(WaitTimeout),
  -                                           RV = query_vbucket_states_loop(Node, Bucket, Type),
  +                                           RV = query_vbucket_states_loop(Node, Bucket),
                                              Me ! {'EXIT', self(), {Ref, RV}},
                                              %% doing cancel is quite
                                              %% important. kill_after is
  
positive.code: query_states(Bucket, Nodes, undefined) ->
      query_states(Bucket, Nodes, ?WAIT_FOR_MEMCACHED_TIMEOUT);
  query_states(Bucket, Nodes, ReadynessWaitTimeout) ->
      NodeRVs = wait_for_memcached(Nodes, Bucket, connected, ReadynessWaitTimeout),
      Failures = [{N, R} || {N, R} <- NodeRVs,
                            case R of
                                {ok, _} -> false;
  
negative.code:          terminate/2, code_change/3]).
  
  wait_for_bucket_creation(Bucket, Nodes) ->
      NodeRVs = wait_for_memcached(Nodes, Bucket, ?WAIT_FOR_MEMCACHED_TIMEOUT),
      BadNodes = [N || {N, R} <- NodeRVs,
                       case R of
                           warming_up -> false;
  