Function readMapInt64Int64

go/fory/map_primitive.go:685–728

readMapInt64Int64 reads map[int64]int64 using chunk protocol

(ctx *ReadContext)

// readMapInt64Int64 reads map[int64]int64 using chunk protocol
func readMapInt64Int64(ctx *ReadContext) map[int64]int64 {
	err := ctx.Err()
	buf := ctx.Buffer()
	size, ok := readTypedMapSize(ctx)
	result := make(map[int64]int64)
	if !ok {
		return result
	}
	result = make(map[int64]int64, 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[k] = v
			size--
		}
	}
	return result
}

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