bufferpool

package

v1.10.0 Latest Latest Go to latest Published: Oct 22, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Package bufferpool provides a pool of pre-registered RDMA buffers to avoid per-request allocation and registration overhead.

This section is empty.

This section is empty.

This section is empty.

type Pool struct {
	// contains filtered or unexported fields
}

Pool manages a fixed set of RDMA-registered host memory buffers.

func NewPool(server *rdma.Server, bufSize, count int) (*Pool, error)

NewPool pre-allocates and registers count buffers of bufSize bytes each.

func (p *Pool) Acquire(ctx context.Context) (*rdma.Buffer, []byte, error)

Acquire blocks until a buffer is available or ctx is cancelled. Returns the buffer and its backing byte slice.

func (p *Pool) Close()

Close deregisters and frees all buffers. The pool must not be used afterward.

func (p *Pool) Release(buf *rdma.Buffer)

Release returns a buffer to the pool.