| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/frame/ |
| D | settings.rs | 12 max_concurrent_streams: Option<u32>, field
77 pub fn max_concurrent_streams(&self) -> Option<u32> { in max_concurrent_streams() method
78 self.max_concurrent_streams in max_concurrent_streams()
82 self.max_concurrent_streams = max; in set_max_concurrent_streams()
173 settings.max_concurrent_streams = Some(val); in load()
240 if let Some(v) = self.max_concurrent_streams { in for_each()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tonic/src/transport/server/ |
| D | mod.rs | 89 max_concurrent_streams: Option<u32>, field
111 max_concurrent_streams: None, in default()
227 pub fn max_concurrent_streams(self, max: impl Into<Option<u32>>) -> Self { in max_concurrent_streams() method
229 max_concurrent_streams: max.into(), in max_concurrent_streams()
477 max_concurrent_streams: self.max_concurrent_streams, in layer()
512 let max_concurrent_streams = self.max_concurrent_streams; in serve_with_shutdown() localVariable
541 .http2_max_concurrent_streams(max_concurrent_streams) in serve_with_shutdown()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/proto/h2/ |
| D | server.rs | 50 pub(crate) max_concurrent_streams: Option<u32>, field
68 max_concurrent_streams: None, in default()
129 if let Some(max) = config.max_concurrent_streams { in new()
130 builder.max_concurrent_streams(max); in new()
|
| /aosp_15_r20/external/grpc-grpc/test/core/transport/chttp2/ |
| H A D | http2_settings_test.cc | 34 EXPECT_EQ(settings.max_concurrent_streams(), 3u); in TEST()
50 EXPECT_EQ(settings.max_concurrent_streams(), 30u); in TEST()
395 EXPECT_EQ(settings.max_concurrent_streams(), 1u); in TEST()
397 EXPECT_EQ(settings.max_concurrent_streams(), 0x7fffffffu); in TEST()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/server/conn/ |
| D | http2.rs | 173 pub fn max_concurrent_streams(&mut self, max: impl Into<Option<u32>>) -> &mut Self { in max_concurrent_streams() method
174 self.h2_builder.max_concurrent_streams = max.into(); in max_concurrent_streams()
|
| /aosp_15_r20/external/curl/lib/ |
| H A D | http2.c | 141 uint32_t max_concurrent_streams; member
544 ctx->max_concurrent_streams = DEFAULT_MAX_CONCURRENT_STREAMS; in cf_h2_ctx_open()
1322 uint32_t max_conn = ctx->max_concurrent_streams; in on_frame_recv()
1323 ctx->max_concurrent_streams = nghttp2_session_get_remote_settings( in on_frame_recv()
1328 ctx->max_concurrent_streams); in on_frame_recv()
1331 if(data && max_conn != ctx->max_concurrent_streams) { in on_frame_recv()
1334 ctx->max_concurrent_streams); in on_frame_recv()
2710 effective_max = ctx->max_concurrent_streams; in cf_h2_query()
|
| H A D | multihandle.h | 169 unsigned int max_concurrent_streams; member
|
| H A D | multi.c | 426 multi->max_concurrent_streams = 100; in Curl_multi_handle()
3688 multi->max_concurrent_streams = (unsigned int)streams;
4124 return multi->max_concurrent_streams;
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| H A D | http2_settings.h | 54 uint32_t max_concurrent_streams() const { return max_concurrent_streams_; } in max_concurrent_streams() function
|
| H A D | parsing.cc | 646 t->settings.acked().max_concurrent_streams())) { in init_header_frame_parser()
670 t->settings.acked().max_concurrent_streams()) in init_header_frame_parser()
|
| H A D | chttp2_transport.cc | 652 settings.local().max_concurrent_streams(); in grpc_chttp2_transport()
1214 t->stream_map.size() < t->settings.peer().max_concurrent_streams() && in maybe_start_some_streams()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/streams/ |
| D | counts.rs | 183 match settings.max_concurrent_streams() { in apply_remote_settings()
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | records.pyx.pxi | 45 max_concurrent_streams = GRPC_ARG_MAX_CONCURRENT_STREAMS variable in ChannelArgKey
|
| /aosp_15_r20/external/grpc-grpc-java/xds/third_party/envoy/src/main/proto/envoy/api/v2/core/ |
| H A D | protocol.proto | 176 google.protobuf.UInt32Value max_concurrent_streams = 2
283 // 0x3 max_concurrent_streams
|
| /aosp_15_r20/external/cronet/net/spdy/ |
| H A D | spdy_session_unittest.cc | 296 size_t max_concurrent_streams() { return session_->max_concurrent_streams_; } in max_concurrent_streams() function in net::SpdySessionTest
298 void set_max_concurrent_streams(size_t max_concurrent_streams) { in set_max_concurrent_streams() argument
299 session_->max_concurrent_streams_ = max_concurrent_streams; in set_max_concurrent_streams()
1524 EXPECT_EQ(0u, max_concurrent_streams()); in TEST_F()
1542 EXPECT_EQ(1u, max_concurrent_streams()); in TEST_F()
1775 const uint32_t max_concurrent_streams = in TEST_F() local
1777 new_settings[kSpdySettingsId] = max_concurrent_streams; in TEST_F()
2609 const uint32_t max_concurrent_streams = 1; in TEST_F() local
2610 new_settings[kSpdySettingsId1] = max_concurrent_streams; in TEST_F()
|
| H A D | spdy_session_pool_unittest.cc | 90 size_t max_concurrent_streams(base::WeakPtr<SpdySession> session) { in max_concurrent_streams() function in net::SpdySessionPoolTest
1940 EXPECT_EQ(2u, max_concurrent_streams(session)); in TEST_F()
2036 EXPECT_EQ(0u, max_concurrent_streams(session)); in TEST_F()
|
| H A D | spdy_network_transaction_unittest.cc | 1195 const uint32_t max_concurrent_streams = 1; in TEST_P() local
1196 settings[spdy::SETTINGS_MAX_CONCURRENT_STREAMS] = max_concurrent_streams; in TEST_P()
1324 const uint32_t max_concurrent_streams = 1; in TEST_P() local
1325 settings[spdy::SETTINGS_MAX_CONCURRENT_STREAMS] = max_concurrent_streams; in TEST_P()
1455 const uint32_t max_concurrent_streams = 1; in TEST_P() local
1456 settings[spdy::SETTINGS_MAX_CONCURRENT_STREAMS] = max_concurrent_streams; in TEST_P()
1576 const uint32_t max_concurrent_streams = 1; in TEST_P() local
1577 settings[spdy::SETTINGS_MAX_CONCURRENT_STREAMS] = max_concurrent_streams; in TEST_P()
|
| H A D | spdy_session.cc | 334 size_t max_concurrent_streams, in NetLogSpdySessionStalledParams() argument
339 .Set("max_concurrent_streams", static_cast<int>(max_concurrent_streams)) in NetLogSpdySessionStalledParams()
|
| /aosp_15_r20/external/grpc-grpc-java/xds/third_party/envoy/src/main/proto/envoy/config/core/v3/ |
| H A D | protocol.proto | 63 google.protobuf.UInt32Value max_concurrent_streams = 1 [(validate.rules).uint32 = {gte: 1}]; field
444 google.protobuf.UInt32Value max_concurrent_streams = 2
570 // 0x3 max_concurrent_streams
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/ |
| D | client.rs | 848 pub fn max_concurrent_streams(&mut self, max: u32) -> &mut Self { in max_concurrent_streams() method
|
| D | server.rs | 841 pub fn max_concurrent_streams(&mut self, max: u32) -> &mut Self { in max_concurrent_streams() method
|
| /aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/ |
| D | connection.rs | 123 .max_concurrent_streams() in new()
|
| /aosp_15_r20/external/grpc-grpc/test/core/end2end/ |
| H A D | BUILD | 365 grpc_core_end2end_test(name = "max_concurrent_streams")
|
| /aosp_15_r20/external/rust/android-crates-io/crates/hyper/src/server/ |
| D | conn.rs | 494 self.h2_builder.max_concurrent_streams = max.into(); in http2_max_concurrent_streams()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/patches/ |
| D | android-dir.patch | 237 +pub const GRPC_ARG_MAX_CONCURRENT_STREAMS: &[u8; 28] = b"grpc.max_concurrent_streams\0";
|