Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for connectionPool (0.1 sec)

  1. 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)
  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.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top