Function readExactVarintPrimitiveRun

go/fory/struct.go:2596–2676

(ctx *ReadContext, fields []FieldInfo, start int, ptr unsafe.Pointer)

}

func readExactVarintPrimitiveRun(ctx *ReadContext, fields []FieldInfo, start int, ptr unsafe.Pointer) int {
	end := start
	maxSize := 0
	plainVarint32Values := true
	for end < len(fields) {
		field := &fields[end]
		if !canReadVarintRun(field) {
			break
		}
		maxSize += getVarintMaxSizeByDispatchId(field.DispatchId)
		if field.DispatchId != PrimitiveVarint32DispatchId || field.Kind != FieldKindValue {
			plainVarint32Values = false
		}
		end++
	}
	buf := ctx.Buffer()
	err := ctx.Err()
	useUnsafe := buf.remaining() >= maxSize+8
	if plainVarint32Values {
		for i := start; i < end; i++ {
			field := &fields[i]
			if useUnsafe {
				*(*int32)(unsafe.Add(ptr, field.Offset)) = buf.UnsafeReadVarint32(err)
			} else {
				*(*int32)(unsafe.Add(ptr, field.Offset)) = buf.ReadVarint32(err)
			}
		}
		return end
	}
	for i := start; i < end; i++ {
		field := &fields[i]
		fieldPtr := unsafe.Add(ptr, field.Offset)
		optInfo := optionalInfo{}
		if field.Kind == FieldKindOptional {
			optInfo = field.Meta.OptionalInfo
		}
		switch field.DispatchId {
		case PrimitiveVarint32DispatchId:
			if useUnsafe {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.UnsafeReadVarint32(err))
			} else {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.ReadVarint32(err))
			}
		case PrimitiveVarint64DispatchId:
			if useUnsafe {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.UnsafeReadVarint64())
			} else {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.ReadVarint64(err))
			}
		case PrimitiveVarUint32DispatchId:
			if useUnsafe {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.UnsafeReadVarUint32(err))
			} else {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.ReadVarUint32(err))
			}
		case PrimitiveVarUint64DispatchId:
			if useUnsafe {
				storeFieldValue(field.Kind, fieldPtr, optInfo, buf.UnsafeReadVarUint64())