Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 62 for poolIdx (0.15 seconds)

  1. cmd/notification.go

    			if offlineHost == "" && ep.IsLocal || offlineHost == ep.Host {
    				offlineDisks = append(offlineDisks, madmin.Disk{
    					Endpoint:  ep.String(),
    					State:     string(madmin.ItemOffline),
    					PoolIndex: ep.PoolIdx,
    					SetIndex:  ep.SetIdx,
    					DiskIndex: ep.DiskIdx,
    				})
    			}
    		}
    	}
    	return offlineDisks
    }
    
    // StorageInfo returns disk information across all peers
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
        // Attempt to get a connection from the pool.
        val pooled1 = planReusePooledConnection()
        if (pooled1 != null) return pooled1
    
        // Attempt a deferred plan before new routes.
        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
    
        // Do blocking calls to plan a route for a new connection.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  3. cmd/metrics-v3-cluster-erasure-set.go

    		"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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 14 07:25:56 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/SmbTransportPoolImplTest.java

        @DisplayName("Should distinguish between pooled and non-pooled connections")
        void testPooledVsNonPooledConnections() {
            // When: Create pooled and non-pooled connections
            SmbTransportImpl pooled = pool.getSmbTransport(ctx, address, 445, false);
            SmbTransportImpl nonPooled = pool.getSmbTransport(ctx, address, 445, true);
    
            // Then: Pool should track pooled but not non-pooled
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 19.2K bytes
    - Click Count (0)
  5. api/maven-api-model/src/main/java/org/apache/maven/api/model/ModelObjectProcessor.java

        /**
         * Process a model object, potentially returning a pooled or optimized version.
         *
         * <p>This method is called during model building for various model objects.
         * Implementations can:</p>
         * <ul>
         *   <li>Return the same object if no processing is desired</li>
         *   <li>Return a pooled equivalent object to reduce memory usage</li>
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  6. 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)
          call.acquireConnectionNoEvents(connection)
        }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *     list of available routes.
     *
     * If the pool gains an eligible connection while DNS, TCP, or TLS work is in flight, this finder
     * will prefer pooled connections. Only pooled HTTP/2 connections are used for such de-duplication.
     *
     * It is possible to cancel the finding process by canceling its call.
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:58:02 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

            // Could implement a more sophisticated buffer pool here
        }
    
        /**
         * Clean up all pooled regions
         *
         * This method should be called when shutting down to
         * release all resources.
         */
        public void cleanup() {
            // Clean up all pooled regions
            RdmaMemoryRegion region;
    
            while ((region = availableSendRegions.poll()) != null) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  9. docs/changelogs/changelog_1x.md

     * Fix: Support the `PATCH` method.
     * Fix: Support request bodies on `DELETE` method.
     * Fix: Drop the `okhttp-protocols` module.
     * Internal: Replaced internal byte array buffers with pooled buffers ("OkBuffer").
    
    
    ## Version 1.3.0
    
    _2014-01-11_
    
     * New: Support for "PATCH" HTTP method in client and MockWebServer.
     * Fix: Drop `Content-Length` header when redirected from POST to GET.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 6.4K bytes
    - Click Count (0)
  10. docs/features/events.md

    System.out.println("REQUEST 1 (new connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
    
    System.out.println("REQUEST 2 (pooled connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
    ```
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 7.7K bytes
    - Click Count (0)
Back to Top