diff options
author | Kali Kaneko (leap communications) <kali@leap.se> | 2019-01-12 18:39:45 +0100 |
---|---|---|
committer | Ruben Pollan <meskio@sindominio.net> | 2019-01-17 12:30:32 +0100 |
commit | b1247d2d0d51108c910a73891ff3116e5f032ab1 (patch) | |
tree | e9948964f0bfb1ad2df3bc7bad02aa1f41ccfbd8 /vendor/github.com/oxtoacart/bpool/bufferpool_test.go | |
parent | efcb8312e31b5c2261b1a1e95ace55b322cfcc27 (diff) |
[pkg] all your deps are vendored to us
Diffstat (limited to 'vendor/github.com/oxtoacart/bpool/bufferpool_test.go')
-rw-r--r-- | vendor/github.com/oxtoacart/bpool/bufferpool_test.go | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/vendor/github.com/oxtoacart/bpool/bufferpool_test.go b/vendor/github.com/oxtoacart/bpool/bufferpool_test.go new file mode 100644 index 0000000..b344bdc --- /dev/null +++ b/vendor/github.com/oxtoacart/bpool/bufferpool_test.go @@ -0,0 +1,30 @@ +package bpool + +import ( + "bytes" + "testing" +) + +func TestBufferPool(t *testing.T) { + var size int = 4 + + bufPool := NewBufferPool(size) + + // Test Get/Put + b := bufPool.Get() + bufPool.Put(b) + + // Add some additional buffers beyond the pool size. + for i := 0; i < size*2; i++ { + bufPool.Put(bytes.NewBuffer([]byte{})) + } + + // Close the channel so we can iterate over it. + close(bufPool.c) + + // Check the size of the pool. + if len(bufPool.c) != size { + t.Fatalf("bufferpool size invalid: got %v want %v", len(bufPool.c), size) + } + +} |