src/mca/plm/alps/plm_alps_module.c
/**
 * Terminate the orteds for a given job
 */
Terminate the orteds for a given job
Terminate the orteds for a given job
static int plm_alps_terminate_orteds(void)
{
    int rc;
    prte_job_t *jdata;
    PRTE_OUTPUT_VERBOSE((10, prte_plm_base_framework.framework_output,
                         "%s plm:alps: terminating orteds", PRTE_NAME_PRINT(PRTE_PROC_MY_NAME)));
    if (NULL != alpsrun) {
        prte_wait_cb_cancel(alpsrun);
    }
    if (PRTE_SUCCESS != (rc = prte_plm_base_prted_exit(PRTE_DAEMON_EXIT_CMD))) {
        PRTE_ERROR_LOG(rc);
    }
    jdata = prte_get_job_data_object(PRTE_PROC_MY_NAME->nspace);
    PRTE_ACTIVATE_JOB_STATE(jdata, PRTE_JOB_STATE_DAEMONS_TERMINATED);
    PRTE_OUTPUT_VERBOSE((10, prte_plm_base_framework.framework_output,
                         "%s plm:alps: terminated orteds", PRTE_NAME_PRINT(PRTE_PROC_MY_NAME)));
    return rc;
}
static int plm_alps_terminate_orteds ( void ) { int rc ; prte_job_t * jdata ; PRTE_OUTPUT_VERBOSE ( ( 10 , prte_plm_base_framework . framework_output , " " , PRTE_NAME_PRINT ( PRTE_PROC_MY_NAME ) ) ) ; if ( NULL != alpsrun ) { prte_wait_cb_cancel ( alpsrun ) ; } if ( PRTE_SUCCESS != ( rc = prte_plm_base_prted_exit ( PRTE_DAEMON_EXIT_CMD ) ) ) { PRTE_ERROR_LOG ( rc ) ; } jdata = prte_get_job_data_object ( PRTE_PROC_MY_NAME -> nspace ) ; PRTE_ACTIVATE_JOB_STATE ( jdata , PRTE_JOB_STATE_DAEMONS_TERMINATED ) ; PRTE_OUTPUT_VERBOSE ( ( 10 , prte_plm_base_framework . framework_output , " " , PRTE_NAME_PRINT ( PRTE_PROC_MY_NAME ) ) ) ; return rc ; }
Terminate the orteds for a given job
Terminate the orteds for a given job
/* deregister the waitpid callback to ensure we don't make it look like
     * alps failed when it didn't. Since the alps may have already completed,
     * do NOT ERROR_LOG any return code to avoid confusing, duplicate error
     * messages
     */ /* now tell them to die */