anchor.diff:      HS = State#state.handoffs,
       case lists:keytake(TP, #handoff_status.transport_pid, HS) of
           false ->
  -            {reply, ok, State, timeout()};
  +            {reply, ok, State};
           {value, Xfer, HS2} ->
               #handoff_status{mod_src_tgt={Mod, SrcPartition, TargetPartition},
                               type=Type,
  
positive.code:         ]).
  
  -include("riak_core_handoff.hrl").
  -define(DEFAULT_TIMEOUT, 60000).
  
  -ifdef(TEST).
  -include_lib("eunit/include/eunit.hrl").
  
negative.code:     case send_handoff({Mod, Src, Target}, ReqOrigin, SrcPid, HS, {Filter, FMF}, ReqOrigin) of
          {ok, Handoff} ->
              HS2 = HS ++ [Handoff],
              {reply, {ok, Handoff}, State#state{handoffs=HS2}};
          {false, Handoff} ->
              {reply, {ok, Handoff}, State}
      end;
  
  handle_call({status, Filter}, _From, State=#state{handoffs=HS}) ->
      Status = lists:filter(filter(Filter), [build_status(HO) || HO <- HS]),
      {reply, Status, State};
  
  handle_call({set_concurrency,Limit},_From,State=#state{handoffs=HS}) ->
      application:set_env(riak_core,handoff_concurrency,Limit),
  