Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for connectionPool (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
      }
    
      @Test
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 18:33:48 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  5. 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)
  6. 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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 5.9K bytes
    - Click Count (1)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top