wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-10 23:41:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

[GCS]Remove useless / heavy heartbeat pub (#11132)

Browse Source
This commit is contained in:
Tao Wang
2020-09-30 14:38:17 +08:00
committed by GitHub
parent 03c11d3b85
commit 15ae8816f7
3 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/gcs_utils.py
-1
View File
@@ -54,7 +54,6 @@ LOG_FILE_CHANNEL = "RAY_LOG_CHANNEL"
REPORTER_CHANNEL = "RAY_REPORTER"
# xray heartbeats
XRAY_HEARTBEAT_PATTERN = "HEARTBEAT:*".encode("ascii")
XRAY_HEARTBEAT_BATCH_PATTERN = "HEARTBEAT_BATCH:".encode("ascii")
# xray job updates
src/ray/gcs/gcs_server/gcs_node_manager.cc
-2
View File
@@ -241,8 +241,6 @@ void GcsNodeManager::HandleReportHeartbeat(const rpc::ReportHeartbeatRequest &re
node_failure_detector_->HandleHeartbeat(node_id, *heartbeat_data);
});
GCS_RPC_SEND_REPLY(send_reply_callback, reply, Status::OK());
RAY_CHECK_OK(gcs_pub_sub_->Publish(HEARTBEAT_CHANNEL, node_id.Hex(),
heartbeat_data->SerializeAsString(), nullptr));
}
void GcsNodeManager::HandleGetResources(const rpc::GetResourcesRequest &request,
src/ray/gcs/pubsub/gcs_pub_sub.h
-1
View File
@@ -32,7 +32,6 @@ namespace gcs {
#define OBJECT_CHANNEL "OBJECT"
#define TASK_CHANNEL "TASK"
#define TASK_LEASE_CHANNEL "TASK_LEASE"
#define HEARTBEAT_CHANNEL "HEARTBEAT"
#define HEARTBEAT_BATCH_CHANNEL "HEARTBEAT_BATCH"
#define ERROR_INFO_CHANNEL "ERROR_INFO"