ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

bproc fixes, these exist in the release 1.0 branch.

Просмотр исходного кода 
This commit was SVN r8292.
Этот коммит содержится в:
Galen Shipman 2005-11-28 21:10:02 +00:00
родитель ff1a820384
Коммит 6e64e8a144
2 изменённых файлов: 6 добавлений и 6 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

6
orte/mca/pls/bproc/pls_bproc.c
Просмотреть файл

@ -119,8 +119,8 @@ static int orte_pls_bproc_node_array(orte_rmaps_base_map_t* map,
for(item = opal_list_get_first(&map->nodes); for(item = opal_list_get_first(&map->nodes);
item != opal_list_get_end(&map->nodes); item != opal_list_get_end(&map->nodes);
item = opal_list_get_next(item)) { item = opal_list_get_next(item)) {
if(*node_array_len < atol(((orte_rmaps_base_node_t*)item)->node_name)) { if(*node_array_len < atol(((orte_rmaps_base_node_t*)item)->node->node_name)) {
*node_array_len = atol(((orte_rmaps_base_node_t*)item)->node_name); *node_array_len = atol(((orte_rmaps_base_node_t*)item)->node->node_name);
} }
} }
(*node_array_len)++; (*node_array_len)++;
@ -137,7 +137,7 @@ static int orte_pls_bproc_node_array(orte_rmaps_base_map_t* map,
item = opal_list_get_next(item)) { item = opal_list_get_next(item)) {
orte_rmaps_base_node_t* node = (orte_rmaps_base_node_t*)item; orte_rmaps_base_node_t* node = (orte_rmaps_base_node_t*)item;
num_on_node = opal_list_get_size(&node->node_procs); num_on_node = opal_list_get_size(&node->node_procs);
(*node_array)[atol(node->node_name)] += num_on_node; (*node_array)[atol(node->node->node_name)] += num_on_node;
num_procs += num_on_node; num_procs += num_on_node;
} }
return num_procs; return num_procs;

6
orte/mca/pls/bproc_seed/pls_bproc_seed.c
Просмотреть файл

@ -82,7 +82,7 @@ static int orte_pls_bproc_nodelist(orte_rmaps_base_map_t* map, int** nodelist, s
item != opal_list_get_end(&map->nodes); item != opal_list_get_end(&map->nodes);
item = opal_list_get_next(item)) { item = opal_list_get_next(item)) {
orte_rmaps_base_node_t* node = (orte_rmaps_base_node_t*)item; orte_rmaps_base_node_t* node = (orte_rmaps_base_node_t*)item;
(*nodelist)[index++] = atol(node->node_name); (*nodelist)[index++] = atol(node->node->node_name);
} }
*num_nodes = count; *num_nodes = count;
return OMPI_SUCCESS; return OMPI_SUCCESS;
@ -514,7 +514,7 @@ static int orte_pls_bproc_launch_app(
} }
if(mca_pls_bproc_seed_component.debug) { if(mca_pls_bproc_seed_component.debug) {
opal_output(0, "orte_pls_bproc: node=%s name=%d.%d.%d procs=%d\n", opal_output(0, "orte_pls_bproc: node=%s name=%d.%d.%d procs=%d\n",
node->node_name, node->node->node_name,
orte_process_info.my_name->cellid, 0, orte_process_info.my_name->cellid, 0,
daemon_vpid_start+rank, daemon_vpid_start+rank,
opal_list_get_size(&node->node_procs)); opal_list_get_size(&node->node_procs));
@ -528,7 +528,7 @@ static int orte_pls_bproc_launch_app(
} }
/* save the daemons pid in the registry */ /* save the daemons pid in the registry */
rc = orte_pls_base_set_node_pid(node->node_cellid, node->node_name, jobid, getpid()); rc = orte_pls_base_set_node_pid(node->node->node_cellid, node->node->node_name, jobid, getpid());
if(ORTE_SUCCESS != rc) { if(ORTE_SUCCESS != rc) {
ORTE_ERROR_LOG(rc); ORTE_ERROR_LOG(rc);
_exit(-1); _exit(-1);