Function readExactFixedPrimitiveRun

go/fory/struct.go:2468–2590

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

}

func readExactFixedPrimitiveRun(ctx *ReadContext, fields []FieldInfo, start int, ptr unsafe.Pointer) int {
	end := start
	size := 0
	for end < len(fields) {
		field := &fields[end]
		if !canReadFixedRun(field) {
			break
		}
		size += getFixedSizeByDispatchId(field.DispatchId)
		end++
	}
	buf := ctx.Buffer()
	var errOut Error
	if !buf.CheckReadable(size, &errOut) {
		ctx.SetError(errOut)
		return end
	}
	baseOffset := buf.ReaderIndex()
	data := buf.GetData()
	bufOffset := baseOffset
	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 PrimitiveBoolDispatchId:
			storeFieldValue(field.Kind, fieldPtr, optInfo, data[bufOffset] != 0)
			bufOffset++
		case PrimitiveInt8DispatchId:
			storeFieldValue(field.Kind, fieldPtr, optInfo, int8(data[bufOffset]))
			bufOffset++
		case PrimitiveUint8DispatchId:
			storeFieldValue(field.Kind, fieldPtr, optInfo, data[bufOffset])
			bufOffset++
		case PrimitiveInt16DispatchId:
			var v int16
			if isLittleEndian {
				v = *(*int16)(unsafe.Pointer(&data[bufOffset]))
			} else {
				v = int16(binary.LittleEndian.Uint16(data[bufOffset:]))
			}
			storeFieldValue(field.Kind, fieldPtr, optInfo, v)
			bufOffset += 2
		case PrimitiveUint16DispatchId:
			var v uint16
			if isLittleEndian {
				v = *(*uint16)(unsafe.Pointer(&data[bufOffset]))
			} else {
				v = binary.LittleEndian.Uint16(data[bufOffset:])
			}
			storeFieldValue(field.Kind, fieldPtr, optInfo, v)
			bufOffset += 2
		case PrimitiveInt32DispatchId:
			var v int32
			if isLittleEndian {