当我尝试使用“大”数组(每个 100 000 个浮点数的 2 个数组)发送 MPI 派生数据类型时,我的程序出现段错误。不过,它可以正常运行较小的阵列。
下面是一个可重现的小例子。这个小程序使用以下 MPI 实现出现段错误: IntelMPI、BullXMPI。它与OpenMPI和PlatformMPI一起正常工作。这是一个带有示例回溯的日志:http: //pastebin.com/FMBpCuj2
更改mpi_send
为mpi_ssend
无济于事。但是,mpi_send
使用一个更大的 2*100 000 浮点数组可以正常工作。在我看来,这表明派生数据类型存在问题。
program struct
include 'mpif.h'
type Data
integer :: id
real, allocatable :: ratio(:)
real, allocatable :: winds(:)
end type
type (Data) :: test
integer :: datatype, oldtypes(3), blockcounts(3)
integer :: offsets(3)
integer :: numtasks, rank, i, ierr
integer :: n, status(mpi_status_size)
call mpi_init(ierr)
call mpi_comm_rank(mpi_comm_world, rank, ierr)
call mpi_comm_size(mpi_comm_world, numtasks, ierr)
if (numtasks /= 2) then
write (*,*) "Needs 2 procs"
call exit(1)
endif
n = 100000
allocate(test%ratio(n))
allocate(test%winds(n))
if (rank == 0) then
test%ratio = 6
test%winds = 7
test%id = 2
else
test%id = 0
test%ratio = 0
test%winds = 0
endif
call mpi_get_address(test%id, offsets(1), ierr)
call mpi_get_address(test%ratio, offsets(2), ierr)
call mpi_get_address(test%winds, offsets(3), ierr)
do i = 2, size(offsets)
offsets(i) = offsets(i) - offsets(1)
end do
offsets(1) = 0
oldtypes = (/mpi_integer, mpi_real, mpi_real/)
blockcounts = (/1, n, n/)
call mpi_type_struct(3, blockcounts, offsets, oldtypes, datatype, ierr)
call mpi_type_commit(datatype, ierr)
if (rank == 0) then
!call mpi_ssend(test, 1, datatype, 1, 0, mpi_comm_world, ierr)
call mpi_send(test, 1, datatype, 1, 0, mpi_comm_world, ierr)
else
call mpi_recv(test, 1, datatype, 0, 0, mpi_comm_world, status, ierr)
end if
print *, 'rank= ',rank
print *, 'data= ',test%ratio(1:5),test%winds(1:5)
deallocate (test%ratio)
deallocate (test%winds)
call mpi_finalize(ierr)
end
注意:不同 MPI 实现之间的比较并不客观,因为测试并非都在同一台机器上(其中一些是超级计算机)。不过,我认为它不应该有所作为。
编辑:代码适用于静态数组。这是 Fortran 90。