1
1
This commit was SVN r1871.
Этот коммит содержится в:
Edgar Gabriel 2004-08-04 17:08:29 +00:00
родитель 1ab1721c6c
Коммит bddf372ac1
2 изменённых файлов: 6 добавлений и 5 удалений

Просмотреть файл

@ -61,13 +61,13 @@ int mca_coll_basic_allgatherv_inter(void *sbuf, int scount,
int size, rsize; int size, rsize;
int err; int err;
int *scounts=NULL; int *scounts=NULL;
MPI_Aint *sdisps=NULL; int *sdisps=NULL;
rsize = ompi_comm_remote_size (comm); rsize = ompi_comm_remote_size (comm);
size = ompi_comm_size (comm); size = ompi_comm_size (comm);
scounts = (int *) calloc(rsize, sizeof(int) ); scounts = (int *) calloc (rsize, sizeof(int) );
sdisps = (MPI_Aint *) calloc (rsize, sizeof(MPI_Aint)); sdisps = (int *) calloc (rsize, sizeof(int));
if ( NULL == scounts || NULL == sdisps ) { if ( NULL == scounts || NULL == sdisps ) {
return err; return err;
} }

Просмотреть файл

@ -171,7 +171,7 @@ int mca_coll_basic_reduce_scatter_inter(void *sbuf, void *rbuf, int *rcounts,
goto exit; goto exit;
} }
err = mca_pml.pml_wait(1, &req, NULL, MPI_STATUS_IGNORE); err = mca_pml.pml_wait_all (1, &req, MPI_STATUS_IGNORE);
if (OMPI_SUCCESS != err ) { if (OMPI_SUCCESS != err ) {
goto exit; goto exit;
} }
@ -226,7 +226,7 @@ int mca_coll_basic_reduce_scatter_inter(void *sbuf, void *rbuf, int *rcounts,
goto exit; goto exit;
} }
err = mca_pml.pml_wait (1, &req, NULL, MPI_STATUS_IGNORE); err = mca_pml.pml_wait_all (1, &req, MPI_STATUS_IGNORE);
if ( OMPI_SUCCESS != err ) { if ( OMPI_SUCCESS != err ) {
goto exit; goto exit;
} }
@ -269,4 +269,5 @@ int mca_coll_basic_reduce_scatter_inter(void *sbuf, void *rbuf, int *rcounts,
free ( tmpbuf2 ); free ( tmpbuf2 );
} }
return err;
} }