Minor cleanups
This commit was SVN r21387.
Этот коммит содержится в:
родитель
ccf6b2cb8c
Коммит
0a67bcb653
@ -374,18 +374,6 @@ static int rte_init(void)
|
|||||||
goto error;
|
goto error;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* setup I/O forwarding system - must come after we init routes */
|
|
||||||
if (ORTE_SUCCESS != (ret = orte_iof_base_open())) {
|
|
||||||
ORTE_ERROR_LOG(ret);
|
|
||||||
error = "orte_iof_base_open";
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
if (ORTE_SUCCESS != (ret = orte_iof_base_select())) {
|
|
||||||
ORTE_ERROR_LOG(ret);
|
|
||||||
error = "orte_iof_base_select";
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* setup the notifier system */
|
/* setup the notifier system */
|
||||||
if (ORTE_SUCCESS != (ret = orte_notifier_base_open())) {
|
if (ORTE_SUCCESS != (ret = orte_notifier_base_open())) {
|
||||||
ORTE_ERROR_LOG(ret);
|
ORTE_ERROR_LOG(ret);
|
||||||
@ -424,6 +412,7 @@ static int rte_finalize(void)
|
|||||||
/* finalize selected modules so they can de-register
|
/* finalize selected modules so they can de-register
|
||||||
* any receives
|
* any receives
|
||||||
*/
|
*/
|
||||||
|
orte_ras_base_close();
|
||||||
orte_rmaps_base_close();
|
orte_rmaps_base_close();
|
||||||
orte_plm_base_close();
|
orte_plm_base_close();
|
||||||
orte_errmgr_base_close();
|
orte_errmgr_base_close();
|
||||||
|
@ -411,14 +411,15 @@ static int orte_rmaps_resilient_map(orte_job_t *jdata)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
/* if no ftgrps are available, then just map it on the lightest loaded
|
/* if no ftgrps are available, then just map it on the lightest loaded
|
||||||
* node in the current map
|
* node in the current map, avoiding the current node if possible
|
||||||
*/
|
*/
|
||||||
if (NULL == target) {
|
if (NULL == target) {
|
||||||
nd = NULL;
|
nd = oldnode; /* put it back where it was if nothing else is found */
|
||||||
totprocs = 1000000;
|
totprocs = 1000000;
|
||||||
map = jdata->map;
|
map = jdata->map;
|
||||||
for (k=0; k < map->nodes->size; k++) {
|
for (k=0; k < map->nodes->size; k++) {
|
||||||
if (NULL == (node = opal_pointer_array_get_item(map->nodes, k))) {
|
if (NULL == (node = opal_pointer_array_get_item(map->nodes, k)) ||
|
||||||
|
node == oldnode) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
if (node->num_procs < totprocs) {
|
if (node->num_procs < totprocs) {
|
||||||
@ -426,12 +427,6 @@ static int orte_rmaps_resilient_map(orte_job_t *jdata)
|
|||||||
totprocs = node->num_procs;
|
totprocs = node->num_procs;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (NULL == nd) {
|
|
||||||
/* we are hosed - abort */
|
|
||||||
orte_show_help("help-orte-rmaps-resilient.txt", "orte-rmaps-resilient:could-not-remap-proc",
|
|
||||||
true, ORTE_NAME_PRINT(&proc->name));
|
|
||||||
return ORTE_ERROR;
|
|
||||||
}
|
|
||||||
/* put proc on the found node */
|
/* put proc on the found node */
|
||||||
OBJ_RETAIN(nd); /* required to maintain bookeeping */
|
OBJ_RETAIN(nd); /* required to maintain bookeeping */
|
||||||
proc->node = nd;
|
proc->node = nd;
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user