Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 156 for routes (0.03 sec)

  1. okhttp/src/commonJvmAndroid/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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. 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,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          pingIntervalMillis = pingIntervalMillis,
          retryOnConnectionFailure = retryOnConnectionFailure,
          user = user,
          routePlanner = routePlanner,
          route = route,
          routes = routes,
          attempt = attempt,
          tunnelRequest = tunnelRequest,
          connectionSpecIndex = connectionSpecIndex,
          isTlsFallback = isTlsFallback,
        )
    
    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/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       *
       * This will be invoked only once for a single [Call]. Retries of different routes or redirects
       * will be handled within the boundaries of a single [callStart] and [callEnd]/[callFailed] pair.
       */
      open fun callStart(call: Call) {
      }
    
      /**
       * Invoked prior to a proxy selection.
       *
       * This will be invoked for route selection regardless of whether the client
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/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")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RouteSelectorTest.kt

        val selection = routeSelector.next()
        dns.assertRequests(uriHost)
        val routes = selection.routes
        assertRoute(routes[0], address, Proxy.NO_PROXY, dns.lookup(uriHost, 0), uriPort)
        assertRoute(routes[1], address, Proxy.NO_PROXY, dns.lookup(uriHost, 1), uriPort)
        assertThat(selection.next()).isSameAs(routes[0])
        assertThat(selection.next()).isSameAs(routes[1])
        assertThat(selection.hasNext()).isFalse()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/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>?,
        requireMultiplexed: Boolean,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/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)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. 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/)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/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 {
        assertLockHeld()
    
        // If this connection is not accepting new exchanges, we're done.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
Back to top