From 8395f097e4300029493fe8601ffdb16d871a5413 Mon Sep 17 00:00:00 2001 From: Matthew Stevenson Date: Sun, 20 Oct 2024 12:46:49 -0700 Subject: [PATCH] Update max concurrent streams. --- src/core/tsi/alts/handshaker/alts_handshaker_client.cc | 4 ++-- .../core/tsi/alts/handshaker/alts_handshaker_client_test.cc | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/core/tsi/alts/handshaker/alts_handshaker_client.cc b/src/core/tsi/alts/handshaker/alts_handshaker_client.cc index 62cbe099c5a..cc1870eef09 100644 --- a/src/core/tsi/alts/handshaker/alts_handshaker_client.cc +++ b/src/core/tsi/alts/handshaker/alts_handshaker_client.cc @@ -929,11 +929,11 @@ void alts_handshaker_client_destroy(alts_handshaker_client* c) { } size_t MaxNumberOfConcurrentHandshakes() { - size_t max_concurrent_handshakes = 40; + size_t max_concurrent_handshakes = 100; absl::optional env_var_max_concurrent_handshakes = grpc_core::GetEnv(kMaxConcurrentStreamsEnvironmentVariable); if (env_var_max_concurrent_handshakes.has_value()) { - size_t effective_max_concurrent_handshakes = 40; + size_t effective_max_concurrent_handshakes = 100; if (absl::SimpleAtoi(*env_var_max_concurrent_handshakes, &effective_max_concurrent_handshakes)) { max_concurrent_handshakes = effective_max_concurrent_handshakes; diff --git a/test/core/tsi/alts/handshaker/alts_handshaker_client_test.cc b/test/core/tsi/alts/handshaker/alts_handshaker_client_test.cc index 8b8a8866a93..72e849a9d43 100644 --- a/test/core/tsi/alts/handshaker/alts_handshaker_client_test.cc +++ b/test/core/tsi/alts/handshaker/alts_handshaker_client_test.cc @@ -512,17 +512,17 @@ TEST(AltsHandshakerClientTest, ScheduleRequestGrpcCallFailureTest) { TEST(MaxNumberOfConcurrentHandshakesTest, Default) { grpc_core::UnsetEnv(kMaxConcurrentStreamsEnvironmentVariable); - EXPECT_EQ(MaxNumberOfConcurrentHandshakes(), 40); + EXPECT_EQ(MaxNumberOfConcurrentHandshakes(), 100); } TEST(MaxNumberOfConcurrentHandshakesTest, EnvVarNotInt) { grpc_core::SetEnv(kMaxConcurrentStreamsEnvironmentVariable, "not-a-number"); - EXPECT_EQ(MaxNumberOfConcurrentHandshakes(), 40); + EXPECT_EQ(MaxNumberOfConcurrentHandshakes(), 100); } TEST(MaxNumberOfConcurrentHandshakesTest, EnvVarNegative) { grpc_core::SetEnv(kMaxConcurrentStreamsEnvironmentVariable, "-10"); - EXPECT_EQ(MaxNumberOfConcurrentHandshakes(), 40); + EXPECT_EQ(MaxNumberOfConcurrentHandshakes(), 100); } TEST(MaxNumberOfConcurrentHandshakesTest, EnvVarSuccess) {