diff --git a/ompi/communicator/comm_init.c b/ompi/communicator/comm_init.c index c519f6728100a67790a8b18692ef873f01657519..87a8923b9fce0009de0d68fe85a59050f826c9ec 100644 --- a/ompi/communicator/comm_init.c +++ b/ompi/communicator/comm_init.c @@ -197,14 +197,6 @@ static int get_modified_ranks(uint32_t jobid, uint32_t vpid, size_t size, opal_v free(rank_to_recv); - // // Print modified_ranks array for debugging purposes - // printf("modified_ranks: ["); - // for (size_t i = 0; i < size; i++) { - // printf("%u", modified_ranks[i]); - // if (i+1 < size) printf(", "); - // } - // printf("]\n"); - close(socket_fd); return 0; @@ -246,14 +238,15 @@ int ompi_comm_init(void) get_modified_ranks(OMPI_PROC_MY_NAME->jobid, OMPI_PROC_MY_NAME->vpid, size, modified_ranks); for (size_t i = 0 ; i < size ; ++i) { - opal_process_name_t name = {.vpid = modified_ranks[i], .jobid = OMPI_PROC_MY_NAME->jobid}; + opal_vpid_t modified_rank = modified_ranks[i]; + opal_process_name_t name = {.vpid = i, .jobid = OMPI_PROC_MY_NAME->jobid}; /* look for existing ompi_proc_t that matches this name */ - group->grp_proc_pointers[i] = (ompi_proc_t *) ompi_proc_lookup (name); - if (NULL == group->grp_proc_pointers[i]) { + group->grp_proc_pointers[modified_rank] = (ompi_proc_t *) ompi_proc_lookup (name); + if (NULL == group->grp_proc_pointers[modified_rank]) { /* set sentinel value */ - group->grp_proc_pointers[i] = (ompi_proc_t *) ompi_proc_name_to_sentinel (name); + group->grp_proc_pointers[modified_rank] = (ompi_proc_t *) ompi_proc_name_to_sentinel (name); } else { - OBJ_RETAIN (group->grp_proc_pointers[i]); + OBJ_RETAIN (group->grp_proc_pointers[modified_rank]); } }