Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for pool_id (0.04 sec)

  1. okhttp/src/jvmTest/kotlin/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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    	hostAnonymizer := map[string]string{}
    	hosts := set.NewStringSet()
    	srvrIdx := 0
    
    	for poolIdx, pool := range globalEndpoints {
    		for _, endpoint := range pool.Endpoints {
    			if !hosts.Contains(endpoint.Host) {
    				hosts.Add(endpoint.Host)
    				srvrIdx++
    			}
    			anonymizeHost(hostAnonymizer, endpoint, poolIdx+1, srvrIdx)
    		}
    	}
    	return hostAnonymizer
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(2)
      }
    
      /**
       * Each OkHttpClient used to get its own instance of NullProxySelector, and because these weren't
       * equal their connections weren't pooled. That's a nasty performance bug!
       *
       * https://github.com/square/okhttp/issues/5519
       */
      @Test
      fun connectionPoolingWithFreshClientSamePool() {
        server.enqueue(MockResponse(body = "abc"))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbFile.java

                throw new MalformedURLException("Name must not be empty");
            }
            return name;
        }
    
        /**
         * Sets whether this file should use an exclusive (non-pooled) connection
         *
         * @param nonPooled
         *            whether this file will use an exclusive connection
         */
        protected void setNonPooled(final boolean nonPooled) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    			Description: getClusterHealthStatusMD(),
    			Value:       float64(health),
    		})
    
    		for _, h := range result.ESHealth {
    			labels := map[string]string{
    				"pool": strconv.Itoa(h.PoolID),
    				"set":  strconv.Itoa(h.SetID),
    			}
    			metrics = append(metrics, MetricV2{
    				Description:    getClusterErasureSetReadQuorumMD(),
    				VariableLabels: labels,
    				Value:          float64(h.ReadQuorum),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        assertThat(recordedRequest2.connectionIndex).isEqualTo(0)
        assertThat(recordedRequest2.exchangeIndex).isEqualTo(1)
    
        // an unrelated request should reuse the pooled connection
        val request3 = Request.Builder().url(server.url("/baz")).build()
        val response3 = client.newCall(request3).execute()
        assertThat(response3.body.string()).isEqualTo("DEF")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
Back to top