Update max concurrent streams.

pull/37966/head
Matthew Stevenson 4 months ago
parent e8addfac9e
commit 8395f097e4
  1. 4
      src/core/tsi/alts/handshaker/alts_handshaker_client.cc
  2. 6
      test/core/tsi/alts/handshaker/alts_handshaker_client_test.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<std::string> 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;

@ -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) {

Loading…
Cancel
Save