Method Read

go/fory/pointer.go:157–208

(ctx *ReadContext, refMode RefMode, readType bool, hasGenerics bool, value reflect.Value)

}

func (s *ptrToValueSerializer) Read(ctx *ReadContext, refMode RefMode, readType bool, hasGenerics bool, value reflect.Value) {
	buf := ctx.Buffer()
	ctxErr := ctx.Err()
	switch refMode {
	case RefModeTracking:
		refID, refErr := ctx.RefResolver().TryPreserveRefId(buf)
		if refErr != nil {
			ctx.SetError(FromError(refErr))
			return
		}
		if refID < int32(NotNullValueFlag) {
			// Reference found
			obj := ctx.RefResolver().GetReadObject(refID)
			if obj.IsValid() {
				value.Set(obj)
			}
			return
		}
	case RefModeNullOnly:
		flag := buf.ReadInt8(ctxErr)
		if flag == NullFlag {
			return
		}
	case RefModeNone:
		// For RefModeNone with nullable=false, no null flag was written.
		// Just continue to read the value data directly.
	}
	if readType {
		// Read type info - in compatible mode this contains the serializer with fieldDefs
		typeID := uint32(buf.ReadUint8(ctxErr))
		if ctx.HasError() {
			return
		}
		internalTypeID := TypeId(typeID)
		// Check if this is a struct type that needs type meta reading
		if IsNamespacedType(internalTypeID) || internalTypeID == COMPATIBLE_STRUCT || internalTypeID == STRUCT {
			typeInfo := ctx.TypeResolver().readTypeInfoWithTypeID(buf, typeID, ctxErr)
			// Use the serializer from TypeInfo which has the remote field definitions
			if structSer, ok := typeInfo.Serializer.(*structSerializer); ok && len(structSer.fieldDefs) > 0 {
				// Allocate the pointer value if needed
				if value.IsNil() {
					value.Set(reflect.New(value.Type().Elem()))
				}
				ctx.RefResolver().Reference(value)
				structSer.ReadData(ctx, value.Elem())
				return
			}
		}
	}

	s.ReadData(ctx, value)
}

func (s *ptrToValueSerializer) ReadWithTypeInfo(ctx *ReadContext, refMode RefMode, typeInfo *TypeInfo, value reflect.Value) {
	s.Read(ctx, refMode, false, false, value)