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

Misc submit bug fixes

parent 67fec471
No related branches found
No related tags found
No related merge requests found
...@@ -28,6 +28,7 @@ slurm_allocate_resources (job_desc_msg_t * job_desc_msg , resource_allocation_re ...@@ -28,6 +28,7 @@ slurm_allocate_resources (job_desc_msg_t * job_desc_msg , resource_allocation_re
slurm_msg_t request_msg ; slurm_msg_t request_msg ;
slurm_msg_t response_msg ; slurm_msg_t response_msg ;
return_code_msg_t * slurm_rc_msg ; return_code_msg_t * slurm_rc_msg ;
resource_allocation_response_msg_t * slurm_alloc_msg;
/* init message connection for message communication with controller */ /* init message connection for message communication with controller */
if ( ( sockfd = slurm_open_controller_conn ( ) ) == SLURM_SOCKET_ERROR ) if ( ( sockfd = slurm_open_controller_conn ( ) ) == SLURM_SOCKET_ERROR )
...@@ -63,6 +64,11 @@ slurm_allocate_resources (job_desc_msg_t * job_desc_msg , resource_allocation_re ...@@ -63,6 +64,11 @@ slurm_allocate_resources (job_desc_msg_t * job_desc_msg , resource_allocation_re
slurm_rc_msg = ( return_code_msg_t * ) response_msg . data ; slurm_rc_msg = ( return_code_msg_t * ) response_msg . data ;
return (int) slurm_rc_msg->return_code; return (int) slurm_rc_msg->return_code;
break ; break ;
case RESPONSE_RESOURCE_ALLOCATION:
slurm_alloc_msg = ( resource_allocation_response_msg_t * ) response_msg . data ;
job_desc_msg->job_id = slurm_alloc_msg->job_id;
return 0;
break ;
default: default:
return SLURM_UNEXPECTED_MSG_ERROR ; return SLURM_UNEXPECTED_MSG_ERROR ;
break ; break ;
...@@ -79,6 +85,7 @@ int slurm_job_will_run (job_desc_msg_t * job_desc_msg , resource_allocation_resp ...@@ -79,6 +85,7 @@ int slurm_job_will_run (job_desc_msg_t * job_desc_msg , resource_allocation_resp
slurm_msg_t request_msg ; slurm_msg_t request_msg ;
slurm_msg_t response_msg ; slurm_msg_t response_msg ;
return_code_msg_t * slurm_rc_msg ; return_code_msg_t * slurm_rc_msg ;
resource_allocation_response_msg_t * slurm_alloc_msg;
/* init message connection for message communication with controller */ /* init message connection for message communication with controller */
if ( ( sockfd = slurm_open_controller_conn ( ) ) == SLURM_SOCKET_ERROR ) if ( ( sockfd = slurm_open_controller_conn ( ) ) == SLURM_SOCKET_ERROR )
...@@ -104,6 +111,11 @@ int slurm_job_will_run (job_desc_msg_t * job_desc_msg , resource_allocation_resp ...@@ -104,6 +111,11 @@ int slurm_job_will_run (job_desc_msg_t * job_desc_msg , resource_allocation_resp
slurm_rc_msg = ( return_code_msg_t * ) response_msg . data ; slurm_rc_msg = ( return_code_msg_t * ) response_msg . data ;
return (int) slurm_rc_msg->return_code; return (int) slurm_rc_msg->return_code;
break ; break ;
case RESPONSE_JOB_WILL_RUN:
slurm_alloc_msg = ( resource_allocation_response_msg_t * ) response_msg . data ;
job_desc_msg->job_id = slurm_alloc_msg->job_id;
return 0;
break ;
default: default:
return SLURM_UNEXPECTED_MSG_ERROR ; return SLURM_UNEXPECTED_MSG_ERROR ;
break ; break ;
......
...@@ -28,6 +28,7 @@ slurm_submit_batch_job (job_desc_msg_t * job_desc_msg ) ...@@ -28,6 +28,7 @@ slurm_submit_batch_job (job_desc_msg_t * job_desc_msg )
slurm_msg_t request_msg ; slurm_msg_t request_msg ;
slurm_msg_t response_msg ; slurm_msg_t response_msg ;
return_code_msg_t * slurm_rc_msg ; return_code_msg_t * slurm_rc_msg ;
resource_allocation_response_msg_t * slurm_aloc_resp_msg;
/* init message connection for message communication with controller */ /* init message connection for message communication with controller */
if ( ( sockfd = slurm_open_controller_conn ( ) ) == SLURM_SOCKET_ERROR ) if ( ( sockfd = slurm_open_controller_conn ( ) ) == SLURM_SOCKET_ERROR )
...@@ -53,6 +54,11 @@ slurm_submit_batch_job (job_desc_msg_t * job_desc_msg ) ...@@ -53,6 +54,11 @@ slurm_submit_batch_job (job_desc_msg_t * job_desc_msg )
slurm_rc_msg = ( return_code_msg_t * ) response_msg . data ; slurm_rc_msg = ( return_code_msg_t * ) response_msg . data ;
return (int) slurm_rc_msg->return_code ; return (int) slurm_rc_msg->return_code ;
break ; break ;
case RESPONSE_SUBMIT_BATCH_JOB:
slurm_aloc_resp_msg = ( resource_allocation_response_msg_t * ) response_msg . data ;
job_desc_msg->job_id = slurm_aloc_resp_msg->job_id;
return 0;
break;
default: default:
return SLURM_UNEXPECTED_MSG_ERROR ; return SLURM_UNEXPECTED_MSG_ERROR ;
break ; break ;
......
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