anchor.diff:                           lager:debug("~p ~p Sending final sync", [Partition, Module]),
                            ok = TcpMod:send(Socket, <<?PT_MSG_SYNC:8>>),
   
  -                         case TcpMod:recv(Socket, 0, RecvTimout) of
  +                         case TcpMod:recv(Socket, 0, RecvTimeout) of
                                {ok,[?PT_MSG_SYNC|<<"sync">>]} ->
                                    lager:debug("~p ~p Final sync received", [Partition, Module]);
                                {error, timeout} -> exit({shutdown, timeout})
  
positive.code:          Msg = <<?PT_MSG_OLDSYNC:8,ModBin/binary>>,
           ok = TcpMod:send(Socket, Msg),
  
           RecvTimout = get_handoff_receive_timeout(),
  
           %% Now that handoff_concurrency applies to both outbound and
           %% inbound conns there is a chance that the receiver may
  
negative.code:     end.
  
  get_handoff_receive_timeout() ->
      app_helper:get_env(riak_core, handoff_timeout, ?TCP_TIMEOUT).
  
  end_fold_time(StartFoldTime) ->
      EndFoldTime = now(),
  