|
Packit Service |
c5cf8c |
! This file created from f77/coll/nonblocking_inpf.f with f77tof90
|
|
Packit Service |
c5cf8c |
! -*- Mode: Fortran; -*-
|
|
Packit Service |
c5cf8c |
!
|
|
Packit Service |
c5cf8c |
! (C) 2012 by Argonne National Laboratory.
|
|
Packit Service |
c5cf8c |
! See COPYRIGHT in top-level directory.
|
|
Packit Service |
c5cf8c |
!
|
|
Packit Service |
c5cf8c |
! A simple test for Fortran support of the MPI_IN_PLACE value in Alltoall[vw].
|
|
Packit Service |
c5cf8c |
!
|
|
Packit Service |
c5cf8c |
program main
|
|
Packit Service |
c5cf8c |
use mpi
|
|
Packit Service |
c5cf8c |
integer SIZEOFINT
|
|
Packit Service |
c5cf8c |
integer MAX_SIZE
|
|
Packit Service |
c5cf8c |
parameter (MAX_SIZE=1024)
|
|
Packit Service |
c5cf8c |
integer rbuf(MAX_SIZE)
|
|
Packit Service |
c5cf8c |
integer rdispls(MAX_SIZE), rcounts(MAX_SIZE), rtypes(MAX_SIZE)
|
|
Packit Service |
c5cf8c |
integer comm, rank, size, req
|
|
Packit Service |
c5cf8c |
integer sumval, ierr, errs
|
|
Packit Service |
c5cf8c |
integer iexpected, igot
|
|
Packit Service |
c5cf8c |
integer i, j
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
errs = 0
|
|
Packit Service |
c5cf8c |
call mtest_init( ierr )
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
comm = MPI_COMM_WORLD
|
|
Packit Service |
c5cf8c |
call mpi_comm_rank( comm, rank, ierr )
|
|
Packit Service |
c5cf8c |
call mpi_comm_size( comm, size, ierr )
|
|
Packit Service |
c5cf8c |
call mpi_type_size( MPI_INTEGER, SIZEOFINT, ierr )
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
do i=1,MAX_SIZE
|
|
Packit Service |
c5cf8c |
rbuf(i) = -1
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
do i=1,size
|
|
Packit Service |
c5cf8c |
rbuf(i) = (i-1) * size + rank
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
call mpi_ialltoall( MPI_IN_PLACE, -1, MPI_DATATYPE_NULL, &
|
|
Packit Service |
c5cf8c |
& rbuf, 1, MPI_INTEGER, comm, req, ierr )
|
|
Packit Service |
c5cf8c |
call mpi_wait( req, MPI_STATUS_IGNORE, ierr )
|
|
Packit Service |
c5cf8c |
do i=1,size
|
|
Packit Service |
c5cf8c |
if (rbuf(i) .ne. (rank*size + i - 1)) then
|
|
Packit Service |
c5cf8c |
errs = errs + 1
|
|
Packit Service |
c5cf8c |
print *, '[', rank, ']: IALLTOALL rbuf(', i, ') = ', &
|
|
Packit Service |
c5cf8c |
& rbuf(i), ', should be', rank * size + i - 1
|
|
Packit Service |
c5cf8c |
endif
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
do i=1,MAX_SIZE
|
|
Packit Service |
c5cf8c |
rbuf(i) = -1
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
do i=1,size
|
|
Packit Service |
c5cf8c |
rcounts(i) = i-1 + rank
|
|
Packit Service |
c5cf8c |
rdispls(i) = (i-1) * (2*size)
|
|
Packit Service |
c5cf8c |
do j=0,rcounts(i)-1
|
|
Packit Service |
c5cf8c |
rbuf(rdispls(i)+j+1) = 100 * rank + 10 * (i-1) + j
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
call mpi_ialltoallv( MPI_IN_PLACE, 0, 0, MPI_DATATYPE_NULL, &
|
|
Packit Service |
c5cf8c |
& rbuf, rcounts, rdispls, MPI_INTEGER, &
|
|
Packit Service |
c5cf8c |
& comm, req, ierr )
|
|
Packit Service |
c5cf8c |
call mpi_wait( req, MPI_STATUS_IGNORE, ierr )
|
|
Packit Service |
c5cf8c |
do i=1,size
|
|
Packit Service |
c5cf8c |
do j=0,rcounts(i)-1
|
|
Packit Service |
c5cf8c |
iexpected = 100 * (i-1) + 10 * rank + j
|
|
Packit Service |
c5cf8c |
igot = rbuf(rdispls(i)+j+1)
|
|
Packit Service |
c5cf8c |
if ( igot .ne. iexpected ) then
|
|
Packit Service |
c5cf8c |
errs = errs + 1
|
|
Packit Service |
c5cf8c |
print *, '[', rank, ']: IALLTOALLV got ', igot, &
|
|
Packit Service |
c5cf8c |
& ',but expected ', iexpected, &
|
|
Packit Service |
c5cf8c |
& ' for block=', i-1, ' element=', j
|
|
Packit Service |
c5cf8c |
endif
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
do i=1,MAX_SIZE
|
|
Packit Service |
c5cf8c |
rbuf(i) = -1
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
do i=1,size
|
|
Packit Service |
c5cf8c |
rcounts(i) = i-1 + rank
|
|
Packit Service |
c5cf8c |
rdispls(i) = (i-1) * (2*size) * SIZEOFINT
|
|
Packit Service |
c5cf8c |
rtypes(i) = MPI_INTEGER
|
|
Packit Service |
c5cf8c |
do j=0,rcounts(i)-1
|
|
Packit Service |
c5cf8c |
rbuf(rdispls(i)/SIZEOFINT+j+1) = 100 * rank &
|
|
Packit Service |
c5cf8c |
& + 10 * (i-1) + j
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
call mpi_ialltoallw( MPI_IN_PLACE, 0, 0, MPI_DATATYPE_NULL, &
|
|
Packit Service |
c5cf8c |
& rbuf, rcounts, rdispls, rtypes, &
|
|
Packit Service |
c5cf8c |
& comm, req, ierr )
|
|
Packit Service |
c5cf8c |
call mpi_wait( req, MPI_STATUS_IGNORE, ierr )
|
|
Packit Service |
c5cf8c |
do i=1,size
|
|
Packit Service |
c5cf8c |
do j=0,rcounts(i)-1
|
|
Packit Service |
c5cf8c |
iexpected = 100 * (i-1) + 10 * rank + j
|
|
Packit Service |
c5cf8c |
igot = rbuf(rdispls(i)/SIZEOFINT+j+1)
|
|
Packit Service |
c5cf8c |
if ( igot .ne. iexpected ) then
|
|
Packit Service |
c5cf8c |
errs = errs + 1
|
|
Packit Service |
c5cf8c |
print *, '[', rank, ']: IALLTOALLW got ', igot, &
|
|
Packit Service |
c5cf8c |
& ',but expected ', iexpected, &
|
|
Packit Service |
c5cf8c |
& ' for block=', i-1, ' element=', j
|
|
Packit Service |
c5cf8c |
endif
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
do i=1,MAX_SIZE
|
|
Packit Service |
c5cf8c |
rbuf(i) = -1
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
do i = 1, size
|
|
Packit Service |
c5cf8c |
rbuf(i) = rank + (i-1)
|
|
Packit Service |
c5cf8c |
enddo
|
|
Packit Service |
c5cf8c |
call mpi_ireduce_scatter_block( MPI_IN_PLACE, rbuf, 1, &
|
|
Packit Service |
c5cf8c |
& MPI_INTEGER, MPI_SUM, comm, &
|
|
Packit Service |
c5cf8c |
& req, ierr )
|
|
Packit Service |
c5cf8c |
call mpi_wait( req, MPI_STATUS_IGNORE, ierr )
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
sumval = size * rank + ((size-1) * size)/2
|
|
Packit Service |
c5cf8c |
if ( rbuf(1) .ne. sumval ) then
|
|
Packit Service |
c5cf8c |
errs = errs + 1
|
|
Packit Service |
c5cf8c |
print *, 'Ireduce_scatter_block does not get expected value.'
|
|
Packit Service |
c5cf8c |
print *, '[', rank, ']:', 'Got ', rbuf(1), ' but expected ', &
|
|
Packit Service |
c5cf8c |
& sumval, '.'
|
|
Packit Service |
c5cf8c |
endif
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
call mtest_finalize( errs )
|
|
Packit Service |
c5cf8c |
|
|
Packit Service |
c5cf8c |
end
|