Method getChangeCountInEntriesChanges

tx.go:746–769

()

}

func (tx *Tx) getChangeCountInEntriesChanges() (int64, error) {
	var res int64
	for _, entriesInDS := range tx.pendingWrites.entriesInBTree {
		for _, entry := range entriesInDS {
			curRecordCnt, err := tx.getEntryNewAddRecordCount(entry)
			if err != nil {
				return res, nil
			}
			res += curRecordCnt
		}
	}
	for _, entriesInDS := range tx.pendingWrites.entries {
		for _, entries := range entriesInDS {
			for _, entry := range entries {
				curRecordCnt, err := tx.getEntryNewAddRecordCount(entry)
				if err != nil {
					return res, err
				}
				res += curRecordCnt
			}
		}
	}
	return res, nil
}

func (tx *Tx) getChangeCountInBucketChanges() int64 {
	var res int64