- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for ConnectionPool (0.4 sec)
-
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("/"))
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 12.2K bytes - Viewed (0) -
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.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jun 19 11:44:16 UTC 2025 - 19.1K bytes - Viewed (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, )
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.6K bytes - Viewed (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() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 46.5K bytes - Viewed (0) -
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 internal val eventListener: EventListener = client.eventListenerFactory.create(this) private val timeout = object : AsyncTimeout() { override fun timedOut() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (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)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 13.4K bytes - Viewed (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 existing
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 6K bytes - Viewed (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) } @ParameterizedTest
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 9.8K bytes - Viewed (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)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 5.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
} @Test fun inUseConnectionsNotEvicted() { val pool = factory.newConnectionPool() val poolApi = ConnectionPool(pool) val c1 = factory.newConnection(pool, routeA1, 50L) val client = OkHttpClient .Builder() .connectionPool(poolApi) .build() val call = client.newCall(Request(addressA.url)) as RealCall
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 12.9K bytes - Viewed (0)