Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for routes (0.18 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        http2Connection.start()
      }
    
      /**
       * Returns true if this connection can carry a stream allocation to `address`. If non-null
       * `route` is the resolved route for a connection.
       */
      internal fun isEligible(
        address: Address,
        routes: List<Route>?,
      ): Boolean {
        lock.assertHeld()
    
        // If this connection is not accepting new exchanges, we're done.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt

            val route = Route(address, proxy, inetSocketAddress)
            if (routeDatabase.shouldPostpone(route)) {
              postponedRoutes += route
            } else {
              routes += route
            }
          }
    
          if (routes.isNotEmpty()) {
            break
          }
        }
    
        if (routes.isEmpty()) {
          // We've exhausted all Proxies so fallback to the postponed routes.
          routes += postponedRoutes
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      /** Returns a plan for the first attempt at [route]. This throws if no plan is possible. */
      @Throws(IOException::class)
      internal fun planConnectToRoute(
        route: Route,
        routes: List<Route>? = null,
      ): ConnectPlan {
        if (route.address.sslSocketFactory == null) {
          if (ConnectionSpec.CLEARTEXT !in route.address.connectionSpecs) {
            throw UnknownServiceException("CLEARTEXT communication not enabled for client")
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  4. docs/changelogs/changelog_4x.md

        automatically retry on an unshared connection.
     *  Fix: Don't crash if a TLS tunnel's response body is truncated.
     *  Fix: Don't track unusable routes beyond their usefulness. We had a bug where we could track
        certain bad routes indefinitely; now we only track the ones that could be necessary.
     *  Fix: Defer proxy selection until a proxy is required. This saves calls to `ProxySelector` on
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  5. docs/features/connections.md

    In OkHttp some fields of the address come from the URL (scheme, hostname, port) and the rest come from the [OkHttpClient](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-ok-http-client/).
    
    ### [Routes](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-route/)
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Feb 21 03:33:59 GMT 2022
    - 5.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *     a race in fast follow-up.
     *
     *  4. If there's no existing connection, make a list of routes (which may require blocking DNS
     *     lookups) and attempt a new connection them. When failures occur, retries iterate the list of
     *     available routes.
     *
     * If the pool gains an eligible connection while DNS, TCP, or TLS work is in flight, this finder
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 4.2K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/internal/RecordingOkAuthenticator.kt

    import okhttp3.Response
    import okhttp3.Route
    
    class RecordingOkAuthenticator(
      val credential: String?,
      val scheme: String?,
    ) : Authenticator {
      val responses = mutableListOf<Response>()
      val routes = mutableListOf<Route>()
    
      fun onlyResponse() = responses.single()
    
      fun onlyRoute() = routes.single()
    
      @Throws(IOException::class)
      override fun authenticate(
        route: Route?,
        response: Response,
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteDatabase.kt

      val failedRoutes: Set<Route>
        @Synchronized get() = _failedRoutes.toSet()
    
      /** Records a failure connecting to [failedRoute]. */
      @Synchronized fun failed(failedRoute: Route) {
        _failedRoutes.add(failedRoute)
      }
    
      /** Records success connecting to [route]. */
      @Synchronized fun connected(route: Route) {
        _failedRoutes.remove(route)
      }
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

       *
       * If [routes] is non-null these are the resolved routes (ie. IP addresses) for the connection.
       * This is used to coalesce related domains to the same HTTP/2 connection, such as `square.com`
       * and `square.ca`.
       */
      fun callAcquirePooledConnection(
        doExtensiveHealthChecks: Boolean,
        address: Address,
        connectionUser: ConnectionUser,
        routes: List<Route>?,
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        server.enqueue(MockResponse(socketPolicy = DisconnectAtStart))
        server.enqueue(MockResponse(socketPolicy = DisconnectAtStart))
    
        client =
          client.newBuilder()
            .dns(DoubleInetAddressDns()) // Two routes so we get two failures.
            .build()
    
        val request = Request(server.url("/"))
        assertFailsWith<IOException> {
          client.newCall(request).execute()
        }.also { expected ->
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 8.4K bytes
    - Viewed (0)
Back to top