Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for pool_id (0.06 sec)

  1. 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)
  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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

        assertThat(server.takeRequest().sequenceNumber).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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CacheTest.kt

        assertThat(recordedRequest2.requestLine).isEqualTo("GET /bar HTTP/1.1")
        assertThat(recordedRequest2.sequenceNumber).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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top