- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for attempts (0.15 sec)
-
docs/changelogs/changelog_4x.md
of unacknowledged data per stream and no per-connection limit. * Fix: Don't operate on a connection after it's been returned to the pool. This race occurred on failed web socket connection attempts. * Upgrade: [Okio 3.6.0][okio_3_6_0]. * Upgrade: [Kotlin 1.8.21][kotlin_1_8_21]. ## Version 4.11.0 _2023-04-22_
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
* proxy server can issue an auth challenge and then close the connection. * * @return the next plan to attempt, or null if no further attempt should be made either because * we've successfully connected or because no further attempts should be made. */ @Throws(IOException::class) internal fun connectTunnel(): ConnectResult { val nextTunnelRequest = createTunnel()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
) val call = client.newCall(Request(url)) val response = call.execute() assertThat(response.body.string()).isEqualTo("hello from IPv6") // In the process we made two connection attempts including one failure. assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(1) assertThat(listener.recordedEventTypes().filter { it == "ConnectEnd" }).hasSize(1)
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/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
.build() val attempts = CountDownLatch(20) val webSockets = Collections.synchronizedList(ArrayList<WebSocket>()) val reconnectOnFailure: WebSocketListener = object : WebSocketListener() { override fun onFailure( webSocket: WebSocket, t: Throwable, response: Response?, ) { if (attempts.count > 0) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
} finally { if (originalDurationNs == Long.MAX_VALUE) { timeout().clearDeadline() } else { timeout().deadlineNanoTime(nowNs + originalDurationNs) } } } /** * Attempts to exhaust this, returning true if successful. This is useful when reading a complete * source is helpful, such as when doing so completes a cache body or frees a socket connection for * reuse. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
* [settings] before writing the response. */ fun settings(settings: Settings) = apply { this.settings.clear() this.settings.merge(settings) } /** * Attempts to perform a web socket upgrade on the connection. * This will overwrite any previously set status, body, or streamHandler. */ fun webSocketUpgrade(listener: WebSocketListener) = apply {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Platform.kt
} return trustManagers[0] as X509TrustManager } open fun trustManager(sslSocketFactory: SSLSocketFactory): X509TrustManager? { return try { // Attempt to get the trust manager from an OpenJDK socket factory. We attempt this on all // platforms in order to support Robolectric, which mixes classes from both Android and the // Oracle JDK. Note that we don't support HTTP/2 or other nice features on Robolectric.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
get() = originalRequest.url.host val request: Request get() = originalRequest val call: RealCall get() = this@RealCall /** * Attempt to enqueue this async call on [executorService]. This will attempt to clean up * if the executor has been shut down by reporting the call as failed. */ fun executeOn(executorService: ExecutorService) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
): Relay { val randomAccessFile = RandomAccessFile(file, "rw") val result = Relay(randomAccessFile, upstream, 0L, metadata, bufferMaxSize) // Write a dirty header. That way if we crash we won't attempt to recover this. randomAccessFile.setLength(0L) result.writeHeader(PREFIX_DIRTY, -1L, -1L) return result } /** * Creates a relay that reads a recorded stream from [file].
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
connectionPool.scheduleCloser() } } } override fun handshake(): Handshake? = handshake /** Track a bad route in the route database. Other routes will be attempted first. */ internal fun connectFailed( client: OkHttpClient, failedRoute: Route, failure: IOException, ) { // Tell the proxy selector when we fail to connect on a fresh connection.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0)