- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for GOAWAY (0.23 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
payload2: Int, ) { check(type == -1) type = Http2.TYPE_PING this.ack = ack this.payload1 = payload1 this.payload2 = payload2 } override fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteString, ) { check(type == -1) this.type = Http2.TYPE_GOAWAY this.streamId = lastGoodStreamId
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/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,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/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, ) { this.withLock { if (closed) throw IOException("closed")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/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 the
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
// GoawayChance is the probability that send a GOAWAY to HTTP/2 clients. When client received // GOAWAY, the in-flight requests will not be affected and new requests will use // a new TCP connection to triggering re-balancing to another server behind the load balance. // Default to 0, means never send GOAWAY. Max is 0.02 to prevent break the apiserver. GoawayChance float64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
okhttp/src/test/java/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. */ @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun connectionShutdownAfterHealthCheck( protocol: Protocol, mockWebServer: MockWebServer,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/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(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0)