- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for GOAWAY (0.08 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/goaway_test.go
// for watch request, test GOAWAY server push 1 byte in every second. responseBody = []byte("hello") // requestPostBody is the request body which client must send to test GOAWAY server for POST method, // otherwise, test GOAWAY server will respond 400 HTTP status code. requestPostBody = responseBody ) // newTestGOAWAYServer return a test GOAWAY server instance.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:54 UTC 2021 - 13.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/server_run_options.go
"--min-request-timeout for specific types of requests.") fs.Float64Var(&s.GoawayChance, "goaway-chance", s.GoawayChance, ""+ "To prevent HTTP/2 clients from getting stuck on a single apiserver, randomly close a connection (GOAWAY). "+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:53:51 UTC 2023 - 15.4K bytes - Viewed (0) -
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) -
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/util/net/http.go
case err == io.EOF: return true case err == io.ErrUnexpectedEOF: return true case msg == "http: can't write HTTP request on broken connection": return true case strings.Contains(msg, "http2: server sent GOAWAY and closed the connection"): return true case strings.Contains(msg, "connection reset by peer"): return true case strings.Contains(strings.ToLower(msg), "use of closed network connection"): return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 05 00:08:58 UTC 2022 - 20.8K bytes - Viewed (0)