diff --git a/src/slurmd/slurmd.c b/src/slurmd/slurmd.c index 23eb9aff798f4c3671fdfa32aa1f94c75ed4aa9a..97ada61d961087c3dc9c5238cbc6cd5bb64c2643 100644 --- a/src/slurmd/slurmd.c +++ b/src/slurmd/slurmd.c @@ -256,6 +256,7 @@ void slurm_rpc_launch_tasks ( slurm_msg_t * msg ) launch_tasks_msg_t * task_desc = ( launch_tasks_msg_t * ) msg->data ; start_time = clock (); + info ("slurmd_req: launch tasks message received"); /* do RPC call */ error_code = launch_tasks ( task_desc ); diff --git a/src/slurmd/task_mgr.c b/src/slurmd/task_mgr.c index fc72b710f076a10393aab7587e65054a7f5a771f..f5b4a8b5deba0de60372322da8505c60d6b2a310 100644 --- a/src/slurmd/task_mgr.c +++ b/src/slurmd/task_mgr.c @@ -160,14 +160,14 @@ int forward_io ( task_start_t * task_arg ) { local_errno = errno ; info ( "error opening socket to srun to pipe stdout errno %i" , local_errno ) ; - pthread_exit ( 0 ) ; +// pthread_exit ( 0 ) ; } if ( ( task_arg->sockets[SIG_STDERR_SOCK] = slurm_open_stream ( &( task_arg -> err_dest ) ) ) == SLURM_PROTOCOL_ERROR ) { local_errno = errno ; info ( "error opening socket to srun to pipe stdout errno %i" , local_errno ) ; - pthread_exit ( 0 ) ; +// pthread_exit ( 0 ) ; } /* spawn io pipe threads */