- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 205 for poolId (0.27 sec)
-
.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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)