- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Stalla (0.18 sec)
-
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
throw IOException("boom") // Despite this exception, 'sink' is healthy. } } val callA = client.newCall( Request( url = server.url("/"), body = requestBody, ), ) assertFailsWith<IOException> { callA.execute() }.also { expected -> assertThat(expected).hasMessage("boom") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
* Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this happened enough then eventually the connection would stall. * Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we could use new flow control capacity before acknowledging it, causing strict HTTP/2 servers to fail the call.
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/test/java/okhttp3/CallTest.kt
client = client.newBuilder() .dispatcher(dispatcher) .build() val requestA = Request(server.url("/a")) val requestB = Request(server.url("/b")) val callA = client.newCall(requestA) val callB = client.newCall(requestB) server.dispatcher = object : mockwebserver3.Dispatcher() { var nextResponse = 'A'
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
DISCONNECT_AFTER_REQUEST, DISCONNECT_DURING_REQUEST_BODY, DISCONNECT_DURING_RESPONSE_BODY, DO_NOT_READ_REQUEST_BODY, FAIL_HANDSHAKE, SHUTDOWN_INPUT_AT_END, SHUTDOWN_OUTPUT_AT_END, STALL_SOCKET_AT_START, NO_RESPONSE, RESET_STREAM_AT_START, EXPECT_CONTINUE, CONTINUE_ALWAYS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
fun sleep(durationNanos: Long) { taskRunner.lock.withLock { val sleepUntil = nanoTime + durationNanos yieldUntil { nanoTime >= sleepUntil } } } /** * Artificially stall until manually resumed by the test thread with [runTasks]. Use this to * simulate races in tasks that doesn't have a deterministic sequence. */ fun yield() { taskRunner.assertThreadDoesntHoldLock()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
*/ @Test fun unacknowledgedPingFailsConnection() { assumeNotWindows() client = client.newBuilder() .pingInterval(Duration.ofMillis(500)) .build() // Stall in onOpen to prevent pongs from being sent. val latch = CountDownLatch(1) webServer.enqueue( MockResponse.Builder() .webSocketUpgrade( object : WebSocketListener() {
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) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
SocketPolicy.FAIL_HANDSHAKE -> FailHandshake SocketPolicy.SHUTDOWN_INPUT_AT_END -> ShutdownInputAtEnd SocketPolicy.SHUTDOWN_OUTPUT_AT_END -> ShutdownOutputAtEnd SocketPolicy.STALL_SOCKET_AT_START -> StallSocketAtStart SocketPolicy.NO_RESPONSE -> NoResponse SocketPolicy.RESET_STREAM_AT_START -> ResetStreamAtStart(http2ErrorCode) else -> error("Unexpected SocketPolicy: $socketPolicy") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public static final field SHUTDOWN_OUTPUT_AT_END Lokhttp3/mockwebserver/SocketPolicy; public static final field SHUTDOWN_SERVER_AFTER_RESPONSE Lokhttp3/mockwebserver/SocketPolicy; public static final field STALL_SOCKET_AT_START Lokhttp3/mockwebserver/SocketPolicy; public static final field UPGRADE_TO_SSL_AT_END Lokhttp3/mockwebserver/SocketPolicy; public static fun getEntries ()Lkotlin/enums/EnumEntries;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") } } /** Same as the previous test, but the server stalls sending the response body. */ @Test fun bodyReadTimeoutDoesNotStartUntilLastRequestBodyByteFire() { enableProtocol(Protocol.HTTP_2) server.enqueue( MockResponse.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(peer.takeFrame().type).isEqualTo(Http2.TYPE_HEADERS) assertThat(peer.takeFrame().type).isEqualTo(Http2.TYPE_RST_STREAM) } /** * Confirm that the client times out if the server stalls after 3 bytes. After the timeout the * connection is still considered healthy while we await the degraded pong. When that doesn't * arrive the connection goes unhealthy. */ @Test fun readTimesOut() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)