Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewBytePoolCap (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top