Method ReadMetaStringBytes

go/fory/meta_string_resolver.go:123–235

ReadMetaStringBytes reads a string from buffer, handling dynamic references

(buf *ByteBuffer, ctxErr *Error)

// ReadMetaStringBytes reads a string from buffer, handling dynamic references
func (r *MetaStringResolver) ReadMetaStringBytes(buf *ByteBuffer, ctxErr *Error) (*MetaStringBytes, error) {
	// ReadData header containing length/reference info (uses VarUint32Small7 to match Java)
	header := buf.ReadVarUint32Small7(ctxErr)
	if ctxErr.HasError() {
		return nil, *ctxErr
	}

	lengthValue := header >> 1
	if header&1 != 0 {
		if lengthValue == 0 || uint64(lengthValue) > uint64(MaxInt) {
			return nil, fmt.Errorf("invalid dynamic index: %d", lengthValue)
		}
		index := int(lengthValue) - 1
		if index < 0 || index >= len(r.dynamicIDToEnumString) {
			return nil, fmt.Errorf("invalid dynamic index: %d", index)
		}
		return r.dynamicIDToEnumString[index], nil
	}
	if lengthValue > uint32(MaxInt16) {
		return nil, fmt.Errorf("meta string length %d exceeds maximum supported length %d", lengthValue, MaxInt16)
	}
	length := int(lengthValue)

	var (
		hashcode int64
		key      smallMetaStringKey
		data     []byte
		encoding meta.Encoding
	)

	// Small string optimization
	if length <= SmallStringThreshold {
		if length == 0 {
			r.dynamicIDToEnumString = append(r.dynamicIDToEnumString, emptyMetaStringBytes)
			return emptyMetaStringBytes, nil
		}
		encByte := buf.ReadByte(ctxErr)
		var encErr error
		encoding, encErr = meta.EncodingFromByte(encByte)
		if encErr != nil {
			return nil, encErr
		}

		if !buf.CheckReadable(length, ctxErr) {
			return nil, *ctxErr
		}
		data = make([]byte, length)
		_, err := buf.Read(data)
		if err != nil {
			return nil, err
		}

		words := smallMetaStringWords(data)
		key = smallMetaStringKey{
			v1:         words[0],
			v2:         words[1],
			compactKey: byte(((length - 1) << smallMetaStringEncodingBits) | int(encoding)),
		}