Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

          if (allocationLimit < oldLimit) {
            // We might need new connections to keep policies satisfied
            connectionPool.scheduleOpener(route.address)
          } else if (allocationLimit > oldLimit) {
            // We might no longer need some connections
            connectionPool.scheduleCloser()
          }
        }
      }
    
      override fun handshake(): Handshake? = handshake
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  5. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

        val request = Request.Builder().url(server.url("/")).build()
    
        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
        }
    
        client.connectionPool.evictAll()
        assertEquals(0, client.connectionPool.connectionCount())
    
        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
        }
    
        assertEquals(2, sessionIds.size)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

    }
    
    suspend fun main() {
      val publicSuffixListGenerator = PublicSuffixListGenerator()
    
      try {
        publicSuffixListGenerator.import()
      } finally {
        publicSuffixListGenerator.client.run {
          connectionPool.evictAll()
          dispatcher.executorService.shutdownNow()
        }
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Aug 06 05:33:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  7. 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;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        client =
          OkHttpClient
            .Builder()
            .connectionPool(client.connectionPool)
            .proxy(server.proxyAddress)
            .build()
        executeSynchronously("/a").assertBody("abc")
        client =
          OkHttpClient
            .Builder()
            .connectionPool(client.connectionPool)
            .proxy(server.proxyAddress)
            .build()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  9. okhttp/api/android/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;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

            writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong())
          }
        }
        // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via
        // ConnectionPool.
        taskRunner.newQueue().execute(name = connectionName, block = readerRunnable)
      }
    
      /** Merges [settings] into this peer's settings and sends them to the remote peer. */
      @Throws(IOException::class)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
Back to top