- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 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) -
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/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) -
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)