Method TestBufferPool_Clears

internal/mem/buffer_pool_ext_test.go:37–118

(t *testing.T)

}

func (s) TestBufferPool_Clears(t *testing.T) {
	poolConfigs := []struct {
		name        string
		factory     func() (*mem.BinaryTieredBufferPool, error)
		wantCleared bool
		bufferSize  int
	}{
		{
			name: "regular_sized",
			factory: func() (*mem.BinaryTieredBufferPool, error) {
				return mem.NewBinaryTieredBufferPool(3) // 8 bytes
			},
			bufferSize:  8,
			wantCleared: true,
		},
		{
			name: "regular_fallback",
			factory: func() (*mem.BinaryTieredBufferPool, error) {
				return mem.NewBinaryTieredBufferPool(3)
			},
			bufferSize:  10,
			wantCleared: true,
		},
		{
			name: "dirty_sized",
			factory: func() (*mem.BinaryTieredBufferPool, error) {
				return mem.NewDirtyBinaryTieredBufferPool(3)
			},
			bufferSize:  8,
			wantCleared: false,
		},
		{
			name: "dirty_fallback",
			factory: func() (*mem.BinaryTieredBufferPool, error) {
				return mem.NewDirtyBinaryTieredBufferPool(3)
			},
			bufferSize:  10,
			wantCleared: false,
		},
	}

	for _, tc := range poolConfigs {
		t.Run(tc.name, func(t *testing.T) {
			pool, err := tc.factory()
			if err != nil {
				t.Fatalf("Failed to create pool: %v", err)
			}

			for {
				buf1 := pool.Get(tc.bufferSize)
				// Mark the buffer with data.
				for i := range *buf1 {
					(*buf1)[i] = 0xAA
				}
				pool.Put(buf1)

				buf2 := pool.Get(tc.bufferSize)
				// Check if we got the same underlying array.