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 May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  2. 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 May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/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()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  4. okhttp/src/main/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,
        )
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 18.6K bytes
    - Viewed (0)
  5. 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 May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  6. 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 May 03 11:42:14 GMT 2024
    - Last Modified: Mon Feb 21 03:33:59 GMT 2022
    - 5.4K bytes
    - Viewed (0)
  7. 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 May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

            }
            is SocketException -> {
              // Conscrypt, JDK 8 (>= 292), JDK 9
            }
            else -> {
              assertThat(expected.message).isEqualTo("exhausted all routes")
            }
          }
        }
      }
    
      @Test
      fun commonNameIsNotTrusted() {
        serverCert =
          HeldCertificate.Builder()
            .signedBy(serverIntermediateCa)
            .serialNumber(3L)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

        }
      }
    
      override fun connectStart(
        route: Route,
        call: Call,
      ) = logEvent(ConnectionEvent.ConnectStart(System.nanoTime(), route, call))
    
      override fun connectFailed(
        route: Route,
        call: Call,
        failure: IOException,
      ) = logEvent(
        ConnectionEvent.ConnectFailed(System.nanoTime(), route, call, failure),
      )
    
      override fun connectEnd(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  10. samples/guide/src/main/java/okhttp3/recipes/kt/Authenticate.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.Route
    
    class Authenticate {
      private val client =
        OkHttpClient.Builder()
          .authenticator(
            object : Authenticator {
              @Throws(IOException::class)
              override fun authenticate(
                route: Route?,
                response: Response,
              ): Request? {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.9K bytes
    - Viewed (0)
Back to top