- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 89 for event (0.13 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(pool.connectionCount()).isEqualTo(2) forceConnectionsToExpire(pool, expireTime) assertThat(pool.connectionCount()).isEqualTo(2) // Excess connections aren't removed until they idle out, even if no longer needed setPolicy(pool, address, ConnectionPool.AddressPolicy(1)) assertThat(pool.connectionCount()).isEqualTo(2) forceConnectionsToExpire(pool, expireTime)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
internal fun FileSystem.deleteIfExists(path: Path) { try { delete(path) } catch (fnfe: FileNotFoundException) { return } } /** Tolerant delete, try to clear as many files as possible even after a failure. */ internal fun FileSystem.deleteContents(directory: Path) { var exception: IOException? = null val files = try { list(directory) } catch (fnfe: FileNotFoundException) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* as a part of the response to `streamId`. * * @param streamId client-initiated stream ID. Must be an odd number. * @param promisedStreamId server-initiated stream ID. Must be an even number. * @param requestHeaders minimally includes `:method`, `:scheme`, `:authority`, and `:path`. */ @Throws(IOException::class) fun pushPromise( streamId: Int, promisedStreamId: Int,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
* * Usually a webserver is reachable with multiple identifiers: its IP addresses, registered * domain names, and even `localhost` when connecting from the server itself. Each of a web server's * names is a distinct URL and they are not interchangeable. For example, even if * `http://square.github.io/dagger` and `http://google.github.io/dagger` are served by the same IP * address, the two URLs identify different resources.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* is exhausted. * * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object DisconnectAtEnd : SocketPolicy /** * Request immediate close of connection without even reading the request. Use to simulate buggy * SSL servers closing connections in response to unrecognized TLS extensions. */ object DisconnectAtStart : SocketPolicy /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
* limitations under the License. */ package okhttp3.internal.cache import java.io.IOException import okio.Buffer import okio.ForwardingSink import okio.Sink /** A sink that never throws IOExceptions, even if the underlying sink does. */ internal open class FaultHidingSink( delegate: Sink, val onException: (IOException) -> Unit, ) : ForwardingSink(delegate) { private var hasErrors = false override fun write(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FailedPlan.kt
* to use `H2_PRIOR_KNOWLEDGE` but the URL's scheme is `https:`. * * Preemptive proxy authentication failed. * * Planning failures are not necessarily fatal. For example, even if we can't DNS lookup the first * proxy in a list, looking up a subsequent one may succeed. */ internal class FailedPlan(e: Throwable) : RoutePlanner.Plan { val result = RoutePlanner.ConnectResult(plan = this, throwable = e)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt
server.requireClientAuth() val call = client.newCall(Request.Builder().url(server.url("/")).build()) assertFailsWith<IOException> { call.execute() } // Observed Events are variable // JDK 14 // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart, // SecureConnectEnd, ConnectEnd, ConnectionAcquired, RequestHeadersStart, RequestHeadersEnd,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 12.5K bytes - Viewed (0) -
docs/contribute/concurrency.md
The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
@Throws(IOException::class) fun parse(responseHeaders: Headers): WebSocketExtensions { // Note that this code does case-insensitive comparisons, even though the spec doesn't specify // whether extension tokens and parameters are case-insensitive or not. var compressionEnabled = false var clientMaxWindowBits: Int? = null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0)