mpi4py.MPI.Win.Rget() NotImplementedError

Hello,

I am experimenting a bit with parallelization of a complex structure and therefore want to use the RMA Rget() method to get a request object to check and wait for completion of some large get calls. However when I run the code I get an NotImplementedError for the method. But its there and implemented here: https://bitbucket.org/mpi4py/mpi4py/src/master/src/mpi4py/MPI/Win.pyx am I right? So why am I getting that error?

Here some example code:

import numpy as np
from mpi4py import MPI


comm = MPI.COMM_WORLD
size = comm.Get_size()
rank = comm.Get_rank()
status = MPI.Status()


dim = 10
itemsize = MPI.DOUBLE.Get_size()
nbytes = dim*itemsize

if rank == 0:
    memory = MPI.Alloc_mem(nbytes + 100)
    memory = np.arange(dim).astype(np.float64)
    print(memory)
    #memory2 = MPI.Alloc_mem(nbytes + 100)
    #memory2 = -np.arange(dim).astype(np.float64)

    fwin = MPI.Win.Create(memory, 1, comm=comm)

else:
    cfwin = MPI.Win.Create(None, comm=comm)

    rbuf = np.zeros(dim, dtype=np.float64)
    print(rank, rbuf)

    print(rank, 'start get...')
    cfwin.Lock(0, lock_type=235)    # MPI_LOCK_SHARED = 235
    #cfwin.Get(rbuf, target_rank=0)
    req = cfwin.Rget(rbuf, target_rank=0)
    cfwin.Unlock(0, )

    req.Wait()

    print(rank, 'get complete.')
    print(rank, rbuf)

run mpirun -np 3 python test_MPI_osc.py and I get the error: [0. 1. 2. 3. 4. 5. 6. 7. 8. 9.] 1 [0. 0. 0. 0. 0. 0. 0. 0. 0. 0.] 1 start get... 2 [0. 0. 0. 0. 0. 0. 0. 0. 0. 0.] 2 start get... Traceback (most recent call last): File "test_MPI_osc.py", line 33, in <module> req = cfwin.Rget(rbuf, target_rank=0) File "mpi4py/MPI/Win.pyx", line 446, in mpi4py.MPI.Win.Rget NotImplementedError Traceback (most recent call last): File "test_MPI_osc.py", line 33, in <module> req = cfwin.Rget(rbuf, target_rank=0) File "mpi4py/MPI/Win.pyx", line 446, in mpi4py.MPI.Win.Rget NotImplementedError

using mpi4py version 3.0.1a0, but had the same problem with the pip install version 3.0.0, OS is Ubuntu 18.04.1 LTS

Any ideas?

edit: P.S. Does Win.Unlock() already assure the completion of a standard Get() call?

Comments (5)