mirror of
https://github.com/hanzo-ds/native.git
synced 2026-10-30 20:00:34 +00:00
zeekay
765c3d0aa1
Module path, package names, and identifiers de-branded to native/proto/compress/ pool/tracing. Server wire-protocol strings preserved. Vendored codec surface used by hanzo-ds/go (proto + compress).
46 lines
1.0 KiB
Go
46 lines
1.0 KiB
Go
//go:build !(amd64 || arm64 || riscv64) || purego
|
|
|
|
package proto
|
|
|
|
import (
|
|
"github.com/go-faster/errors"
|
|
"github.com/segmentio/asm/bswap"
|
|
)
|
|
|
|
func (c *ColUUID) DecodeColumn(r *Reader, rows int) error {
|
|
const size = 16
|
|
data, err := r.ReadRaw(rows * size)
|
|
if err != nil {
|
|
return errors.Wrap(err, "read")
|
|
}
|
|
v := *c
|
|
bswap.Swap64(data) // BE <-> LE
|
|
for i := 0; i < len(data); i += size {
|
|
// In-place conversion from slice to array.
|
|
// https://go.dev/ref/spec#Conversions_from_slice_to_array_pointer
|
|
v = append(v, *(*[size]byte)(data[i : i+size]))
|
|
}
|
|
*c = v
|
|
return nil
|
|
}
|
|
|
|
func (c ColUUID) EncodeColumn(b *Buffer) {
|
|
const size = 16
|
|
offset := len(b.Buf)
|
|
b.Buf = append(b.Buf, make([]byte, size*len(c))...)
|
|
for _, v := range c {
|
|
copy(b.Buf[offset:offset+size], v[:])
|
|
offset += size
|
|
}
|
|
bswap.Swap64(b.Buf) // BE <-> LE
|
|
}
|
|
|
|
// WriteColumn encodes ColUUID rows to *Writer.
|
|
func (c ColUUID) WriteColumn(w *Writer) {
|
|
if len(c) == 0 {
|
|
return
|
|
}
|
|
// Can't write UUID as-is: bswap is required.
|
|
w.ChainBuffer(c.EncodeColumn)
|
|
}
|