Clean out some debugging statements that were inadvertently left in the commit
This commit was SVN r11933.
Этот коммит содержится в:
родитель
559b9b0ae8
Коммит
7494a7a83f
@ -125,13 +125,11 @@ void orte_pls_base_recv(int status, orte_process_name_t* sender,
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
case ORTE_PLS_TERMINATE_JOB_CMD:
|
case ORTE_PLS_TERMINATE_JOB_CMD:
|
||||||
opal_output(0, "pls_base_recv: terminate job");
|
|
||||||
count = 1;
|
count = 1;
|
||||||
if (ORTE_SUCCESS != (rc = orte_dss.unpack(buffer, &job, &count, ORTE_JOBID))) {
|
if (ORTE_SUCCESS != (rc = orte_dss.unpack(buffer, &job, &count, ORTE_JOBID))) {
|
||||||
ORTE_ERROR_LOG(rc);
|
ORTE_ERROR_LOG(rc);
|
||||||
goto SEND_ANSWER;
|
goto SEND_ANSWER;
|
||||||
}
|
}
|
||||||
opal_output(0, "pls_base_recv: terminate job with jobid %ld", (long)job);
|
|
||||||
|
|
||||||
if (ORTE_SUCCESS != (rc = orte_pls.terminate_job(job))) {
|
if (ORTE_SUCCESS != (rc = orte_pls.terminate_job(job))) {
|
||||||
ORTE_ERROR_LOG(rc);
|
ORTE_ERROR_LOG(rc);
|
||||||
@ -145,8 +143,6 @@ void orte_pls_base_recv(int status, orte_process_name_t* sender,
|
|||||||
goto SEND_ANSWER;
|
goto SEND_ANSWER;
|
||||||
}
|
}
|
||||||
|
|
||||||
opal_output(0, "pls_base_recv: terminate orteds with jobid %ld", (long)job);
|
|
||||||
|
|
||||||
if (ORTE_SUCCESS != (rc = orte_pls.terminate_orteds(job))) {
|
if (ORTE_SUCCESS != (rc = orte_pls.terminate_orteds(job))) {
|
||||||
ORTE_ERROR_LOG(rc);
|
ORTE_ERROR_LOG(rc);
|
||||||
}
|
}
|
||||||
|
@ -135,8 +135,6 @@ int orte_pls_proxy_terminate_job(orte_jobid_t job)
|
|||||||
return rc;
|
return rc;
|
||||||
}
|
}
|
||||||
|
|
||||||
opal_output(0, "pls_proxy_terminate_job: sending for job %ld", (long)job);
|
|
||||||
|
|
||||||
if (0 > orte_rml.send_buffer(orte_pls_proxy_replica, cmd, ORTE_RML_TAG_PLS, 0)) {
|
if (0 > orte_rml.send_buffer(orte_pls_proxy_replica, cmd, ORTE_RML_TAG_PLS, 0)) {
|
||||||
ORTE_ERROR_LOG(ORTE_ERR_COMM_FAILURE);
|
ORTE_ERROR_LOG(ORTE_ERR_COMM_FAILURE);
|
||||||
OBJ_RELEASE(cmd);
|
OBJ_RELEASE(cmd);
|
||||||
@ -181,8 +179,6 @@ int orte_pls_proxy_terminate_orteds(orte_jobid_t job)
|
|||||||
orte_std_cntr_t count;
|
orte_std_cntr_t count;
|
||||||
int rc;
|
int rc;
|
||||||
|
|
||||||
opal_output(0, "pls_proxy_terminate_orteds: sending for job %ld", (long)job);
|
|
||||||
|
|
||||||
command = ORTE_PLS_TERMINATE_ORTEDS_CMD;
|
command = ORTE_PLS_TERMINATE_ORTEDS_CMD;
|
||||||
|
|
||||||
cmd = OBJ_NEW(orte_buffer_t);
|
cmd = OBJ_NEW(orte_buffer_t);
|
||||||
|
@ -1081,8 +1081,6 @@ int orte_pls_rsh_terminate_job(orte_jobid_t jobid)
|
|||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
|
|
||||||
opal_output(0, "pls_rsh_terminate_job: called for job %ld with %ld daemons", jobid, (long)opal_list_get_size(&daemons));
|
|
||||||
|
|
||||||
/* order them to kill their local procs for this job */
|
/* order them to kill their local procs for this job */
|
||||||
if (ORTE_SUCCESS != (rc = orte_pls_base_orted_kill_local_procs(&daemons, jobid))) {
|
if (ORTE_SUCCESS != (rc = orte_pls_base_orted_kill_local_procs(&daemons, jobid))) {
|
||||||
ORTE_ERROR_LOG(rc);
|
ORTE_ERROR_LOG(rc);
|
||||||
@ -1113,8 +1111,6 @@ int orte_pls_rsh_terminate_orteds(orte_jobid_t jobid)
|
|||||||
goto CLEANUP;
|
goto CLEANUP;
|
||||||
}
|
}
|
||||||
|
|
||||||
opal_output(0, "pls_rsh_terminate_orteds: called for job %ld with %ld daemons", jobid, (long)opal_list_get_size(&daemons));
|
|
||||||
|
|
||||||
/* now tell them to die! */
|
/* now tell them to die! */
|
||||||
if (ORTE_SUCCESS != (rc = orte_pls_base_orted_exit(&daemons))) {
|
if (ORTE_SUCCESS != (rc = orte_pls_base_orted_exit(&daemons))) {
|
||||||
ORTE_ERROR_LOG(rc);
|
ORTE_ERROR_LOG(rc);
|
||||||
|
@ -635,8 +635,6 @@ static void orte_daemon_recv_pls(int status, orte_process_name_t* sender,
|
|||||||
* we should kill all local procs. Otherwise, only kill those within
|
* we should kill all local procs. Otherwise, only kill those within
|
||||||
* the specified jobid
|
* the specified jobid
|
||||||
*/
|
*/
|
||||||
opal_output(0, "orted_daemon_recv_pls: kill_local_procs");
|
|
||||||
|
|
||||||
n = 1;
|
n = 1;
|
||||||
if (ORTE_SUCCESS != (ret = orte_dss.unpack(buffer, &job, &n, ORTE_JOBID))) {
|
if (ORTE_SUCCESS != (ret = orte_dss.unpack(buffer, &job, &n, ORTE_JOBID))) {
|
||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
@ -687,8 +685,6 @@ static void orte_daemon_recv_pls(int status, orte_process_name_t* sender,
|
|||||||
|
|
||||||
/**** EXIT COMMAND ****/
|
/**** EXIT COMMAND ****/
|
||||||
case ORTE_DAEMON_EXIT_CMD:
|
case ORTE_DAEMON_EXIT_CMD:
|
||||||
opal_output(0, "orted_daemon_recv_pls: exit");
|
|
||||||
|
|
||||||
/* send the response before we wakeup because otherwise
|
/* send the response before we wakeup because otherwise
|
||||||
* we'll depart before it gets out!
|
* we'll depart before it gets out!
|
||||||
*/
|
*/
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user