Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 231 for poolId (0.09 sec)

  1. docs/contribute/concurrency.md

     * **Exchange** carries a single HTTP request/response pair.
    
     * **ExchangeFinder** chooses which connection carries each exchange. Where possible it will use the same connection for all exchanges in a single call. It prefers reusing pooled connections over establishing new connections.      
    
    #### Per-Connection Locks
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. fess-crawler/pom.xml

    			<artifactId>commons-net</artifactId>
    			<version>${commons.net.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>org.apache.commons</groupId>
    			<artifactId>commons-pool2</artifactId>
    			<version>${commons.pool2.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>com.google.guava</groupId>
    			<artifactId>guava</artifactId>
    			<version>${guava.version}</version>
    		</dependency>
    		<dependency>
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:13 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  3. .github/workflows/mint.yml

            run: |
              ${GITHUB_WORKSPACE}/.github/workflows/run-mint.sh "compress-encrypt" "minio" "minio123" "${{ steps.vars.outputs.sha_short }}"
    
          - name: multiple pools
            run: |
              ${GITHUB_WORKSPACE}/.github/workflows/run-mint.sh "pools" "minio" "minio123" "${{ steps.vars.outputs.sha_short }}"
    
          - name: standalone erasure
            run: |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. internal/config/server.go

    type ServerConfigV1 struct {
    	ServerConfigVersion
    	ServerConfigCommon
    	Pools [][]string `yaml:"pools"`
    }
    
    // ServerConfig represents a MinIO configuration file
    type ServerConfig struct {
    	ServerConfigVersion
    	ServerConfigCommon
    	Pools []struct {
    		Args          []string `yaml:"args"`
    		SetDriveCount uint64   `yaml:"set-drive-count"`
    	} `yaml:"pools"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 15:54:03 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

          expected.assertSuppressed { throwables: List<Throwable>? ->
            assertThat(throwables!!.size).isEqualTo(1)
          }
        }
      }
    
      /**
       * When a pooled connection fails, don't blame the route. Otherwise pooled connection failures can
       * cause unnecessary SSL fallbacks.
       *
       * https://github.com/square/okhttp/issues/515
       */
      @Test
      fun sslFallbackNotUsedWhenRecycledConnectionFails() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        // Running at time 75, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(75L)).isEqualTo(75L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Running at time 149, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(149L)).isEqualTo(1L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  7. cmd/storage-rest-client.go

    	diskID     atomic.Pointer[string]
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    }
    
    // Retrieve location indexes.
    func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx
    }
    
    // Wrapper to restClient.CallWithMethod to handle network errors, in case of network error the connection is disconnected
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt

     * of which connections to keep open for future use.
     *
     * @constructor Create a new connection pool with tuning parameters appropriate for a single-user
     * application. The tuning parameters in this pool are subject to change in future OkHttp releases.
     * Currently this pool holds up to 5 idle connections which will be evicted after 5 minutes of
     * inactivity.
     */
    class ConnectionPool internal constructor(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 03 20:39:41 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    	if err != nil {
    		removeRoots(fsDirs)
    		return nil, nil, err
    	}
    
    	// Wait up to 10 seconds for disks to come online.
    	pools := obj.(*erasureServerPools)
    	t := time.Now()
    	for _, pool := range pools.serverPools {
    		for _, sets := range pool.erasureDisks {
    			for _, s := range sets {
    				if !s.IsLocal() {
    					for {
    						if s.IsOnline() {
    							break
    						}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  10. buildscripts/verify-build.sh

    	export MINIO_ROOT_PASSWORD=$SECRET_KEY
    	export MINIO_ENDPOINTS="http://127.0.0.1:9000${WORK_DIR}/pool-disk-sets{1...4} http://127.0.0.1:9001${WORK_DIR}/pool-disk-sets{5...8}"
    	"${MINIO[@]}" server --address ":9000" >"$WORK_DIR/pool-minio-9000.log" 2>&1 &
    	"${MINIO[@]}" server --address ":9001" >"$WORK_DIR/pool-minio-9001.log" 2>&1 &
    
    	"${WORK_DIR}/mc" ready verify
    }
    
    function start_minio_pool_erasure_sets_ipv6() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 19:28:51 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top