hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-05 18:11:42 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[Core]make thread of client manager in gcs server configurable (#17978)

Browse source
This commit is contained in:
Tao Wang 2021-08-24 11:27:35 +08:00 • committed by GitHub
parent 15adedc72c
commit f0edbf0d30
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/ray/common/ray_config_def.h
View file

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

4
src/ray/gcs/gcs_server/gcs_server.cc
View file

@ -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<rpc::NodeManagerClientPool>(client_call_manager_)),
pubsub_periodical_runner_(main_service_) {}