@@ -399,22 +399,22 @@ int ompi_coll_base_alltoall_intra_linear_sync(const void *sbuf, int scount,
399
399
prcv = (char * ) rbuf ;
400
400
psnd = (char * ) sbuf ;
401
401
402
- /* Post first batch or ireceive and isend requests */
402
+ /* Post first batch of irecv and isend requests */
403
403
for (nreqs = 0 , nrreqs = 0 , ri = (rank + 1 ) % size ; nreqs < total_reqs ;
404
404
ri = (ri + 1 ) % size , ++ nrreqs ) {
405
- nreqs ++ ;
406
405
error = MCA_PML_CALL (irecv
407
406
(prcv + (ptrdiff_t )ri * rext , rcount , rdtype , ri ,
408
407
MCA_COLL_BASE_TAG_ALLTOALL , comm , & reqs [nreqs ]));
408
+ nreqs ++ ;
409
409
if (MPI_SUCCESS != error ) { line = __LINE__ ; goto error_hndl ; }
410
410
}
411
411
for (nsreqs = 0 , si = (rank + size - 1 ) % size ; nreqs < 2 * total_reqs ;
412
- si = (si + size - 1 ) % size , ++ nsreqs ) {
413
- nreqs ++ ;
412
+ si = (si + size - 1 ) % size , ++ nsreqs ) {
414
413
error = MCA_PML_CALL (isend
415
414
(psnd + (ptrdiff_t )si * sext , scount , sdtype , si ,
416
415
MCA_COLL_BASE_TAG_ALLTOALL ,
417
416
MCA_PML_BASE_SEND_STANDARD , comm , & reqs [nreqs ]));
417
+ nreqs ++ ;
418
418
if (MPI_SUCCESS != error ) { line = __LINE__ ; goto error_hndl ; }
419
419
}
420
420
0 commit comments