Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 327 for pool (0.01 sec)

  1. schema/pool.go

    package schema
    
    import (
    	"reflect"
    	"sync"
    )
    
    // sync pools
    var (
    	normalPool      sync.Map
    	poolInitializer = func(reflectType reflect.Type) FieldNewValuePool {
    		v, _ := normalPool.LoadOrStore(reflectType, &sync.Pool{
    			New: func() interface{} {
    				return reflect.New(reflectType).Interface()
    			},
    		})
    		return v.(FieldNewValuePool)
    	}
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Apr 11 13:37:44 UTC 2022
    - 345 bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_test.go

    	for i, pool := range nmeta2.Pools {
    		if i == 0 {
    			nmeta2.Pools[i] = PoolStatus{
    				CmdLine:    pool.CmdLine,
    				ID:         i,
    				LastUpdate: UTCNow(),
    				Decommission: &PoolDecommissionInfo{
    					Complete: false,
    				},
    			}
    		}
    	}
    
    	testCases := []struct {
    		meta           poolMeta
    		pools          []*erasureSets
    		expectedUpdate bool
    		expectedErr    bool
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  3. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	zipFile, err := os.Create("format.json.zip")
    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/InternersTest.java

        String not = new String("a");
    
        Interner<String> pool = Interners.newStrongInterner();
        assertSame(canonical, pool.intern(canonical));
        assertSame(canonical, pool.intern(not));
      }
    
      public void testStrong_null() {
        Interner<String> pool = Interners.newStrongInterner();
        assertThrows(NullPointerException.class, () -> pool.intern(null));
      }
    
      public void testStrong_builder() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. docs/distributed/DECOMMISSION.md

    # Decommissioning
    
    Decommissiong is a mechanism in MinIO to drain older pools (usually with old hardware) and migrate the content from such pools to a newer pools (usually better hardware). Decommissioning spreads the data across all pools - for example, if you decommission `pool1`, all the data from `pool1` spreads across `pool2` and `pool3`.
    
    ## Features
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jul 11 14:59:49 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/InternersTest.java

        String not = new String("a");
    
        Interner<String> pool = Interners.newStrongInterner();
        assertSame(canonical, pool.intern(canonical));
        assertSame(canonical, pool.intern(not));
      }
    
      public void testStrong_null() {
        Interner<String> pool = Interners.newStrongInterner();
        assertThrows(NullPointerException.class, () -> pool.intern(null));
      }
    
      public void testStrong_builder() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-erasure-set.go

    	erasureSetOnlineDrivesCountMD = NewGaugeMD(erasureSetOnlineDrivesCount,
    		"Count of online drives in the erasure set in a pool", poolIDL, setIDL)
    	erasureSetHealingDrivesCountMD = NewGaugeMD(erasureSetHealingDrivesCount,
    		"Count of healing drives in the erasure set in a pool", poolIDL, setIDL)
    	erasureSetHealthMD = NewGaugeMD(erasureSetHealth,
    		"Health of the erasure set in a pool (1=healthy, 0=unhealthy)",
    		poolIDL, setIDL)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. docs/distributed/CONFIG.md

    `v1` format
    ```yaml
    pools: # Specify the nodes and drives with pools
      -
        - "https://server-example-pool1:9000/mnt/disk{1...4}/"
        - "https://server{1...2}-pool1:9000/mnt/disk{1...4}/"
        - "https://server3-pool1:9000/mnt/disk{1...4}/"
        - "https://server4-pool1:9000/mnt/disk{1...4}/"
    ```
    
    to `v2` format
    
    ```yaml
    pools:
      - args:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jun 25 02:30:18 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. docs/contribute/concurrency.md

    ## Connection Pool
    
    A primary responsibility for any HTTP client is to efficiently manage network connections. Creating and establishing new connections require a fair amount of overhead and added latency. OkHttp will make every effort to reuse existing connections to avoid this overhead and added latency.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

            this.totalAllocated = new AtomicLong();
            this.totalReleased = new AtomicLong();
    
            // Pre-allocate buffer pool
            initializeBufferPool();
        }
    
        /**
         * Initialize the buffer pool with pre-allocated regions
         */
        private void initializeBufferPool() {
            // Allocate send buffers
            for (int i = 0; i < initialSendBuffers; i++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
Back to top