Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,147 for pool (0.02 sec)

  1. cmd/erasure-server-pool-rebalance_gen_test.go

    Klaus Post <******@****.***> 1759093161 +0200
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 11K bytes
    - Viewed (0)
  2. cmd/admin-handlers-pools.go

    		return
    	}
    
    	vars := mux.Vars(r)
    	v := vars["pool"]
    	byID := vars["by-id"] == "true"
    
    	pools := strings.Split(v, ",")
    	poolIndices := make([]int, 0, len(pools))
    
    	for _, pool := range pools {
    		var idx int
    		if byID {
    			var err error
    			idx, err = strconv.Atoi(pool)
    			if err != nil {
    				// We didn't find any matching pools, invalid input
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  3. internal/bpool/bpool.go

    		// someone tried to put back buffer which is not part of this buffer pool
    		// we simply don't put this back into pool, a modified buffer provided
    		// by this package is no more usable, callers make sure to not modify
    		// the capacity of the buffer.
    		return
    	}
    
    	select {
    	case bp.c <- b[:bp.w]:
    		// buffer went back into pool
    	default:
    		// buffer didn't go back into pool, just discard
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3K bytes
    - Viewed (0)
  4. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 25 02:30:18 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  6. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  7. 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: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  8. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        // Running at time 75, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(75L)).isEqualTo(75L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Running at time 149, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(149L)).isEqualTo(1L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
Back to top