- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewBytePoolCap (0.1 sec)
-
internal/bpool/bpool.go
// BytePoolCap implements a leaky pool of []byte in the form of a bounded channel. type BytePoolCap struct { c chan []byte w int wcap int } // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new // byte arrays sized based on width. func NewBytePoolCap(maxSize uint64, width int, capwidth int) (bp *BytePoolCap) { if capwidth <= 0 { panic("total buffer capacity must be provided") } if capwidth < 64 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 3K bytes - Viewed (0) -
internal/bpool/bpool_test.go
package bpool import ( "testing" ) // Tests - bytePool functionality. func TestBytePool(t *testing.T) { size := uint64(4) width := 1024 capWidth := 2048 bp := NewBytePoolCap(size, width, capWidth) // Check the width if bp.Width() != width { t.Fatalf("bytepool width invalid: got %v want %v", bp.Width(), width) } // Check with width cap if bp.WidthCap() != capWidth {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 2.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} // Initialize byte pool once for all sets, bpool size is set to // setCount * setDriveCount with each memory upto blockSizeV2. buffers := bpool.NewBytePoolCap(n, blockSizeV2, blockSizeV2*2) if n >= 16384 { // pre-populate buffers only n >= 16384 which is (32Gi/2Mi) // for all setups smaller than this avoid pre-alloc. buffers.Populate() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0)