anchor.diff:              BinObj = Module:encode_handoff_item(K, V),
   
               ItemQueue2 = [BinObj | ItemQueue],
  +            ItemQueueLength2 = ItemQueueLength + 1,
               ItemQueueByteSize2 = ItemQueueByteSize + byte_size(BinObj),
  +
  +            Acc2 = Acc#ho_acc{item_queue_length=ItemQueueLength2,
  +                              item_queue_byte_size=ItemQueueByteSize2},
   
               %% Unit size is bytes:
               HandoffBatchThreshold = app_helper:get_env(riak_core, handoff_batch_threshold, 1024*1024),
   
               case ItemQueueByteSize2 =< HandoffBatchThreshold of
                   true -> 
  -                         Acc#ho_acc{item_queue=ItemQueue2,
  -                                    item_queue_byte_size=ItemQueueByteSize2};
  -
  -                false -> send_objects(ItemQueue2, Acc)
  +                         Acc2#ho_acc{item_queue=ItemQueue2};
  +
  +                false -> send_objects(ItemQueue2, Acc2)
               end;
   
           false ->
  -            Acc#ho_acc{error=ok, total=Total+1}
  +            Acc#ho_acc{error=ok, total_objects=TotalObjects+1}
       end.
   
   send_objects([], Acc) ->
  
positive.code:                                       src_target={SrcPartition, TargetPartition},
                                        stats=Stats,                                
                                        tcp_mod=TcpMod,
                                        total_bytes=0,
                                        total=0,
                                        item_queue=[],
                                        item_queue_byte_size=0}},                             
  
           %% IFF the vnode is using an async worker to perform the fold
  
negative.code:                  module=Module,
                   parent=ParentPid,
                   tcp_mod=TcpMod,
                   total_objects=SentCount} = R,
  
           case ErrStatus of
               ok ->
  