From caeb422cb2aeb3d7bff4ba44eba22cf3987ac06a Mon Sep 17 00:00:00 2001
From: Moe Jette <jette1@llnl.gov>
Date: Mon, 23 Sep 2002 21:36:03 +0000
Subject: [PATCH] Added support for ping RPC. slurmctld now will ping slurmd
periodically and flag non-responsive nodes as such. slurmd now responds to
ping RPC.
---
src/slurmd/slurmd.c | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/src/slurmd/slurmd.c b/src/slurmd/slurmd.c
index 9c1cd2f1e18..870043f4fd3 100644
--- a/src/slurmd/slurmd.c
+++ b/src/slurmd/slurmd.c
@@ -88,6 +88,7 @@ inline static int send_node_registration_status_msg();
inline static void slurm_rpc_kill_tasks(slurm_msg_t * msg);
inline static void slurm_rpc_launch_tasks(slurm_msg_t * msg);
+inline static void slurm_rpc_ping(slurm_msg_t * msg);
inline static void slurm_rpc_reattach_tasks_streams(slurm_msg_t * msg);
inline static void slurm_rpc_revoke_credential(slurm_msg_t * msg);
inline static void slurmd_rpc_shutdown_slurmd(slurm_msg_t * msg);
@@ -425,6 +426,9 @@ void slurmd_req(slurm_msg_t * msg)
case REQUEST_SHUTDOWN_IMMEDIATE:
slurmd_rpc_shutdown_slurmd(msg);
break;
+ case REQUEST_PING:
+ slurm_rpc_ping(msg);
+ break;
default:
error("slurmd_req: invalid request msg type %d\n",
msg->msg_type);
@@ -482,6 +486,12 @@ void slurm_rpc_launch_tasks(slurm_msg_t * msg)
}
}
+/* Just respond to ping */
+void slurm_rpc_ping(slurm_msg_t * msg)
+{
+ slurm_send_rc_msg(msg, SLURM_SUCCESS);
+}
+
/* Kills Launched Tasks */
void slurm_rpc_kill_tasks(slurm_msg_t * msg)
{
--
GitLab