anchor.diff:                NodePids = [{Node, proc_lib:spawn_link(
                                      fun () ->
                                              {ok, TRef} = timer2:kill_after(WaitTimeout),
  -                                           RV = query_vbucket_states_loop(Node, Bucket),
  +                                           RV = query_vbucket_states_loop(Node, Bucket, Me),
                                              Me ! {'EXIT', self(), {Ref, RV}},
                                              %% doing cancel is quite
                                              %% important. kill_after is
  
positive.code:                      {VBucket, State} <- Pairs],
              {ok, RV, []};
          _ ->
              ?log_error("Failed to query vbucket states from some nodes:~n~p", [Failures]),
  
              BadNodes = [N || {N, _} <- Failures],
              {ok, [], BadNodes}
      end.
  
  -spec mark_bucket_warmed(Bucket::bucket_name(), [node()]) -> ok | {error, [node()], list()}.
  
negative.code:                                            erlang:unlink(Me)
                                     end)}
                            || Node <- Nodes],
                [recv_result(Bucket, Parent, Ref, NodePid) || NodePid <- NodePids]
        end).
  
  recv_result(Bucket, Parent, Ref, {Node, Pid}) ->
      receive
          {'EXIT', Parent, Reason} ->
              ?log_debug("Parent died ~p", [Reason]),
              exit(Reason);
          {'EXIT', Pid, {Ref, RV}} ->
              {Node, RV};
          {'EXIT', Pid, killed} ->
              receive
                  warming_up ->
                      {Node, warming_up}
              after 0 ->
                      {Node, timeout}
              end;
          {'EXIT', Pid, Reason} = ExitMsg ->
              ?log_info("Got exception trying to query vbuckets of ~p bucket ~p~n~p",
                        [Node, Bucket, Reason]),
              {Node, ExitMsg}
      end.
  
  complete_flush(Bucket, Nodes, Timeout) ->
      {Replies, BadNodes} = gen_server:multi_call(Nodes, server_name(Bucket), complete_flush, Timeout),
  