Method readData

go/fory/slice_dyn.go:265–319

(ctx *ReadContext, value reflect.Value, expectedLength int)

}

func (s sliceDynSerializer) readData(ctx *ReadContext, value reflect.Value, expectedLength int) {
	buf := ctx.Buffer()
	ctxErr := ctx.Err()
	length := ctx.ReadCollectionLength()
	sliceType := value.Type()
	if ctx.HasError() {
		return
	}
	if expectedLength >= 0 && length != expectedLength {
		ctx.SetError(DeserializationErrorf("array length %d does not match serialized length %d", expectedLength, length))
		return
	}
	if length == 0 {
		value.Set(reflect.MakeSlice(sliceType, 0, 0))
		return
	}

	collectFlag := buf.ReadInt8(ctxErr)
	if ctx.HasError() {
		return
	}

	var elemTypeInfo *TypeInfo
	var elemType reflect.Type
	var elemSerializer Serializer
	if (collectFlag & CollectionIsSameType) != 0 {
		if (collectFlag & CollectionIsDeclElementType) == 0 {
			elemTypeInfo = ctx.TypeResolver().ReadTypeInfo(buf, ctxErr)
		}
		if elemTypeInfo != nil && elemTypeInfo.Serializer != nil {
			elemType = elemTypeInfo.Type
			elemSerializer = elemTypeInfo.Serializer
		} else {
			// When CollectionIsDeclElementType is set, get serializer from the declared element type
			elemType = sliceType.Elem()
			elemSerializer, _ = ctx.TypeResolver().getSerializerByType(elemType, false)
		}
		if ctx.HasError() {
			return
		}
		if !buf.CheckReadable(length, ctxErr) {
			return
		}
		value.Set(reflect.MakeSlice(sliceType, length, length))
		ctx.RefResolver().Reference(value)
		s.readSameType(ctx, buf, value, elemType, elemSerializer, collectFlag, length)
		return
	}
	if !buf.CheckReadable(length, ctxErr) {
		return
	}
	value.Set(reflect.MakeSlice(sliceType, length, length))
	ctx.RefResolver().Reference(value)
	s.readDifferentTypes(ctx, buf, value, collectFlag, length)
}

func (s sliceDynSerializer) ReadWithTypeInfo(ctx *ReadContext, refMode RefMode, typeInfo *TypeInfo, value reflect.Value) {
	// typeInfo is already read, don't read it again