anchor.diff:               {error, closed} -> exit({shutdown, max_concurrency})
            end,
   
  -         log_start(Module, {Type, Opts}, SrcNode, TargetNode),
  +         lager:info("Starting ~p transfer of ~p from ~p ~p to ~p ~p",
  +                    [Type, Module, SrcNode, SrcPartition,
  +                     TargetNode, TargetPartition]),
   
            M = <<?PT_MSG_INIT:8,TargetPartition:160/integer>>,
            ok = TcpMod:send(Socket, M),
  
positive.code: %% can be set with env riak_core, handoff_status_interval
  %% note this is in seconds
  -define(STATUS_INTERVAL, 2).
  
  %% Accumulator for the visit item HOF
  -record(ho_acc,
  
negative.code: 
                   FoldTimeDiff = end_fold_time(StartFoldTime),
  
                   lager:info("~p transfer of ~p from ~p ~p to ~p ~p"
                              " completed: sent ~p objects in ~.2f seconds",
                              [Type, Module, SrcNode, SrcPartition,
                               TargetNode, TargetPartition, SentCount,
                               FoldTimeDiff]),
  
                   case Type of
                       repair -> ok;
                       _ -> gen_fsm:send_event(ParentPid, handoff_complete)
                   end;
               {error, ErrReason} ->
                   ?log_fail("because of ~p", [ErrReason]),
                   if ErrReason == timeout ->
                           riak_core_stat:update(handoff_timeouts);
                      true -> ok
  