anchor.diff:            item_queue_byte_size :: non_neg_integer(),
   
             acksync_threshold    :: non_neg_integer(),
  +          acksync_timer        :: timer:tref(),
   
             type                 :: ho_type(),
   
  
positive.code:             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);
                  {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) ->
      #ho_acc{filter=Filter,
              module=Module,
              total_objects=TotalObjects,
  
negative.code:                                      parent=ParentPid,
                                       socket=Socket,
                                       src_target={SrcPartition, TargetPartition},
                                       stats=Stats,
                                       tcp_mod=TcpMod,
  
                                       total_bytes=0,
                                       total_objects=0,
  
                                       use_batching=RemoteSupportsBatching,
  
                                       item_queue=[],
                                       item_queue_length=0,
                                       item_queue_byte_size=0,
  
                                       acksync_threshold=AckSyncThreshold,
  
                                       type=Type,
                                       notsent_acc=UnsentAcc0,
                                       notsent_fun=UnsentFun},
  