- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for poolIdx (2.14 sec)
-
cmd/admin-server-info.go
} poolNumbers := make(map[int]struct{}) network := make(map[string]string) for _, ep := range endpointServerPools { for _, endpoint := range ep.Endpoints { if endpoint.IsLocal { poolNumbers[endpoint.PoolIdx+1] = struct{}{} } nodeName := endpoint.Host if nodeName == "" { nodeName = addr } if endpoint.IsLocal { // Only proceed for local endpoints network[nodeName] = string(madmin.ItemOnline)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (1) -
cmd/storage-interface.go
WriteAll(ctx context.Context, volume string, path string, b []byte) (err error) // Read all. ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) GetDiskLoc() (poolIdx, setIdx, diskIdx int) // Retrieve location indexes.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 5.3K bytes - Viewed (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,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 14 07:25:56 UTC 2024 - 4.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactory.java
} if (componentName == null) { throw new IllegalStateException( "componentName is not set. Please specify a valid component name for the pooled object factory."); } if (logger.isDebugEnabled()) { logger.debug("Creating new pooled object for component: {}", componentName); }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 6.6K bytes - Viewed (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>Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Mon Sep 29 14:45:25 UTC 2025 - 4.3K bytes - Viewed (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) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.7K bytes - Viewed (0) -
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. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 4.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
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(); } }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 5.3K bytes - Viewed (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.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 6.4K bytes - Viewed (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(); } ```
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 7.7K bytes - Viewed (0)