Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 259 for poolId (0.04 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt

     *
     * Typically instances of this class are created, connected and exercised automatically by the HTTP
     * client. Applications may use this class to monitor HTTP connections as members of a
     * [connection pool][ConnectionPool].
     *
     * Do not confuse this class with the misnamed `HttpURLConnection`, which isn't so much a connection
     * as a single request/response exchange.
     *
     * ## Modern TLS
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  2. cmd/endpoint-ellipses_test.go

    			if err != nil && testCase.success {
    				t.Fatalf("Test %d: unexpected error: %v", i+1, err)
    			}
    			_, _, err = createServerEndpoints(testCase.serverAddr, srvCtxt.Layout.pools, srvCtxt.Layout.legacy)
    			if err != nil && testCase.success {
    				t.Errorf("Test %d: Expected success but failed instead %s", i+1, err)
    			}
    			if err == nil && !testCase.success {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  3. internal/s3select/select.go

    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = bpool.Pool[*bytes.Buffer]{
    	New: func() *bytes.Buffer {
    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = bpool.Pool[*bufio.Writer]{
    	New: func() *bufio.Writer {
    		// io.Discard is just used to create the writer. Actual destination
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  4. cmd/testdata/undeleteable-object.tgz

    š½0® îÊr ­f¬ \à¾×ég—! sÑ'ˆ3wi øÈ ëƒ:×ÖÛW,jŒ…,c'œ‰iä Ÿ %…2͚Ƨ» 1ì-Îe XϤ­âù ×Àw \ƃá (ELð15ûüètvë½ç;Ê’×ëŠ0Ñëºh "R ç(j?xÚ´ÄSvM¢ oÓj®:ëtÆé´D±¡±y ?=bœ³~5ï0ËDeí:ˆŠ÷'ºv?dÚ•ÊY>¼³Ÿ÷…^] &_Êï Î u²À 0Ÿ Ÿ‡qXF½Î%‹ %Ë multisitea/data/disterasure/xl3/.minio.sys/pool.bin/xl.meta XL2 Æ w Ä$•Ä Ó ÉŸþ¥¹ °Ä ºHØH Å Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ 5 A·DoCÁ§slÂ0RÿŦEcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘kªPartASizes‘k¤Sizek¥MTimeÓ ÉŸþ¥¹ °§MetaSys ¼x-minio-internal-inline-dataÄ...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 26 00:31:12 GMT 2024
    - 8.7M bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

     * This processor supports searching with multiple searchers concurrently and merging their results based on
     * ranking scores to provide more comprehensive and accurate search results.
     *
     * The processor maintains a pool of searchers and an executor service for concurrent operations.
     * It implements rank fusion techniques to combine results from different search engines
     * and provides a unified search interface.
     */
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 27.5K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbFile.java

                    // for scenarios where the same file or directory is accessed multiple times
                    log.trace("Tree handle released to connection pool for reuse");
                    // The connection pool will handle cleanup based on its own timeout settings
                }
            }
    
            // Clear attribute cache only if we're doing strict cleanup
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 103.2K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/QueuesTest.java

            new LinkedBlockingDeque<Object>(),
            new LinkedBlockingDeque<Object>(10),
            new PriorityBlockingQueue<Object>(10, Ordering.arbitrary()));
      }
    
      /*
       * We need to perform operations in a thread pool, even for simple cases, because the queue might
       * be a SynchronousQueue.
       */
      private ExecutorService threadPool;
    
      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  8. docs/es/docs/advanced/events.md

    Esto puede ser muy útil para configurar **recursos** que necesitas usar para toda la app, y que son **compartidos** entre requests, y/o que necesitas **limpiar** después. Por ejemplo, un pool de conexiones a una base de datos, o cargando un modelo de machine learning compartido.
    
    ## Caso de Uso { #use-case }
    
    Empecemos con un ejemplo de **caso de uso** y luego veamos cómo resolverlo con esto.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  9. helm-releases/minio-2.0.1.tgz

    If defined, it must be a sub-directory of the path specified in {{ .Values.mountPath }} ## bucketRoot: "" # Number of drives attached to a node drivesPerNode: 1 # Number of MinIO containers running replicas: 16 # Number of expanded MinIO clusters pools: 1 ## TLS Settings for MinIO tls: enabled: false ## Create a secret with private.key and public.crt files and pass that here. Ref: https://github.com/minio/minio/tree/master/docs/tls/kubernetes#2-create-kubernetes-secret certSecret: "" publicCrt: public.crt...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 31 09:09:09 GMT 2021
    - 13.6K bytes
    - Click Count (0)
  10. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

       * instance. This method is guaranteed to only be called once.
       *
       * <p>By default this returns a new {@link ScheduledExecutorService} with a single thread pool
       * that sets the name of the thread to the {@linkplain #serviceName() service name}. Also, the
       * pool will be {@linkplain ScheduledExecutorService#shutdown() shut down} when the service
       * {@linkplain Service.State#TERMINATED terminates} or {@linkplain Service.State#TERMINATED
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.8K bytes
    - Click Count (0)
Back to Top