- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for RouteDatabase (0.2 sec)
-
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]. */
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) -
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()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 13.2K bytes - Viewed (0) -
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, ) }, ) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
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,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0) -
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,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
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 =
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
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(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0) -
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
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) -
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>()
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
} override fun removePlanToCancel(connectPlan: ConnectPlan) { call.plansToCancel -= connectPlan } override fun updateRouteDatabaseAfterSuccess(route: Route) { call.client.routeDatabase.connected(route) } override fun connectStart(route: Route) { eventListener.connectStart(call, route.socketAddress, route.proxy) poolConnectionListener.connectStart(route, call) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 3.6K bytes - Viewed (0)