Function writeMapInt64Int64

go/fory/map_primitive.go:647–682

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

(buf *ByteBuffer, m map[int64]int64, hasGenerics bool)

// 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
func writeMapInt64Int64(buf *ByteBuffer, m map[int64]int64, hasGenerics bool) {
	length := len(m)
	buf.WriteVarUint32(uint32(length))
	if length == 0 {
		return
	}

	remaining := length
	for remaining > 0 {
		chunkSize := remaining
		if chunkSize > MAX_CHUNK_SIZE {
			chunkSize = MAX_CHUNK_SIZE
		}

		if hasGenerics {
			buf.WriteUint8(KEY_DECL_TYPE | VALUE_DECL_TYPE)
			buf.WriteUint8(uint8(chunkSize))
		} else {
			buf.WriteUint8(0)
			buf.WriteUint8(uint8(chunkSize))
			buf.WriteUint8(uint8(VARINT64)) // key type
			buf.WriteUint8(uint8(VARINT64)) // value type
		}

		count := 0
		for k, v := range m {
			buf.WriteVarint64(k)
			buf.WriteVarint64(v)
			count++
			if count >= chunkSize {
				break
			}
		}
		remaining -= chunkSize
	}
}

// readMapInt64Int64 reads map[int64]int64 using chunk protocol
func readMapInt64Int64(ctx *ReadContext) map[int64]int64 {