wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-09-12 12:51:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Notify listeners after registered node stored (#13069)

Browse Source
This commit is contained in:
Tao Wang
2021-01-05 11:18:03 +08:00
committed by GitHub
parent 88eaa87e3a
commit a0bbf2bfc2
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ray/gcs/gcs_server/gcs_node_manager.cc
+1 -1
View File
@@ -33,7 +33,6 @@ void GcsNodeManager::HandleRegisterNode(const rpc::RegisterNodeRequest &request,
NodeID node_id = NodeID::FromBinary(request.node_info().node_id()); NodeID node_id = NodeID::FromBinary(request.node_info().node_id());
RAY_LOG(INFO) << "Registering node info, node id = " << node_id RAY_LOG(INFO) << "Registering node info, node id = " << node_id
<< ", address = " << request.node_info().node_manager_address(); << ", address = " << request.node_info().node_manager_address();
AddNode(std::make_shared<rpc::GcsNodeInfo>(request.node_info()));
auto on_done = [this, node_id, request, reply, auto on_done = [this, node_id, request, reply,
send_reply_callback](const Status &status) { send_reply_callback](const Status &status) {
RAY_CHECK_OK(status); RAY_CHECK_OK(status);
@@ -41,6 +40,7 @@ void GcsNodeManager::HandleRegisterNode(const rpc::RegisterNodeRequest &request,
<< ", address = " << request.node_info().node_manager_address(); << ", address = " << request.node_info().node_manager_address();
RAY_CHECK_OK(gcs_pub_sub_->Publish(NODE_CHANNEL, node_id.Hex(), RAY_CHECK_OK(gcs_pub_sub_->Publish(NODE_CHANNEL, node_id.Hex(),
request.node_info().SerializeAsString(), nullptr)); request.node_info().SerializeAsString(), nullptr));
AddNode(std::make_shared<rpc::GcsNodeInfo>(request.node_info()));
GCS_RPC_SEND_REPLY(send_reply_callback, reply, status); GCS_RPC_SEND_REPLY(send_reply_callback, reply, status);
}; };
RAY_CHECK_OK( RAY_CHECK_OK(