- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 15 for poolIdx (0.04 seconds)
-
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)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 4.9K bytes - Click Count (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.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 5.3K 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 Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 14 07:25:56 GMT 2024 - 4.4K bytes - Click Count (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); }Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 6.6K 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 Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Sep 29 14:45:25 GMT 2025 - 4.3K bytes - Click Count (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. *
Created: Fri Dec 26 11:42:13 GMT 2025 - 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: Sat Dec 20 13:44:44 GMT 2025 - 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 Dec 26 11:42:13 GMT 2025 - 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 Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Click Count (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(); } }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 5.3K bytes - Click Count (0)