- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for poolIdx (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val reuseCallConnection = planReuseCallConnection() if (reuseCallConnection != null) return reuseCallConnection // Attempt to get a connection from the pool. val pooled1 = planReusePooledConnection() if (pooled1 != null) return pooled1 // Attempt a deferred plan before new routes. if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() // Do blocking calls to plan a route for a new connection.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// If we raced another call connecting to this host, coalesce the connections. This makes for // 3 different lookups in the connection pool! val pooled3 = routePlanner.planReusePooledConnection(this, routes) if (pooled3 != null) return pooled3.connection connection.withLock { connectionPool.put(connection) call.acquireConnectionNoEvents(connection) }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 19.3K bytes - Click Count (2) -
docs/features/events.md
System.out.println("REQUEST 1 (new connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } System.out.println("REQUEST 2 (pooled connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } ```
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 7.7K bytes - Click Count (0) -
docs/features/calls.md
## Retrying Requests Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available. ## [Calls](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-call/)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 3.9K bytes - Click Count (0) -
docs/features/connections.md
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 5.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
// Second call attempts the pooled connection, and it fails. Then it retries a new route which // succeeds. val response2 = client.newCall(request).execute() assertThat(response2.body.string()).isEqualTo("abc") assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) // Pooled connection. assertThat(server.takeRequest().exchangeIndex).isEqualTo(0) // New connection.Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 67.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
} /** * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled * connections. */ private fun detachTimeout(timeout: ForwardingTimeout) { val oldDelegate = timeout.delegate timeout.setDelegate(Timeout.NONE) oldDelegate.clearDeadline()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 17.6K bytes - Click Count (7) -
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() {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 133.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
when { client.fastFallback -> FastFallbackExchangeFinder(routePlanner, client.taskRunner) else -> SequentialExchangeFinder(routePlanner) } } } /** Finds a new or pooled connection to carry a forthcoming request and response. */ internal fun initExchange(chain: RealInterceptorChain): Exchange { withLock { check(expectMoreExchanges) { "released" }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 19.5K bytes - Click Count (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"))
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0)