Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for poolIdx (0.05 seconds)

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

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
        // Attempt to get a connection from the pool.
        val pooled1 = planReusePooledConnection()
        if (pooled1 != null) return pooled1
    
        // Attempt a deferred plan before new routes.
        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
    
        // Do blocking calls to plan a route for a new connection.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

        // If we raced another call connecting to this host, coalesce the connections. This makes for
        // 3 different lookups in the connection pool!
        val pooled3 = routePlanner.planReusePooledConnection(this, routes)
        if (pooled3 != null) return pooled3.connection
    
        connection.withLock {
          connectionPool.put(connection)
          call.acquireConnectionNoEvents(connection)
        }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  3. docs/features/events.md

    System.out.println("REQUEST 1 (new connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
    
    System.out.println("REQUEST 2 (pooled connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
    ```
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 7.7K bytes
    - Click Count (0)
  4. docs/features/calls.md

    ## Retrying Requests
    
    Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available.
    
    ## [Calls](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-call/)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 3.9K bytes
    - Click Count (0)
  5. docs/features/connections.md

    If there's a problem with the connection, OkHttp will select another route and try again. This allows OkHttp to recover when a subset of a server's addresses are unreachable. It's also useful when a pooled connection is stale or if the attempted TLS version is unsupported.
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 5.4K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        // Second call attempts the pooled connection, and it fails. Then it retries a new route which
        // succeeds.
        val response2 = client.newCall(request).execute()
        assertThat(response2.body.string()).isEqualTo("abc")
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) // Pooled connection.
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0) // New connection.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 67.5K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  8. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

          expected.assertSuppressed { throwables: List<Throwable>? ->
            assertThat(throwables!!.size).isEqualTo(1)
          }
        }
      }
    
      /**
       * When a pooled connection fails, don't blame the route. Otherwise pooled connection failures can
       * cause unnecessary SSL fallbacks.
       *
       * https://github.com/square/okhttp/issues/515
       */
      @Test
      fun sslFallbackNotUsedWhenRecycledConnectionFails() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

            when {
              client.fastFallback -> FastFallbackExchangeFinder(routePlanner, client.taskRunner)
              else -> SequentialExchangeFinder(routePlanner)
            }
        }
      }
    
      /** Finds a new or pooled connection to carry a forthcoming request and response. */
      internal fun initExchange(chain: RealInterceptorChain): Exchange {
        withLock {
          check(expectMoreExchanges) { "released" }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(2)
      }
    
      /**
       * Each OkHttpClient used to get its own instance of NullProxySelector, and because these weren't
       * equal their connections weren't pooled. That's a nasty performance bug!
       *
       * https://github.com/square/okhttp/issues/5519
       */
      @Test
      fun connectionPoolingWithFreshClientSamePool() {
        server.enqueue(MockResponse(body = "abc"))
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
Back to Top