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:          exit:{shutdown, timeout} ->
               %% A receive timeout during handoff
               riak_core_stat:update(handoff_timeouts),
               log_fail(Module, {Type, Opts}, SrcNode, TargetNode,
                        " because of TCP recv timeout");
           Err:Reason ->
               ReasonStr3 = io_lib:format(" because of ~p:~p ~p",
                                          [Err, Reason, erlang:get_stacktrace()]),
               log_fail(Module, {Type, Opts}, SrcNode, TargetNode, ReasonStr3),
               gen_fsm:send_event(ParentPid, {handoff_error, Err, Reason})
       end.
  
  
negative.code: 
  start_fold(TargetNode, Module, {Type, Opts}, ParentPid, SslOpts) ->
      SrcNode = node(),
      SrcPartition = get_src_partition(Opts),
      TargetPartition = get_target_partition(Opts),
  
       try
           Filter = get_filter(Opts),
           [_Name,Host] = string:tokens(atom_to_list(TargetNode), "@"),
           {ok, Port} = get_handoff_port(TargetNode),
  