1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
from mpi4py import MPI
try:
import numpy
except ImportError:
raise SystemExit from None
# extract the section a[0:6:2, 0:5:2] and store it in e[:,:]
a = numpy.empty((6, 5), dtype=float, order="f")
e = numpy.empty((3, 3), dtype=float, order="f")
a.flat = numpy.arange(a.size, dtype=float)
lb, sizeofdouble = MPI.DOUBLE.Get_extent()
# create datatype for a 1D section
oneslice = MPI.DOUBLE.Create_vector(3, 1, 2)
# create datatype for a 2D section
twoslice = oneslice.Create_hvector(3, 1, 12 * sizeofdouble)
twoslice.Commit()
# send and recv on same process
myrank = MPI.COMM_WORLD.Get_rank()
status = MPI.Status()
MPI.COMM_WORLD.Sendrecv(
[a, 1, twoslice], myrank, 0, (e, MPI.DOUBLE), myrank, 0, status
)
assert numpy.allclose(a[::2, ::2], e)
assert status.Get_count(twoslice) == 1
assert status.Get_count(MPI.DOUBLE) == e.size
oneslice.Free()
twoslice.Free()
|
