ptypy.utils.parallel.receive

ptypy.utils.parallel.receive(source=None, tag=0)

Wrapper for comm.Recv. Probes first with comm.recv. If the unpickled is a 3-tuple with first entry==’npy’, prepares buffer and waits with comm.Recv

Parameters:

• source (int or None) – The rank of the node / process sending data. If None, this is set to MPI.ANY_SOURCE

• tag (int) – Not really useful here - defaults to 0 all the time

Returns:

out

Return type:

ndarray or other