From f0edbf0d3046c5c721c8c5d7a7615ca6c8874f40 Mon Sep 17 00:00:00 2001 From: Tao Wang Date: Tue, 24 Aug 2021 11:27:35 +0800 Subject: [PATCH] [Core]make thread of client manager in gcs server configurable (#17978) --- src/ray/common/ray_config_def.h | 4 +++- src/ray/gcs/gcs_server/gcs_server.cc | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/ray/common/ray_config_def.h b/src/ray/common/ray_config_def.h index 6a0860108..7365f6937 100644 --- a/src/ray/common/ray_config_def.h +++ b/src/ray/common/ray_config_def.h @@ -213,7 +213,9 @@ RAY_CONFIG(int32_t, maximum_profile_table_rows_count, 10 * 1000) 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) +RAY_CONFIG(uint32_t, gcs_server_rpc_server_thread_num, 4) +/// Number of threads used by client call manager in gcs server. +RAY_CONFIG(uint32_t, gcs_server_rpc_client_thread_num, 4) /// 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.cc b/src/ray/gcs/gcs_server/gcs_server.cc index 610762f97..8cc4f8de7 100644 --- a/src/ray/gcs/gcs_server/gcs_server.cc +++ b/src/ray/gcs/gcs_server/gcs_server.cc @@ -36,7 +36,9 @@ GcsServer::GcsServer(const ray::gcs::GcsServerConfig &config, main_service_(main_service), rpc_server_(config.grpc_server_name, config.grpc_server_port, config.grpc_server_thread_num), - client_call_manager_(main_service), + client_call_manager_( + main_service, + /*num_threads=*/RayConfig::instance().gcs_server_rpc_client_thread_num()), raylet_client_pool_( std::make_shared(client_call_manager_)), pubsub_periodical_runner_(main_service_) {}