parkipy.distributed.gather_points

parkipy.distributed.gather_points(mpi_comm, execution_space, arr, nt, buffers=None)

Gather a distributed array arr with nt points locally onto the first MPI rank.

buffers may be given and will be used for sending and receiving MPI messages. (It is a dict object as returned by create_buffers().)

mpi_comm is an optional MPI.Comm communication context.

This function handles the communication between the rank.

Returns new_nt, the global number of target points (all gathered on the first MPI rank).