anchor.diff:      { ok, Ring } = riak_core_ring_manager:get_raw_ring(),
       riak_core_ring:all_owners(Ring).
   
  -%%%%%%%%%%
  +%%
  +%% Data object utilities:
  +%%
   
   %% Construct test handoff objects and send them to the requested vnode:
   seed_data({0, _Size}, _SecondarySHA1) ->
  
positive.code:     <<HashAsNum:128/integer>> = crypto:md5(term_to_binary({node(), Now})),
      riak_core_util:integer_to_list(HashAsNum,62).
  
  %% particular handoff encoding method:
  force_encoding(Node, HandoffEncoding) ->
      case HandoffEncoding of
          default -> lager:info("Using default encoding type."), true;
  
negative.code:     go(1, {NObjs, ValueSize}).
  
  go(NVnodes, {NObjs, ValueSize}) ->
      go(NVnodes, { NObjs, ValueSize }, strategy_other_owner).
  
  go(NVnodes, {NObjs, ValueSize}, GatherStrategy) ->
      go(NVnodes, {NObjs, ValueSize}, GatherStrategy, use_existing_concurrency).
  
  go(NVnodes, {NObjs, ValueSize}, GatherStrategy, ConcurrencyN) ->
  
      Targets = gather_targets(NVnodes, GatherStrategy),
  
      lager:info("Seeding ~p objects of size ~p to ~p nodes by strategy ~p...~n", [NObjs, ValueSize, NVnodes, GatherStrategy]),
      lists:map(fun(Target) -> seed_data({NObjs, ValueSize}, Target) end, Targets),
      lager:info("Done seeding.~n"),
  
      OldConcurrencyN = set_handoff_concurrency(ConcurrencyN),
  
      lager:info("Forcing handoff.~n"),
      riak_core_vnode_manager:force_handoffs(),
      lager:info("Done forcing handoff.~n"),
  
      %% Be a friendly citizen and restore the original concurrency settings:
      set_handoff_concurrency(OldConcurrencyN),
  
      true.
  
  %%%%%%%%%%
  
  %%
  %% Different ways of gathering target vnodes for handoff:
  %%
  
  gather_targets(NVnodes, GatherStrategy) ->
      case GatherStrategy of 
          strategy_other_owner -> gather_vnodes_1(NVnodes);
          strategy_roundrobin  -> gather_vnodes_rr(NVnodes);
          _ -> erlang:throw("Invalid gather strategy " ++ GatherStrategy)
      end.
  
  %% Construct a list of target vnodes such that we select from vnodes that we don't own:
  gather_vnodes_1(NVnodes) ->
      Secondaries = get_secondaries(),
  
      case length(Secondaries) >= NVnodes of
  