Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 205 for poolId (0.27 sec)

  1. .github/workflows/mint/minio-pools.yaml

    Harshavardhana <******@****.***> 1699046298 -0700
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Nov 03 21:18:18 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

             */
            public JvmObj() {
                // Default constructor
            }
    
            /** JVM memory statistics */
            public JvmMemoryObj memory;
            /** JVM buffer pool statistics */
            public JvmPoolObj[] pools;
            /** JVM garbage collection statistics */
            public JvmGcObj[] gc;
            /** JVM thread statistics */
            public JvmThreadsObj threads;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  3. cmd/endpoint-ellipses.go

    	setDriveCount uint64
    }
    
    // buildDisksLayoutFromConfFile supports with and without ellipses transparently.
    func buildDisksLayoutFromConfFile(pools []poolArgs) (layout disksLayout, err error) {
    	if len(pools) == 0 {
    		return layout, errInvalidArgument
    	}
    
    	for _, list := range pools {
    		var endpointsList endpointsList
    
    		for _, arg := range list.args {
    			switch {
    			case ellipses.HasList(arg):
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  4. cmd/background-newdisks-heal-ops.go

    	locker := z.NewNSLock(minioMetaBucket, fmt.Sprintf("new-drive-healing/%d/%d", poolIdx, setIdx))
    	lkctx, err := locker.GetLock(ctx, newDiskHealingTimeout)
    	if err != nil {
    		return fmt.Errorf("Healing of drive '%v' on %s pool, belonging to %s erasure set already in progress: %w",
    			disk, humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1), err)
    	}
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

        // If we raced another call connecting to this host, coalesce the connections. This makes for
        // 3 different lookups in the connection pool!
        val pooled3 = routePlanner.planReusePooledConnection(this, routes)
        if (pooled3 != null) return pooled3.connection
    
        connection.withLock {
          connectionPool.put(connection)
          user.acquireConnectionNoEvents(connection)
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/SmbTransportPool.java

                boolean exclusive, boolean forceSigning);
    
        /**
         * Removes a transport from the pool.
         *
         * @param trans the transport to remove
         */
        void removeTransport(SmbTransport trans);
    
        /**
         * Closes the pool and all connections in it
         *
         * @return whether any transport was still in use
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  7. cmd/globals.go

    	// diskFillFraction is the fraction of a disk we allow to be filled.
    	diskFillFraction = 0.99
    
    	// diskReserveFraction is the fraction of a disk where we will fill other server pools first.
    	// If all pools reach this, we will use all pools with regular placement.
    	diskReserveFraction = 0.15
    
    	// diskAssumeUnknownSize is the size to assume when an unknown size upload is requested.
    	diskAssumeUnknownSize = 1 << 30
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  8. docs/features/calls.md

    ## Retrying Requests
    
    Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available.
    
    ## [Calls](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-call/)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test causes two connections to become available simultaneously, one from a TCP connect and
       * one from the pool. We must take the pooled connection because by taking it from the pool, we've
       * fully acquired it.
       *
       * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In
       * particular, we set up this sequence of events:
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. docs/smb3-features/05-rdma-smb-direct-design.md

        }
        
        public void releaseBuffer(ByteBuffer buffer) {
            // For direct buffers, we rely on GC
            // Could implement a more sophisticated buffer pool here
        }
        
        public void cleanup() {
            // Clean up all pooled regions
            RdmaMemoryRegion region;
            
            while ((region = availableSendRegions.poll()) != null) {
                region.close();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
Back to top