Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for poolIdx (2.14 sec)

  1. 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)
  2. 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)
  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,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. 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)
  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>
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Mon Sep 29 14:45:25 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  6. 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)
  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.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  8. 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)
  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.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (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();
    }
    ```
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
Back to top