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

In srun, log if a job allocation is revoked while waiting for resources.

parent 78de8d9e
No related branches found
No related tags found
No related merge requests found
...@@ -126,6 +126,8 @@ static void _signal_while_allocating(int signo) ...@@ -126,6 +126,8 @@ static void _signal_while_allocating(int signo)
destroy_job = 1; destroy_job = 1;
if (pending_job_id != 0) { if (pending_job_id != 0) {
slurm_complete_job(pending_job_id, NO_VAL); slurm_complete_job(pending_job_id, NO_VAL);
info("Job allocation %u has been revoked.", pending_job_id);
} }
} }
...@@ -438,6 +440,8 @@ allocate_nodes(void) ...@@ -438,6 +440,8 @@ allocate_nodes(void)
/* create message thread to handle pings and such from slurmctld */ /* create message thread to handle pings and such from slurmctld */
msg_thr = slurm_allocation_msg_thr_create(&j->other_port, &callbacks); msg_thr = slurm_allocation_msg_thr_create(&j->other_port, &callbacks);
/* NOTE: Do not process signals in separate pthread. The signal will
* cause slurm_allocate_resources_blocking() to exit immediately. */
xsignal_unblock(sig_array); xsignal_unblock(sig_array);
for (i = 0; sig_array[i]; i++) for (i = 0; sig_array[i]; i++)
xsignal(sig_array[i], _signal_while_allocating); xsignal(sig_array[i], _signal_while_allocating);
...@@ -448,7 +452,7 @@ allocate_nodes(void) ...@@ -448,7 +452,7 @@ allocate_nodes(void)
if (destroy_job) { if (destroy_job) {
/* cancelled by signal */ /* cancelled by signal */
break; break;
} else if(!resp && !_retry()) { } else if (!resp && !_retry()) {
break; break;
} }
} }
......
...@@ -56,7 +56,7 @@ expect { ...@@ -56,7 +56,7 @@ expect {
send_user "\nSent SIGINT\n" send_user "\nSent SIGINT\n"
exp_continue exp_continue
} }
-re "Terminated job" { -re "Job allocation ($number) has been revoked" {
incr matches incr matches
exp_continue exp_continue
} }
......
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