mdb/kvstore/globals.go

package kvstore

import (
	"sync"
	"time"
)

var (
	connTimeout  = 16 * time.Second
	pollInterval = 500 * time.Millisecond
	modQSize     = 1024
	poolBufSize  = 8192
	bufferPool   = sync.Pool{
		New: func() any {
			return make([]byte, poolBufSize)
		},
	}
)

func GetDataBuf(size int) []byte {
	if size > poolBufSize {
		return make([]byte, size)
	}
	return bufferPool.Get().([]byte)[:size]
}

func RecycleDataBuf(b []byte) {
	if cap(b) != poolBufSize {
		return
	}
	bufferPool.Put(b)
}