anchor.diff:  -include("riak_core_vnode.hrl").
   -include("riak_core_handoff.hrl").
   -define(ACK_COUNT, 1000).
  +%% can be set with env riak_core, handoff_timeout
  +-define(TCP_TIMEOUT, 60000).
   
   start_link(TargetNode, Module, Partition, VnodePid) ->
       SslOpts = get_handoff_ssl_options(),
  
positive.code:          %% protocol but for now the sender must assume that a closed
           %% socket at this point is a rejection by the receiver to
           %% enforce handoff_concurrency.
           case TcpMod:recv(Socket, 0, RecvTimout) of
               {ok,[?PT_MSG_OLDSYNC|<<"sync">>]} -> ok;
               {error, timeout} -> exit({shutdown, timeout});
               {error, closed} -> exit({shutdown, max_concurrency})
  
negative.code:     end.
  
  get_handoff_receive_timeout() ->
      app_helper:get_env(riak_core, handoff_timeout, ?TCP_TIMEOUT).
  
  end_fold_time(StartFoldTime) ->
      EndFoldTime = now(),
  