- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for connectionPool (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/contribute/debug_logging.md
This logs task enqueues, starts, and finishes. ``` [2020-01-01 00:00:00] Q10000 scheduled after 0 µs: OkHttp ConnectionPool [2020-01-01 00:00:00] Q10000 starting : OkHttp ConnectionPool [2020-01-01 00:00:00] Q10000 run again after 300 s : OkHttp ConnectionPool [2020-01-01 00:00:00] Q10000 finished run in 1 ms: OkHttp ConnectionPool [2020-01-01 00:00:00] Q10001 scheduled after 0 µs: OkHttp squareup.com applyAndAckSettings
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 2.7K bytes - Click Count (0) -
android-test/src/androidDeviceTest/java/okhttp/android/test/SingleAndroidTest.kt
private var client: OkHttpClient = OkHttpClient .Builder() .sslSocketFactory( handshakeCertificates.sslSocketFactory(), handshakeCertificates.trustManager, ).connectionPool(ConnectionPool(0, 1, TimeUnit.SECONDS)) .build() private val server = MockWebServer() @Test fun testHttpsRequest() { server.useHttps(handshakeCertificates.sslSocketFactory())Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 26 07:38:51 GMT 2026 - 2.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
/** * Returns the [ConnectionPool] for the OkHttpClient, or an override from the Call.Chain. */ val connectionPool: ConnectionPool /** * Returns a new chain with the specified [ConnectionPool]. */ fun withConnectionPool(connectionPool: ConnectionPool): Chain val eventListener: EventListener }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 8.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
private var client: OkHttpClient = clientTestRule .newClientBuilder() .connectionPool(ConnectionPool(connectionListener = listener)) .fastFallback(fastFallback) .build() @BeforeEach fun setUp() { platform.assumeNotOpenJSSE() platform.assumeNotBouncyCastle() listener.forbidLock(get(client.connectionPool)) listener.forbidLock(client.dispatcher) } @TestCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 9.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt
* * Typically instances of this class are created, connected and exercised automatically by the HTTP * client. Applications may use this class to monitor HTTP connections as members of a * [connection pool][ConnectionPool]. * * Do not confuse this class with the misnamed `HttpURLConnection`, which isn't so much a connection * as a single request/response exchange. * * ## Modern TLS *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 4.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SessionReuseTest.kt
val request = Request(server.url("/")) client.newCall(request).execute().use { response -> assertEquals(200, response.code) } client.connectionPool.evictAll() assertEquals(0, client.connectionPool.connectionCount()) // Force reuse. This appears flaky (30% of the time) even though sessions are reused. // javax.net.ssl.SSLHandshakeException: No new session is allowed and no existingCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 5.9K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ExternalHttp2Example.kt
.source() .readUtf8Line() .also { line = it } != null ) { println(line) } } finally { response.body.close() } client.connectionPool.evictAll() }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/JSSETest.kt
assertThat(it.protocol).isEqualTo(Protocol.HTTP_2) assertThat(it.handshake!!.tlsVersion).isEqualTo(TlsVersion.TLS_1_3) } client.connectionPool.evictAll() assertEquals(0, client.connectionPool.connectionCount()) client.newCall(request).execute().use { assertThat(it.protocol).isEqualTo(Protocol.HTTP_2)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 5.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
} }.also { expected -> assertEquals(cancelMode == INTERRUPT, Thread.interrupted()) } responseBody.close() assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount()) } @Test fun cancelAndFollowup() { val responseBodySize = 8 * 1024 * 1024 // 8 MiB. server.enqueue( MockResponse .Builder() .body(Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 9.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/TestTls13Request.kt
urls: List<String>, client: OkHttpClient, ) { try { for (url in urls) { sendRequest(client, url) } } finally { client.dispatcher.executorService.shutdownNow() client.connectionPool.evictAll() } } private fun buildClient(vararg specs: ConnectionSpec): OkHttpClient = OkHttpClient .Builder() .connectionSpecs(listOf(*specs)) .build() private fun sendRequest(
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu May 22 14:39:30 GMT 2025 - 3.6K bytes - Click Count (0)