Ensure that nodes get included in the nidmap when spawning a new DVM job - we really only need to do this once, but for now we do it for every job until we work out how to avoid the duplication. Remove debug from orte-dvm tool
Этот коммит содержится в:
родитель
ef13ba7db3
Коммит
3478def791
@ -113,6 +113,7 @@ void orte_daemon_recv(int status, orte_process_name_t* sender,
|
||||
orte_std_cntr_t num_procs, num_new_procs = 0, p;
|
||||
orte_proc_t *cur_proc = NULL, *prev_proc = NULL;
|
||||
bool found = false;
|
||||
orte_node_t *node;
|
||||
|
||||
/* unpack the command */
|
||||
n = 1;
|
||||
@ -548,6 +549,11 @@ void orte_daemon_recv(int status, orte_process_name_t* sender,
|
||||
orte_rml.send_buffer_nb(ORTE_PROC_MY_NAME, iofbuf, ORTE_RML_TAG_IOF_HNP,
|
||||
orte_rml_send_callback, NULL);
|
||||
}
|
||||
for (i=1; i < orte_node_pool->size; i++) {
|
||||
if (NULL != (node = (orte_node_t*)opal_pointer_array_get_item(orte_node_pool, i))) {
|
||||
node->state = ORTE_NODE_STATE_ADDED;
|
||||
}
|
||||
}
|
||||
/* now launch the job - this will just push it into our state machine */
|
||||
if (ORTE_SUCCESS != (ret = orte_plm.spawn(jdata))) {
|
||||
ORTE_ERROR_LOG(ret);
|
||||
|
@ -427,10 +427,6 @@ static void notify_requestor(int sd, short args, void *cbdata)
|
||||
int ret;
|
||||
opal_buffer_t *reply;
|
||||
|
||||
opal_output(0, "%s dvm: job %s has completed",
|
||||
ORTE_NAME_PRINT(ORTE_PROC_MY_NAME),
|
||||
(NULL == jdata) ? "NULL" : ORTE_JOBID_PRINT(jdata->jobid));
|
||||
|
||||
/* notify the requestor */
|
||||
reply = OBJ_NEW(opal_buffer_t);
|
||||
/* see if there was any problem */
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user