- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for MaxConcurrentStreams (0.27 sec)
-
pilot/pkg/networking/core/cluster_traffic_policy.go
} // Check if cluster is HTTP2 http2ProtocolOptions := options.GetExplicitHttpConfig().GetHttp2ProtocolOptions() if http2ProtocolOptions != nil && maxConcurrentStreams > 0 { http2ProtocolOptions.MaxConcurrentStreams = &wrapperspb.UInt32Value{Value: maxConcurrentStreams} } } if settings.Http != nil && settings.Http.UseClientProtocol { // Use downstream protocol. If the incoming traffic use HTTP 1.1, the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
http2Options.MaxConcurrentStreams = uint32(s.HTTP2MaxStreamsPerConnection) } else { // match http2.initialMaxConcurrentStreams used by clients // this makes it so that a malicious client can only open 400 streams before we forcibly close the connection // https://github.com/golang/net/commit/b225e7ca6dde1ef5a5ae5ce922861bda011cfabd http2Options.MaxConcurrentStreams = 100 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
pilot/pkg/grpc/grpc.go
maxStreams := features.MaxConcurrentStreams maxRecvMsgSize := features.MaxRecvMsgSize grpcOptions := []grpc.ServerOption{ grpc.UnaryInterceptor(middleware.ChainUnaryServer(interceptors...)), grpc.MaxConcurrentStreams(uint32(maxStreams)), grpc.MaxRecvMsgSize(maxRecvMsgSize),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 04:27:50 UTC 2024 - 4.2K bytes - Viewed (0) -
security/pkg/nodeagent/sds/server.go
if !started { sdsServiceLog.Warn("SDS grpc server could not be started") } }() } func (s *Server) grpcServerOptions() []grpc.ServerOption { grpcOptions := []grpc.ServerOption{ grpc.MaxConcurrentStreams(uint32(maxStreams)), } return grpcOptions
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 17:44:41 UTC 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
} private fun connectHttp2( peer: MockHttp2Peer, realConnection: RealConnection, maxConcurrentStreams: Int, ): Http2Connection { // Write the mocking script. val settings1 = Settings() settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams peer.sendFrame().settings(settings1) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 0)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/features/tuning.go
// limitations under the License. package features import ( "runtime" "time" "istio.io/istio/pkg/env" ) // Define performance tuning related features here. var ( MaxConcurrentStreams = env.Register( "ISTIO_GPRC_MAXSTREAMS", 100000, "Sets the maximum number of concurrent grpc streams.", ).Get() // MaxRecvMsgSize The max receive buffer size of gRPC received channel of Pilot in bytes.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 04:22:19 UTC 2024 - 4.8K bytes - Viewed (0) -
src/net/http/h2_bundle.go
MaxHandlers int // MaxConcurrentStreams optionally specifies the number of // concurrent streams that each client may have open at a // time. This is unrelated to the number of http.Handler goroutines // which may be active globally, which is MaxHandlers. // If zero, MaxConcurrentStreams defaults to at least 100, per // the HTTP/2 spec's recommendations. MaxConcurrentStreams uint32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/crd-all.gen.yaml
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:42 UTC 2024 - 671.7K bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:42 UTC 2024 - 671.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 0) peer.acceptFrame() // PING peer.play() // Play it back. val maxConcurrentStreamsUpdated = CountDownLatch(1) val maxConcurrentStreams = AtomicInteger() val listener: Http2Connection.Listener = object : Http2Connection.Listener() { override fun onStream(stream: Http2Stream) { throw AssertionError() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0)