- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for pool_id (0.03 sec)
-
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 Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 99.7K bytes - Viewed (0) -
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 Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 147.4K bytes - Viewed (0) -
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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 103.2K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 133.6K bytes - Viewed (0) -
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 Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 17:41:45 UTC 2025 - 116.8K bytes - Viewed (0)