Method readChunk

go/fory/map.go:476–569

readChunk reads a chunk of entries, returns remaining size

(ctx *ReadContext, mapVal reflect.Value, header uint8, size int, keyType, valueType reflect.Type, resolver *TypeResolver)

// readChunk reads a chunk of entries, returns remaining size
func (s mapSerializer) readChunk(ctx *ReadContext, mapVal reflect.Value, header uint8, size int, keyType, valueType reflect.Type, resolver *TypeResolver) int {
	buf := ctx.Buffer()
	ctxErr := ctx.Err()

	// IMPORTANT: map readers must follow the key/value ref bits written on the
	// wire, even when local field metadata would choose a different ref policy.
	// Shared xlang tests depend on reading remote-written ref metadata first and
	// only then writing a new local payload. DO NOT REMOVE this comment.
	trackKeyRef := (header & TRACKING_KEY_REF) != 0
	trackValRef := (header & TRACKING_VALUE_REF) != 0
	keyDeclType := (header & KEY_DECL_TYPE) != 0
	valDeclType := (header & VALUE_DECL_TYPE) != 0
	declaredKeyType := keyType
	declaredValueType := valueType

	chunkSize := int(buf.ReadUint8(ctxErr))
	if ctx.HasError() {
		return 0
	}
	if chunkSize == 0 || chunkSize > size {
		ctx.SetError(DeserializationErrorf("invalid map chunk size %d for remaining length %d", chunkSize, size))
		return 0
	}

	// Read type info if not declared
	var keyTypeInfo, valueTypeInfo *TypeInfo
	var keySer, valSer Serializer

	if !keyDeclType {
		keyTypeInfo = resolver.ReadTypeInfo(buf, ctxErr)
		if ctxErr.HasError() {
			return 0
		}
		keySer = keyTypeInfo.Serializer
		keyType = keyTypeInfo.Type
		keyType, keySer = wrapMapSerializerIfNeeded(declaredKeyType, keyType, keySer)
	} else {
		keySer = s.keySerializer
		if keySer == nil {
			keySer, _ = resolver.getSerializerByType(keyType, false)
		}
	}

	if !valDeclType {
		valueTypeInfo = resolver.ReadTypeInfo(buf, ctxErr)
		if ctxErr.HasError() {
			return 0
		}
		valSer = valueTypeInfo.Serializer
		valueType = valueTypeInfo.Type
		valueType, valSer = wrapMapSerializerIfNeeded(declaredValueType, valueType, valSer)
	} else {
		valSer = s.valueSerializer
		if valSer == nil {
			valSer, _ = resolver.getSerializerByType(valueType, false)
		}
	}