- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 14 for ConnectionPool (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
assertConnectionNotReused(request, request) } @Test fun connectionsAreNotReusedIfPoolIsSizeZero() { client = client .newBuilder() .connectionPool(ConnectionPool(0, 5, TimeUnit.SECONDS)) .build() server.enqueue(MockResponse(body = "a")) server.enqueue(MockResponse(body = "b")) val request = Request(server.url("/"))
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 12.2K bytes - Click Count (1) -
android-test/src/androidTest/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 Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Nov 21 12:33:41 GMT 2025 - 2.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
taskRunner = taskRunner, connectionPool = connectionPool, route = route, rawSocket = rawSocket, javaNetSocket = javaNetSocket!!, handshake = handshake, protocol = protocol!!, socket = socket, pingIntervalMillis = pingIntervalMillis, connectionListener = connectionPool.connectionListener, )Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 19.3K bytes - Click Count (2) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt
assert200Http2Response(execute(url), server.hostName) val sanUrl = url.newBuilder().host("san.com").build() assert200Http2Response(execute(sanUrl), "san.com") assertThat(client.connectionPool.connectionCount()).isEqualTo(1) } /** * Test connecting to an alternative host then common name, although only subject alternative * names are used if present no special consideration of common name.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jun 19 11:44:16 GMT 2025 - 19.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
} } @Test fun connectionPool() { var connectionPool = ConnectionPool() connectionPool = ConnectionPool(0, 0L, TimeUnit.SECONDS) val idleConnectionCount: Int = connectionPool.idleConnectionCount() val connectionCount: Int = connectionPool.connectionCount() connectionPool.evictAll() } @Test fun connectionSpec() {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 47K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt
assertThat(a.dispatcher).isNotNull() assertThat(a.connectionPool).isNotNull() assertThat(a.sslSocketFactory).isNotNull() assertThat(a.x509TrustManager).isNotNull() // Multiple clients share the instances. val b = client.newBuilder().build() assertThat(b.dispatcher).isSameAs(a.dispatcher) assertThat(b.connectionPool).isSameAs(a.connectionPool) assertThat(b.sslSocketFactory).isSameAs(a.sslSocketFactory)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 13.4K bytes - Click Count (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
val originalRequest: Request, val forWebSocket: Boolean, ) : Call, Cloneable, Lockable { private val connectionPool: RealConnectionPool = client.connectionPool.delegate @Volatile internal var eventListener: EventListener = client.eventListenerFactory.create(this) private val timeout = object : AsyncTimeout() {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 19.7K 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 Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 5.9K bytes - Click Count (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* [Call.request] is a redirect to a different host. * * If the [Call] is able to reuse an existing pooled connection, this method will not be invoked. * See [ConnectionPool]. */ open fun dnsStart( call: Call, domainName: String, ) { } /** * Invoked immediately after a DNS lookup. * * This method is invoked after [dnsStart].
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0) -
okhttp/api/jvm/okhttp.api
public final fun certificatePinner ()Lokhttp3/CertificatePinner; public final fun connectTimeoutMillis ()I public final fun connectionPool ()Lokhttp3/ConnectionPool; public final fun connectionSpecs ()Ljava/util/List; public final fun cookieJar ()Lokhttp3/CookieJar; public final fun dispatcher ()Lokhttp3/Dispatcher; public final fun dns ()Lokhttp3/Dns;
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 70.2K bytes - Click Count (0)