anchor.diff:                NodePids = [{Node, proc_lib:spawn_link(
                                      fun () ->
                                              {ok, TRef} = timer2:kill_after(SecondsToWait * 1000),
  -                                           RV = new_style_query_vbucket_states_loop(Node, Bucket, Type),
  +                                           RV = query_vbucket_states_loop(Node, Bucket, Type),
                                              Me ! {'EXIT', self(), {Ref, RV}},
                                              %% doing cancel is quite
                                              %% important. kill_after is
  
positive.code:                 up ->
                      warming_up;
                  connected ->
                      new_style_query_vbucket_states_loop_next_step(Node, Bucket, Type)
              end;
          Exc ->
              ?log_debug("Exception from query_vbucket_states of ~p:~p~n~p", [Bucket, Node, Exc]),
              new_style_query_vbucket_states_loop_next_step(Node, Bucket, Type)
      end.
  
  new_style_query_vbucket_states_loop_next_step(Node, Bucket, Type) ->
      ?log_debug("Waiting for ~p on ~p", [Bucket, Node]),
      timer:sleep(1000),
      new_style_query_vbucket_states_loop(Node, Bucket, Type).
  
  -spec wait_for_memcached_new_style([node()], bucket_name(), up | connected, non_neg_integer()) -> [{node(), warming_up | {ok, list()} | any()}].
  wait_for_memcached_new_style(Nodes, Bucket, Type, SecondsToWait) ->
      Parent = self(),
      misc:executing_on_new_process(
        fun () ->
  
negative.code:                      end],
      BadNodes.
  
  query_vbucket_states_loop(Node, Bucket, Type) ->
      case (catch gen_server:call(server_name(Bucket, Node), query_vbucket_states, infinity)) of
          {ok, _} = Msg ->
              Msg;
  