Function readMapInt32Int32

go/fory/map_primitive.go:600–643

readMapInt32Int32 reads map[int32]int32 using chunk protocol

(ctx *ReadContext)

// readMapInt32Int32 reads map[int32]int32 using chunk protocol
func readMapInt32Int32(ctx *ReadContext) map[int32]int32 {
	err := ctx.Err()
	buf := ctx.Buffer()
	size, ok := readTypedMapSize(ctx)
	result := make(map[int32]int32)
	if !ok {
		return result
	}
	result = make(map[int32]int32, size)

	for size > 0 {
		chunkHeader := buf.ReadUint8(err)
		if chunkHeader&(TRACKING_KEY_REF|KEY_HAS_NULL|TRACKING_VALUE_REF|VALUE_HAS_NULL) != 0 {
			ctx.SetError(DeserializationError("typed map reader does not support ref/null chunks"))
			return result
		}

		chunkSize := int(buf.ReadUint8(err))
		if ctx.HasError() {
			return result
		}
		if chunkSize == 0 || chunkSize > size {
			ctx.SetError(DeserializationErrorf("invalid map chunk size %d for remaining length %d", chunkSize, size))
			return result
		}
		if (chunkHeader & KEY_DECL_TYPE) == 0 {
			if !ctx.readExpectedTypeID(VARINT32) {
				return result
			}
		}
		if (chunkHeader & VALUE_DECL_TYPE) == 0 {
			if !ctx.readExpectedTypeID(VARINT32) {
				return result
			}
		}
		for i := 0; i < chunkSize; i++ {
			k := buf.ReadVarint32(err)
			v := buf.ReadVarint32(err)
			result[k] = v
			size--
		}
	}
	return result
}

// writeMapInt64Int64 writes map[int64]int64 using chunk protocol
// When hasGenerics=true, element types are known so we set DECL_TYPE flags and skip type info