anchor.diff:      <<HashAsNum:128/integer>> = crypto:md5(term_to_binary({node(), Now})),
       riak_core_util:integer_to_list(HashAsNum,62).
   
  -%% particular handoff encoding method:
  +%%
  +%% Other helper functions:
  +%%
  +
  +%% Fiddle with the cluster's handoff concurrency:
  +set_handoff_concurrency(ConcurrencyN) when is_integer(ConcurrencyN) ->
  +    OriginalConcurrencyN = get_handoff_concurrency(),
  +    lager:info("Prior concurrency setting ~p, setting to ~p.~n", [OriginalConcurrencyN, ConcurrencyN]),
  +    rpc:multicall(riak_core_handoff_manager, set_concurrency, [ConcurrencyN]),
  +    lager:info("Done setting concurrency.~n"),
  +    OriginalConcurrencyN;
  +
  +set_handoff_concurrency(ConcurrencySettings) when is_list(ConcurrencySettings) ->
  +    lager:info("Restoring concurrency settings to ~p.~n", [ConcurrencySettings]),
  +    rpc:multicall(riak_core_handoff_manager, set_concurrency, ConcurrencySettings),
  +    lager:info("Done restoring concurrency settings.~n");
  +
  +set_handoff_concurrency(use_existing_concurrency) ->
  +    use_existing_concurrency.
  +
  +get_handoff_concurrency() ->
  +    rpc:multicall(riak_core_handoff_manager, get_concurrency, []).
  +
  +%% Force use of a particular particular handoff encoding method:
   force_encoding(Node, HandoffEncoding) ->
       case HandoffEncoding of
           default -> lager:info("Using default encoding type."), true;
  
positive.code:     go(1, {NObjs, ValueSize}).
  
  go(NVnodes, {NObjs, ValueSize}) ->
  
      Secondaries = get_secondaries(),
  
      case length(Secondaries) >= NVnodes of
  
negative.code:     { 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) ->
  