anchor.diff:              case TcpMod:recv(Sock, 0, RecvTimeout) of
                   {ok,[?PT_MSG_OLDSYNC|<<"sync">>]} ->
                       Acc2 = Acc#ho_acc{ack=0, error=ok, stats=Stats3},
  -                    visit_item(K, V, Acc2);
  +                    visit_item2(K, V, Acc2);
                   {error, Reason} ->
                       Acc#ho_acc{ack=0, error={error, Reason}, stats=Stats3}
               end;
           {error, Reason} ->
               Acc#ho_acc{ack=0, error={error, Reason}, stats=Stats3}
       end;
  -visit_item(K, V, Acc) ->
  +visit_item2(K, V, Acc) ->
       #ho_acc{filter=Filter,
               module=Module,
               total_objects=TotalObjects,
  
positive.code:            total_objects=TotalObjects,
             total_bytes=TotalBytes,
             stats=FinalStats,
             notsent_acc=NotSentAcc} = AccRecord,
  
           case ErrStatus of
               ok ->
                   %% One last sync to make sure the message has been received.
  
negative.code:     ObjectList = term_to_binary(Items),
  
      M = <<?PT_MSG_BATCH:8, ObjectList/binary>>,
  
      NumBytes = byte_size(M),
  
      Stats2 = incr_bytes(incr_objs(Stats, NObjects), NumBytes),
      Stats3 = maybe_send_status({Module, SrcPartition, TargetPartition}, Stats2),
  
      case TcpMod:send(Sock, M) of
          ok ->
              Acc#ho_acc{ack=Ack+1, error=ok, stats=Stats3,
                         total_objects=TotalObjects+NObjects,
                         total_bytes=TotalBytes+NumBytes,
                         item_queue=[],
  