File: sizedbufferpool_test.go

package info (click to toggle)
golang-github-shenwei356-bpool 0.0~git20160710.f9e0ee4-2
  • links: PTS, VCS
  • area: main
  • in suites: bullseye
  • size: 88 kB
  • sloc: makefile: 2
file content (50 lines) | stat: -rw-r--r-- 1,235 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
package bpool

import (
	"bytes"
	"testing"
)

// TestSizedBufferPool checks that over-sized buffers are released and that new
// buffers are created in their place.
func TestSizedBufferPool(t *testing.T) {

	var size int = 4
	var capacity int = 1024

	bufPool := NewSizedBufferPool(size, capacity)

	b := bufPool.Get()

	// Check the cap before we use the buffer.
	if cap(b.Bytes()) != capacity {
		t.Fatalf("buffer capacity incorrect: got %v want %v", cap(b.Bytes()),
			capacity)
	}

	// Grow the buffer beyond our capacity and return it to the pool
	b.Grow(capacity * 3)
	bufPool.Put(b)

	// Add some additional buffers to fill up the pool.
	for i := 0; i < size; i++ {
		bufPool.Put(bytes.NewBuffer(make([]byte, 0, bufPool.a*2)))
	}

	// Check that oversized buffers are being replaced.
	if len(bufPool.c) < size {
		t.Fatalf("buffer pool too small: got %v want %v", len(bufPool.c), size)
	}

	// Close the channel so we can iterate over it.
	close(bufPool.c)

	// Check that there are buffers of the correct capacity in the pool.
	// for buffer := range bufPool.c {
	// 	if cap(buffer.Bytes()) != bufPool.a {
	// 		t.Fatalf("returned buffers wrong capacity: got %v want %v",
	// 			cap(buffer.Bytes()), capacity)
	// 	}
	// }

}