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:     GoodNodes = [N || {N, _R} <- GoodReplies],
      {GoodNodes, BadReplies, BadNodes}.
  
  -spec query_states(bucket_name(), [node()], undefined | pos_integer()) -> {ok, [{node(), vbucket_id(), vbucket_state()}], [node()]}.
  query_states(Bucket, Nodes, ReadynessWaitTimeout0) ->
      ReadynessWaitTimeout = case ReadynessWaitTimeout0 of
                                 undefined -> ?WAIT_FOR_MEMCACHED_SECONDS;
                                 _ -> ReadynessWaitTimeout0
                             end,
      query_states_new_style(Bucket, Nodes, ReadynessWaitTimeout).
  
  %% TODO: consider supporting partial janitoring
  query_states_new_style(Bucket, Nodes, ReadynessWaitTimeout) ->
      NodeRVs = wait_for_memcached_new_style(Nodes, Bucket, connected, ReadynessWaitTimeout),
      BadNodes = [N || {N, R} <- NodeRVs,
                       case R of
                           {ok, _} -> false;
  
negative.code:          get_tap_docs_estimate_many_taps/4,
           get_mass_tap_docs_estimate/3]).
  
  -export([start_link/1]).
  
  %% gen_server callbacks
  -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
           terminate/2, code_change/3]).
  
  wait_for_bucket_creation(Bucket, Nodes) ->
      NodeRVs = wait_for_memcached(Nodes, Bucket, up, ?WAIT_FOR_MEMCACHED_SECONDS),
      BadNodes = [N || {N, R} <- NodeRVs,
                       case R of
                           warming_up -> false;
  