- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for poolIdx (0.07 sec)
-
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) -
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) -
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) -
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) -
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)