Function readMapIntInt

go/fory/map_primitive.go:770–813

readMapIntInt reads map[int]int using chunk protocol

(ctx *ReadContext)

// readMapIntInt reads map[int]int using chunk protocol
func readMapIntInt(ctx *ReadContext) map[int]int {
	err := ctx.Err()
	buf := ctx.Buffer()
	size, ok := readTypedMapSize(ctx)
	result := make(map[int]int)
	if !ok {
		return result
	}
	result = make(map[int]int, 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(VARINT64) {
				return result
			}
		}
		if (chunkHeader & VALUE_DECL_TYPE) == 0 {
			if !ctx.readExpectedTypeID(VARINT64) {
				return result
			}
		}
		for i := 0; i < chunkSize; i++ {
			k := buf.ReadVarint64(err)
			v := buf.ReadVarint64(err)
			result[int(k)] = int(v)
			size--
		}
	}
	return result
}

// ============================================================================
// Dedicated map serializers