Skip to content
Snippets Groups Projects
Commit b6c315b1 authored by Moe Jette's avatar Moe Jette
Browse files

Minor code restructuring to eliminate potential memory leak.

parent ec11e5a8
No related branches found
No related tags found
No related merge requests found
...@@ -73,6 +73,8 @@ static void _wait_for_procs(uint32_t job_id, uid_t job_uid); ...@@ -73,6 +73,8 @@ static void _wait_for_procs(uint32_t job_id, uid_t job_uid);
void void
slurmd_req(slurm_msg_t *msg, slurm_addr *cli) slurmd_req(slurm_msg_t *msg, slurm_addr *cli)
{ {
int rc;
switch(msg->msg_type) { switch(msg->msg_type) {
case REQUEST_BATCH_JOB_LAUNCH: case REQUEST_BATCH_JOB_LAUNCH:
_rpc_batch_job(msg, cli); _rpc_batch_job(msg, cli);
...@@ -112,11 +114,11 @@ slurmd_req(slurm_msg_t *msg, slurm_addr *cli) ...@@ -112,11 +114,11 @@ slurmd_req(slurm_msg_t *msg, slurm_addr *cli)
break; break;
case REQUEST_NODE_REGISTRATION_STATUS: case REQUEST_NODE_REGISTRATION_STATUS:
/* Treat as ping (for slurmctld agent) */ /* Treat as ping (for slurmctld agent) */
if (_rpc_ping(msg, cli) == SLURM_SUCCESS) { rc = _rpc_ping(msg, cli);
/* Then initiate a separate node registration */ slurm_free_node_registration_status_msg(msg->data);
slurm_free_node_registration_status_msg(msg->data); /* Then initiate a separate node registration */
if (rc == SLURM_SUCCESS)
send_registration_msg(SLURM_SUCCESS); send_registration_msg(SLURM_SUCCESS);
}
break; break;
case REQUEST_PING: case REQUEST_PING:
_rpc_ping(msg, cli); _rpc_ping(msg, cli);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment