cost-model/core/pkg/util/bufferpool.go

package util

import (
	"math"
	"math/bits"
	"sync"
)

// bufferPool holds "tiered" []byte `sync.Pool` instances by capacity up to math.MaxUint16
type bufferPool struct {
	pools [17]sync.Pool
}

func newBufferPool() *bufferPool {
	bp := new(bufferPool)

	for i := 0; i < 17; i++ {
		length := 1 << i
		bp.pools[i].New = func() any {
			return make([]byte, length)
		}
	}
	return bp
}

// poolIndex returns the pool index for a buffer of the given size.
func poolIndex(length int) int {
	return bits.Len32(uint32(length - 1))
}

// putIndex returns the pool index for returning a buffer with the given capacity.
// It is the inverse of poolIndex: given a capacity that was originally handed out
// by Get, it finds the pool that owns it.
//
// Because Get always returns buffers with capacity 1<<i, the capacity here will
// always be a power of two. bits.Len32(1<<i) = i+1, so we subtract 1 to recover i.
func putIndex(capacity int) int {
	return bits.Len32(uint32(capacity)) - 1
}

func isPowerOfTwo(capacity int) bool {
	return capacity&(capacity-1) == 0
}

func (bp *bufferPool) Get(length int) []byte {
	if length <= 0 {
		return nil
	}

	// Beyond our pool range: allocate directly
	if length > math.MaxUint16 {
		return make([]byte, length)
	}

	i := poolIndex(length)
	buf := bp.pools[i].Get().([]byte)
	return buf[:length]
}

func (bp *bufferPool) Put(buf []byte) {
	capacity := cap(buf)
	if capacity == 0 || capacity > math.MaxUint16 || !isPowerOfTwo(capacity) {
		return
	}

	i := putIndex(capacity)
	bp.pools[i].Put(buf[:cap(buf)])
}