Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 198 for spool (0.48 sec)

  1. cmd/globals.go

    	consoleapi "github.com/minio/console/api"
    	"github.com/minio/dnscache"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/bpool"
    	"github.com/minio/minio/internal/bucket/bandwidth"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/config/browser"
    	"github.com/minio/minio/internal/grid"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. internal/bpool/bpool_test.go

    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool cap invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bp.Put(b)
    
    	// Fill the pool beyond the capped pool size.
    	for i := uint64(0); i < size*2; i++ {
    		bp.Put(make([]byte, bp.w, bp.wcap))
    	}
    
    	b = bp.Get()
    	if len(b) != width {
    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    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/batch-handlers.go

    	}
    	jpool.ResizeWorkers(workers)
    
    	randomWait := func() time.Duration {
    		// randomWait depends on the number of nodes to avoid triggering resume and cleanups at the same time.
    		return time.Duration(rand.Float64() * float64(time.Duration(globalEndpoints.NEndpoints())*time.Hour))
    	}
    
    	go func() {
    		jpool.resume(randomWait)
    		jpool.cleanupReports(randomWait)
    	}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen.go

    Harshavardhana <******@****.***> 1656968574 -0700
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 22:09:38 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. docs/metrics/prometheus/alerts.md

        for: 5m
        labels:
          severity: critical
        annotations:
          summary: "Instance {{ $labels.server }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }}"
          description: "MinIO instance {{ $labels.server }} of job {{ $labels.job }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }} for more than 5 minutes."
    ```
    
    ## Verify the configuration and alerts
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 28 20:53:59 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt

     * of which connections to keep open for future use.
     *
     * @constructor Create a new connection pool with tuning parameters appropriate for a single-user
     * application. The tuning parameters in this pool are subject to change in future OkHttp releases.
     * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of
     * inactivity.
     */
    class ConnectionPool internal constructor(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 03 20:39:41 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 22:09:38 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. cmd/metrics-v3-cluster-erasure-set.go

    	erasureSetReadQuorumMD = NewGaugeMD(erasureSetReadQuorum,
    		"Read quorum for the erasure set in a pool", poolIDL, setIDL)
    	erasureSetWriteQuorumMD = NewGaugeMD(erasureSetWriteQuorum,
    		"Write quorum for the erasure set in a pool", poolIDL, setIDL)
    	erasureSetOnlineDrivesCountMD = NewGaugeMD(erasureSetOnlineDrivesCount,
    		"Count of online drives in the erasure set in a pool", poolIDL, setIDL)
    	erasureSetHealingDrivesCountMD = NewGaugeMD(erasureSetHealingDrivesCount,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top