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

Fix intercommunicator split (was triggered by MPICH/icsend test)

Просмотр исходного кода
Этот коммит содержится в:
Artem Polyakov 2015-12-07 15:41:29 +02:00
родитель 04fc4060db
Коммит f2794740b3
1 изменённых файлов: 3 добавлений и 4 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

7
ompi/communicator/comm.c
Просмотреть файл

@ -180,7 +180,7 @@ int ompi_comm_set_nb ( ompi_communicator_t **ncomm,
if (0 < remote_size) { if (0 < remote_size) {
ompi_communicator_t *old_localcomm; ompi_communicator_t *old_localcomm;
if (NULL == remote_group || &ompi_mpi_group_null.group == remote_group) { if (NULL == remote_group) {
ret = ompi_group_incl(oldcomm->c_remote_group, remote_size, ret = ompi_group_incl(oldcomm->c_remote_group, remote_size,
remote_ranks, &newcomm->c_remote_group); remote_ranks, &newcomm->c_remote_group);
if (OPAL_UNLIKELY(OMPI_SUCCESS != ret)) { if (OPAL_UNLIKELY(OMPI_SUCCESS != ret)) {
@ -432,7 +432,7 @@ int ompi_comm_split( ompi_communicator_t* comm, int color, int key,
int rc=OMPI_SUCCESS; int rc=OMPI_SUCCESS;
ompi_communicator_t *newcomp = NULL; ompi_communicator_t *newcomp = NULL;
int *lranks=NULL, *rranks=NULL; int *lranks=NULL, *rranks=NULL;
ompi_group_t * local_group=NULL, * remote_group=NULL; ompi_group_t * local_group=NULL;
ompi_comm_allgatherfct *allgatherfct=NULL; ompi_comm_allgatherfct *allgatherfct=NULL;
@ -508,7 +508,6 @@ int ompi_comm_split( ompi_communicator_t* comm, int color, int key,
/* Step 2: determine all the information for the remote group */ /* Step 2: determine all the information for the remote group */
/* --------------------------------------------------------- */ /* --------------------------------------------------------- */
if ( inter ) { if ( inter ) {
remote_group = &ompi_mpi_group_null.group;
rsize = comm->c_remote_group->grp_proc_count; rsize = comm->c_remote_group->grp_proc_count;
rresults = (int *) malloc ( rsize * 2 * sizeof(int)); rresults = (int *) malloc ( rsize * 2 * sizeof(int));
if ( NULL == rresults ) { if ( NULL == rresults ) {
@ -592,7 +591,7 @@ int ompi_comm_split( ompi_communicator_t* comm, int color, int key,
comm->error_handler,/* error handler */ comm->error_handler,/* error handler */
pass_on_topo, pass_on_topo,
local_group, /* local group */ local_group, /* local group */
remote_group); /* remote group */ NULL); /* remote group */
if ( NULL == newcomp ) { if ( NULL == newcomp ) {
rc = MPI_ERR_INTERN; rc = MPI_ERR_INTERN;