- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 62 for poolIdx (0.06 seconds)
-
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 peersCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
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) -
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) -
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-pooledCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 19.2K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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)