Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for RouteDatabase (0.12 sec)

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

     * used so that OkHttp can learn from its mistakes: if there was a failure attempting to connect to
     * a specific IP address or proxy server, that failure is remembered and alternate routes are
     * preferred.
     */
    class RouteDatabase {
      private val _failedRoutes = mutableSetOf<Route>()
    
      val failedRoutes: Set<Route>
        @Synchronized get() = _failedRoutes.toSet()
    
      /** Records a failure connecting to [failedRoute]. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt

      }
    
      private fun newRouteSelector(
        address: Address,
        routeDatabase: RouteDatabase = this.routeDatabase,
        fastFallback: Boolean = false,
        call: RealCall = this.call,
      ): RouteSelector {
        return RouteSelector(
          address = address,
          routeDatabase = routeDatabase,
          fastFallback = fastFallback,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/OkHttpClientTest.kt

        assertNotSame(
          client.routeDatabase,
          OkHttpClient.Builder()
            .build()
            .routeDatabase,
        )
    
        // same client with no change affecting route db
        assertSame(
          client.routeDatabase,
          client.newBuilder()
            .build()
            .routeDatabase,
        )
        assertSame(
          client.routeDatabase,
          client.newBuilder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/RouteFailureTest.kt

              retryOnConnectionFailure = false
            }
            .build()
    
        executeSynchronously(request)
          .assertFailureMatches("stream was reset: REFUSED_STREAM")
    
        assertThat(client.routeDatabase.failedRoutes).isEmpty()
        assertThat(server1.requestCount).isEqualTo(1)
        assertThat(server2.requestCount).isEqualTo(0)
    
        assertThat(clientTestRule.recordedConnectionEventTypes()).containsExactly(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  5. okhttp/src/main/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 connectionUser: ConnectionUser,
    ) : RoutePlanner {
      private var routeSelection: RouteSelector.Selection? = null
      private var routeSelector: RouteSelector? = null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt

        socketReadTimeoutMillis: Int = 10_000,
        pingIntervalMillis: Int = 10_000,
        retryOnConnectionFailure: Boolean = true,
        fastFallback: Boolean = true,
        routeDatabase: RouteDatabase = RouteDatabase(),
      ) : this(
        RealConnectionPool(
          taskRunner = taskRunner,
          maxIdleConnections = maxIdleConnections,
          keepAliveDuration = keepAliveDuration,
          timeUnit = timeUnit,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 03 20:39:41 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. okhttp/src/main/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 =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

                socketReadTimeoutMillis = 10_000,
                pingIntervalMillis = 10_000,
                retryOnConnectionFailure = false,
                fastFallback = true,
                address = address,
                routeDatabase = RouteDatabase(),
                connectionUser = user,
              ),
              taskRunner,
            )
          },
        )
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt

     * IP address, and TLS mode. Connections may also be recycled.
     */
    class RouteSelector(
      private val address: Address,
      private val routeDatabase: RouteDatabase,
      private val connectionUser: ConnectionUser,
      private val fastFallback: Boolean,
    ) {
      // State for negotiating the next proxy to use.
      private var proxies = emptyList<Proxy>()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

              fastFallback = client.fastFallback,
              address = client.address(request.url),
              connectionUser = CallConnectionUser(this, connectionPool.connectionListener, chain),
              routeDatabase = client.routeDatabase,
            )
          this.exchangeFinder =
            when {
              client.fastFallback -> FastFallbackExchangeFinder(routePlanner, client.taskRunner)
              else -> SequentialExchangeFinder(routePlanner)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
Back to top