- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for GOAWAY (0.09 sec)
-
pilot/pkg/grpc/grpc.go
grpc.MaxRecvMsgSize(maxRecvMsgSize), // Ensure we allow clients sufficient ability to send keep alives. If this is higher than client // keep alive setting, it will prematurely get a GOAWAY sent. grpc.KeepaliveEnforcementPolicy(keepalive.EnforcementPolicy{ MinTime: options.Time / 2, }), grpc.KeepaliveParams(keepalive.ServerParameters{ Time: options.Time,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 04:27:50 UTC 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY * frame) and an attempt is made to use the connection. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 875 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt
fail("") } override fun ackSettings() { fail("") } override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { fail("") } override fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteString, ) { fail("") } override fun windowUpdate( streamId: Int, windowSizeIncrement: Long, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/authentication.go
if utilfeature.DefaultFeatureGate.Enabled(genericfeatures.UnauthenticatedHTTP2DOSMitigation) && req.ProtoMajor == 2 && isAnonymousUser(resp.User) { // limit this connection to just this request, // and then send a GOAWAY and tear down the TCP connection // https://github.com/golang/net/commit/97aa3a539ec716117a9d15a4659a911f50d13c3c w.Header().Set("Connection", "close") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 6.4K 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/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.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
/** Lookup table for valid frame types. */ 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. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.7K 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) -
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) -
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)