wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-29 23:42:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Core] Announce worker port at end of constructor (#11036)

Browse Source
This commit is contained in:
Stephanie Wang
2020-09-25 21:56:00 -07:00
committed by GitHub
parent 29663d89f1
commit 552ebdbeda
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/core_worker/core_worker.cc
+4 -4
View File
@@ -335,10 +335,6 @@ CoreWorker::CoreWorker(const CoreWorkerOptions &options, const WorkerID &worker_
core_worker_server_->RegisterService(grpc_service_);
core_worker_server_->Run();
// Tell the raylet the port that we are listening on.
// NOTE: This also marks the worker as available in Raylet.
RAY_CHECK_OK(local_raylet_client_->AnnounceWorkerPort(core_worker_server_->GetPort()));
// Set our own address.
RAY_CHECK(!local_raylet_id.IsNil());
rpc_address_.set_ip_address(options_.node_ip_address);
@@ -532,6 +528,10 @@ CoreWorker::CoreWorker(const CoreWorkerOptions &options, const WorkerID &worker_
// Start the IO thread after all other members have been initialized, in case
// the thread calls back into any of our members.
io_thread_ = std::thread(&CoreWorker::RunIOService, this);
// Tell the raylet the port that we are listening on.
// NOTE: This also marks the worker as available in Raylet. We do this at the
// very end in case there is a problem during construction.
RAY_CHECK_OK(local_raylet_client_->AnnounceWorkerPort(core_worker_server_->GetPort()));
}
void CoreWorker::Shutdown() {