Skip to main content

Browse the archive

Revision f5d395aca20928fe5b6962b4222d0945e982de72 authored by Simon Byrne on 23 April 2020, 22:57:48 UTC, committed by GitHub on 23 April 2020, 22:57:48 UTC 
Bump patch version
1 parent 5ae9eb8
Raw File
04-sendrecv.jl 
using MPI
MPI.Init()

comm = MPI.COMM_WORLD
rank = MPI.Comm_rank(comm)
size = MPI.Comm_size(comm)

dst = mod(rank+1, size)
src = mod(rank-1, size)

N = 4

send_mesg = Array{Float64}(undef, N)
recv_mesg = Array{Float64}(undef, N)

fill!(send_mesg, Float64(rank))

rreq = MPI.Irecv!(recv_mesg, src,  src+32, comm)

print("$rank: Sending   $rank -> $dst = $send_mesg\n")
sreq = MPI.Isend(send_mesg, dst, rank+32, comm)

stats = MPI.Waitall!([rreq, sreq])

print("$rank: Received $src -> $rank = $recv_mesg\n")

MPI.Barrier(comm)
back to top