- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 30 for GOAWAY (0.11 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
assertThat(sendGoAway(expectedStreamId, expectedError, EMPTY_BYTE_ARRAY)) .isEqualTo(frame) reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteString, ) { assertThat(lastGoodStreamId).isEqualTo(expectedStreamId)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 28.1K bytes - Viewed (0) -
src/net/http/h2_bundle.go
cc.mu.Lock() defer cc.mu.Unlock() old := cc.goAway cc.goAway = f // Merge the previous and current GoAway error frames. if cc.goAwayDebug == "" { cc.goAwayDebug = string(f.DebugData()) } if old != nil && old.ErrCode != http2ErrCodeNo { cc.goAway.ErrCode = old.ErrCode } last := f.LastStreamID for streamID, cs := range cc.streams {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/with_retry_after.go
// // Copied from net/http2 library // "Connection" headers aren't allowed in HTTP/2 (RFC 7540, 8.1.2.2), // but respect "Connection" == "close" to mean sending a GOAWAY and tearing // down the TCP connection when idle, like we do for HTTP/1. if params.TearDownConnection { w.Header().Set("Connection", "close") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 31 14:10:46 UTC 2021 - 4.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt
assertThat(frameLog(true, 3, 226, TYPE_DATA, FLAG_END_STREAM)) .isEqualTo("<< 0x00000003 226 DATA END_STREAM") assertThat(frameLog(false, 0, 8, TYPE_GOAWAY, FLAG_NONE)) .isEqualTo(">> 0x00000000 8 GOAWAY ") } /** Window update frames have special formatting. */ @Test fun windowUpdateFrames() { assertThat(frameLogWindowUpdate(false, 0, 4, Int.MAX_VALUE.toLong()))
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/keepalive/options.go
// the connection is closed. Timeout time.Duration // MaxServerConnectionAge is a duration for the maximum amount of time a // connection may exist before it will be closed by the server sending a GoAway. // A random jitter is added to spread out connection storms. // See https://github.com/grpc/grpc-go/blob/bd0b3b2aa2a9c87b323ee812359b0e9cda680dad/keepalive/keepalive.go#L49
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.9K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
a network error similar to 'connection refused' - the HTTP Server waits gracefully for existing requests to complete up to '60s' (dictated by ShutdownTimeout) - active long running requests will receive a GOAWAY. T0+70s: HTTPServerStoppedListening: - this event is signaled when the HTTP Server has stopped listening which is immediately after server.Shutdown has been invoked
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K 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) -
staging/src/k8s.io/apimachinery/pkg/util/net/http_test.go
name: "with broken connection error", err: fmt.Errorf("http: can't write HTTP request on broken connection"), expected: true, }, { name: "with server sent GOAWAY error", err: fmt.Errorf("error foo - http2: server sent GOAWAY and closed the connection - error bar"), expected: true, }, { name: "with connection reset by peer error",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 18 01:21:56 UTC 2023 - 24.5K 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)