- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 107 for routes (0.05 seconds)
-
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`. */ internal fun callAcquirePooledConnection( doExtensiveHealthChecks: Boolean, address: Address, call: RealCall, routes: List<Route>?, requireMultiplexed: Boolean,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 11.1K bytes - Click Count (0) -
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")
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) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
route.address.url.toUri(), route.proxy.address(), e, ) } call.eventListener.connectFailed(call, route.socketAddress, route.proxy, null, e) connectionPool.connectionListener.connectFailed(route, call, e) return ConnectResult(plan = this, throwable = e) } finally { call.plansToCancel -= this if (!success) {
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) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RouteSelectorTest.kt
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()).isSameInstanceAs(routes[0]) assertThat(selection.next()).isSameInstanceAs(routes[1]) assertThat(selection.hasNext()).isFalse()
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) -
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.
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) -
fastapi/openapi/utils.py
operation["tags"] = route.tags operation["summary"] = generate_operation_summary(route=route, method=method) if route.description: operation["description"] = route.description operation_id = route.operation_id or route.unique_id if operation_id in operation_ids: endpoint_name = getattr(route.endpoint, "__name__", "<unnamed_endpoint>")
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Mar 15 11:44:39 GMT 2026 - 25.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* * Each call is made on either a reused [Connection] from a pool, or on a new connection * established from a planned [Route]. OkHttp won't retry if it's already attempted all * available routes. * * @param retry true if OkHttp will make another attempt */ open fun retryDecision( call: Call, exception: IOException, retry: Boolean, ) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0) -
cmd/admin-router.go
type adminAPIHandlers struct{} // registerAdminRouter - Add handler functions for each service REST API routes. func registerAdminRouter(router *mux.Router, enableConfigOps bool) { adminAPI := adminAPIHandlers{} // Admin router adminRouter := router.PathPrefix(adminPathPrefix).Subrouter() adminVersions := []string{ adminAPIVersionPrefix, }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 26.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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)Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 13K bytes - Click Count (0) -
cmd/api-router.go
func registerAPIRouter(router *mux.Router) { // Initialize API. api := objectAPIHandlers{ ObjectAPI: newObjectLayerFn, } // API Router apiRouter := router.PathPrefix(SlashSeparator).Subrouter() var routers []*mux.Router for _, domainName := range globalDomainNames { if IsKubernetes() {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:19 GMT 2025 - 23.3K bytes - Click Count (0)