- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 166 for connection (0.15 sec)
-
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
} } /** * This test reproduces a crash where OkHttp attempted to use a deferred connection when the call * already had a healthy connection. It sets up a deferred connection by stalling the IPv6 * connect, and it sets up a same-connection retry with [ErrorCode.REFUSED_STREAM]. * * https://github.com/square/okhttp/pull/7190 */ @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
} } else { exchange.noRequestBody() if (!exchange.connection.isMultiplexed) { // If the "Expect: 100-continue" expectation wasn't met, prevent the HTTP/1 connection // from being reused. Otherwise we're still obligated to transmit the request body to // leave the connection in a consistent state. exchange.noNewExchangesOnConnection() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.3K bytes - Viewed (1) -
container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt
} } @Test fun testUrlConnectionDirect() { testRequest { val url = URI(mockServer.endpoint + "/person?name=peter").toURL() val connection = url.openConnection() as HttpURLConnection assertThat(connection.inputStream.source().buffer().readUtf8()).contains("Peter the person") } } @Test fun testUrlConnectionPlaintextProxied() { testRequest {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
import okhttp3.internal.concurrent.TaskRunner import okhttp3.internal.connection.CallConnectionUser import okhttp3.internal.connection.FastFallbackExchangeFinder import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.connection.RealRoutePlanner import okhttp3.internal.connection.RouteDatabase
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* * 4. If there's no existing connection, make a list of routes (which may require blocking DNS * lookups) and attempt a new connection them. When failures occur, retries iterate the list of * available routes. * * If the pool gains an eligible connection while DNS, TCP, or TLS work is in flight, this finder * will prefer pooled connections. Only pooled HTTP/2 connections are used for such de-duplication. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt
call: Call, connection: Connection, ) { logWithTime("connectionAcquired: $connection") delegate.connectionAcquired(call, connection) } override fun connectionReleased( call: Call, connection: Connection, ) { logWithTime("connectionReleased") delegate.connectionReleased(call, connection) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
import java.io.IOException import java.util.concurrent.TimeUnit import okhttp3.Call import okhttp3.Connection import okhttp3.Interceptor import okhttp3.Request import okhttp3.Response import okhttp3.internal.checkDuration import okhttp3.internal.connection.Exchange import okhttp3.internal.connection.RealCall /** * A concrete interceptor chain that carries the entire interceptor chain: all application
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
} /** * Return the route from [connection] if it should be retried, even if the connection itself is * unhealthy. The biggest gotcha here is that we shouldn't reuse routes from coalesced * connections. */ private fun retryRoute(connection: RealConnection): Route? { return connection.withLock { when { connection.routeFailureCount != 0 -> null
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) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
clientTestRule.wrap( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) { socketClass = connection.socket().javaClass.name } }, ), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 27K bytes - Viewed (1) -
native-image-tests/src/main/resources/testlist.txt
okhttp3.internal.concurrent.TaskLoggerTest okhttp3.internal.concurrent.TaskRunnerRealBackendTest okhttp3.internal.concurrent.TaskRunnerTest okhttp3.internal.connection.ConnectionPoolTest okhttp3.internal.connection.ConnectionSpecSelectorTest okhttp3.internal.connection.RouteExceptionTest okhttp3.internal.connection.RouteSelectorTest okhttp3.internal.http.CancelTest okhttp3.internal.http.HttpDateTest okhttp3.internal.http.StatusLineTest
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu May 11 14:48:57 GMT 2023 - 2.8K bytes - Viewed (0)