Method writeChunk

go/fory/map.go:196–278

writeChunk writes a chunk of entries with the same key/value types

(ctx *WriteContext, iter *reflect.MapIter, entryKey, entryVal *reflect.Value, resolver *TypeResolver, trackRef bool)

// writeChunk writes a chunk of entries with the same key/value types
func (s mapSerializer) writeChunk(ctx *WriteContext, iter *reflect.MapIter, entryKey, entryVal *reflect.Value, resolver *TypeResolver, trackRef bool) bool {
	buf := ctx.Buffer()
	keyType := (*entryKey).Type()
	valueType := (*entryVal).Type()

	// Reserve space: header (1 byte) + size (1 byte)
	headerOffset := buf.writerIndex
	buf.WriteInt16(-1)

	header := 0
	var keySer, valSer Serializer
	keyWriteRef := s.keyReferencable
	valueWriteRef := s.valueReferencable

	// Determine key serializer and write type info if needed
	if s.hasGenerics && s.keySerializer != nil {
		header |= KEY_DECL_TYPE
		keySer = s.keySerializer
	} else {
		keyTypeInfo, _ := getTypeInfoForValue(*entryKey, resolver)
		resolver.WriteTypeInfo(buf, keyTypeInfo, ctx.Err())
		keySer = keyTypeInfo.Serializer
		keyWriteRef = s.keyReferencable && keyTypeInfo.NeedWriteRef
	}

	// Determine value serializer and write type info if needed
	if s.hasGenerics && s.valueSerializer != nil {
		header |= VALUE_DECL_TYPE
		valSer = s.valueSerializer
	} else {
		valueTypeInfo, _ := getTypeInfoForValue(*entryVal, resolver)
		resolver.WriteTypeInfo(buf, valueTypeInfo, ctx.Err())
		valSer = valueTypeInfo.Serializer
		valueWriteRef = s.valueReferencable && valueTypeInfo.NeedWriteRef
	}

	// Set ref tracking flags
	keyRefMode := RefModeNone
	if keyWriteRef && trackRef {
		header |= TRACKING_KEY_REF
		keyRefMode = RefModeTracking
	}
	valueRefMode := RefModeNone
	if valueWriteRef && trackRef {
		header |= TRACKING_VALUE_REF
		valueRefMode = RefModeTracking
	}

	buf.PutUint8(headerOffset, uint8(header))

	// Write entries with same type
	chunkSize := 0
	for chunkSize < MAX_CHUNK_SIZE {
		k := *entryKey
		v := *entryVal

		// Break if null or type changed
		if !k.IsValid() || !v.IsValid() || k.Type() != keyType || v.Type() != valueType {