Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 10 for RouteDatabase (0.51 seconds)

  1. okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt

            .routeDatabase,
        )
        assertNotSame(
          client.routeDatabase,
          client
            .newBuilder()
            .proxySelector(proxySelector)
            .build()
            .routeDatabase,
        )
        assertNotSame(
          client.routeDatabase,
          client
            .newBuilder()
            .proxy(Proxy.NO_PROXY)
            .build()
            .routeDatabase,
        )
        assertNotSame(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 13.4K bytes
    - Click Count (1)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

     * IP address, and TLS mode. Connections may also be recycled.
     */
    class RouteSelector internal constructor(
      private val address: Address,
      private val routeDatabase: RouteDatabase,
      private val call: RealCall,
      private val fastFallback: Boolean,
    ) {
      // State for negotiating the next proxy to use.
      private var proxies = emptyList<Proxy>()
      private var nextProxyIndex: Int = 0
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 7.3K bytes
    - Click Count (2)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RouteSelectorTest.kt

      }
    
      private fun newRouteSelector(
        address: Address,
        routeDatabase: RouteDatabase = this.routeDatabase,
        fastFallback: Boolean = false,
        call: RealCall = this.call,
      ): RouteSelector =
        RouteSelector(
          address = address,
          routeDatabase = routeDatabase,
          fastFallback = fastFallback,
          call = call,
        )
    
      companion object {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      private val socketReadTimeoutMillis: Int,
      private val pingIntervalMillis: Int,
      private val retryOnConnectionFailure: Boolean,
      private val fastFallback: Boolean,
      override val address: Address,
      private val routeDatabase: RouteDatabase,
      private val call: RealCall,
      request: Request,
    ) : RoutePlanner {
      private val doExtensiveHealthChecks = request.method != "GET"
      private var routeSelection: RouteSelector.Selection? = null
    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)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

       * The default is 1024 bytes.
       */
      @get:JvmName("minWebSocketMessageToCompress")
      val minWebSocketMessageToCompress: Long = builder.minWebSocketMessageToCompress
    
      internal val routeDatabase: RouteDatabase = builder.routeDatabase ?: RouteDatabase()
      internal val taskRunner: TaskRunner = builder.taskRunner ?: TaskRunner.INSTANCE
    
      @get:JvmName("connectionPool")
      val connectionPool: ConnectionPool =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 51.5K bytes
    - Click Count (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

          pingIntervalMillis = client.pingIntervalMillis,
          retryOnConnectionFailure = client.retryOnConnectionFailure,
          fastFallback = client.fastFallback,
          address = address,
          routeDatabase = client.routeDatabase,
          call = call,
          request = call.request(),
        )
      }
    
      override fun close() {
        taskFaker.close()
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 6.6K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

              retryOnConnectionFailure = chain.retryOnConnectionFailure,
              fastFallback = client.fastFallback,
              address = chain.address(request.url),
              routeDatabase = client.routeDatabase,
              call = this,
              request = request,
            )
          this.exchangeFinder =
            when {
              client.fastFallback -> FastFallbackExchangeFinder(routePlanner, client.taskRunner)
    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)
  8. okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt

            .apply {
              retryOnConnectionFailure = false
            }.build()
    
        executeSynchronously(request)
          .assertFailureMatches("stream was reset: REFUSED_STREAM")
    
        assertThat(client.routeDatabase.failedRoutes).isEmpty()
        server1.takeRequest()
        assertThat(server1.requestCount).isEqualTo(1)
        assertThat(server2.requestCount).isEqualTo(0)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jan 10 15:25:06 GMT 2026
    - 11.8K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          }
        }
        return null
      }
    
      /** Returns the connection to use, which might be different from [connection]. */
      override fun handleSuccess(): RealConnection {
        call.client.routeDatabase.connected(route)
    
        val connection = this.connection!!
        connection.connectionListener.connectEnd(connection, route, call)
    
    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)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

          val address = failedRoute.address
          address.proxySelector.connectFailed(
            address.url.toUri(),
            failedRoute.proxy.address(),
            failure,
          )
        }
    
        client.routeDatabase.failed(failedRoute)
      }
    
      /**
       * Track a failure using this connection. This may prevent both the connection and its route from
       * being used for future exchanges.
       */
      override fun trackFailure(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 14.6K bytes
    - Click Count (0)
Back to Top