From 4dd0aa78225b9b7175b07205e5bce03b8354194a Mon Sep 17 00:00:00 2001 From: Tao Wang Date: Wed, 25 Nov 2020 11:40:29 +0800 Subject: [PATCH] [GCS]make thread number of gcs rpc server configurable (#12257) --- src/ray/common/ray_config_def.h | 2 ++ src/ray/gcs/gcs_server/gcs_server_main.cc | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/ray/common/ray_config_def.h b/src/ray/common/ray_config_def.h index 7559e5392..85b8a21a7 100644 --- a/src/ray/common/ray_config_def.h +++ b/src/ray/common/ray_config_def.h @@ -221,6 +221,8 @@ RAY_CONFIG(uint32_t, object_store_get_warn_per_num_attempts, 50) /// message. RAY_CONFIG(uint32_t, object_store_get_max_ids_to_print_in_warning, 20) +/// Number of threads used by rpc server in gcs server. +RAY_CONFIG(uint32_t, gcs_server_rpc_server_thread_num, 1) /// Allow up to 5 seconds for connecting to gcs service. /// Note: this only takes effect when gcs service is enabled. RAY_CONFIG(int64_t, gcs_service_connect_retries, 50) diff --git a/src/ray/gcs/gcs_server/gcs_server_main.cc b/src/ray/gcs/gcs_server/gcs_server_main.cc index 6c3879ca2..a89d8ead0 100644 --- a/src/ray/gcs/gcs_server/gcs_server_main.cc +++ b/src/ray/gcs/gcs_server/gcs_server_main.cc @@ -74,7 +74,8 @@ int main(int argc, char *argv[]) { ray::gcs::GcsServerConfig gcs_server_config; gcs_server_config.grpc_server_name = "GcsServer"; gcs_server_config.grpc_server_port = gcs_server_port; - gcs_server_config.grpc_server_thread_num = 1; + gcs_server_config.grpc_server_thread_num = + RayConfig::instance().gcs_server_rpc_server_thread_num(); gcs_server_config.redis_address = redis_address; gcs_server_config.redis_port = redis_port; gcs_server_config.redis_password = redis_password;