- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for GOAWAY (0.04 seconds)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketEffect.kt
public class CloseSocket( public val closeSocket: Boolean = true, public val shutdownInput: Boolean = false, public val shutdownOutput: Boolean = false, ) : SocketEffect /** * On HTTP/2, send a [GOAWAY frame](https://tools.ietf.org/html/rfc7540#section-6.8) immediately * after the response and will close the connection when the client's socket is exhausted. * * On HTTP/1 this closes the socket. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 1.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2.kt
private val FRAME_NAMES = arrayOf( "DATA", "HEADERS", "PRIORITY", "RST_STREAM", "SETTINGS", "PUSH_PROMISE", "PING", "GOAWAY", "WINDOW_UPDATE", "CONTINUATION", ) /** * Lookup table for valid flags for DATA, HEADERS, CONTINUATION. Invalid combinations are * represented in binary. */Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 5.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
val pingFrame = peer.takeFrame() assertThat(pingFrame.type).isEqualTo(Http2.TYPE_PING) val goaway = peer.takeFrame() assertThat(goaway.type).isEqualTo(Http2.TYPE_GOAWAY) assertThat(goaway.streamId).isEqualTo(0) assertThat(goaway.errorCode).isEqualTo(ErrorCode.PROTOCOL_ERROR) } @Test fun close() { // Write the mocking script.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 75.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
* @param errorCode reason for closing the connection. * @param debugData only valid for HTTP/2; opaque debug data to send. */ @Throws(IOException::class) fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteArray, ) { withLock { if (closed) throw IOException("closed")Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
var debugData = ByteString.EMPTY if (opaqueDataLength > 0) { // Must read debug data in order to not corrupt the connection. debugData = source.readByteString(opaqueDataLength.toLong()) } handler.goAway(lastStreamId, errorCode, debugData) } /** Unlike other `readXxx()` functions, this one must log the frame before returning. */ @Throws(IOException::class) private fun readWindowUpdate( handler: Handler,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 19.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
lastGoodStreamId = this.lastGoodStreamId } // TODO: propagate exception message into debugData. // TODO: configure a timeout on the reader so that it doesn’t block forever. writer.goAway(lastGoodStreamId, statusCode, EMPTY_BYTE_ARRAY) } } /** * Closes this connection. This cancels all open streams and unanswered pings. It closes theCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 31.9K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
} } /** * This simulates a race condition where we receive a healthy HTTP/2 connection and just prior to * writing our request, we get a GOAWAY frame from the server. */ @Test fun connectionShutdownAfterHealthCheck() { server.enqueue( MockResponse .Builder() .body("ABC")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 67.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
) server.enqueue( MockResponse(body = "def"), ) // Send a separate request which will trigger a GOAWAY frame on the healthy connection. val response = getResponse(newRequest("/")) assertContent("abc", response) // Ensure the GOAWAY frame has time to be read and processed. Thread.sleep(500) assertContent( "def", getResponse( Request(Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 133.3K bytes - Click Count (0)