Revision fb94cc59c598ba13db693fec344a0282d373b88e authored by Simon Byrne on 26 June 2019, 04:58:42 UTC, committed by Simon Byrne on 26 June 2019, 04:58:48 UTC
1 parent f689ed5
test_cman_julia.jl
using Test
using MPI
using Distributed
# Start workers via `mpiexec` that communicate among themselves via MPI;
# communicate with the workers via TCP
if !Sys.iswindows() && occursin( "OpenRTE", open(f->read(f, String),`mpiexec --version`))
mgr = MPI.MPIManager(np=4, mpirun_cmd=`mpiexec --oversubscribe -n 4`)
else
mgr = MPI.MPIManager(np=4)
end
addprocs(mgr)
refs = []
for w in workers()
push!(refs, @spawnat w MPI.Comm_rank(MPI.COMM_WORLD))
end
ids = falses(nworkers())
for r in refs
id = fetch(r)
@test !ids[id+1]
ids[id+1] = true
end
for id in ids
@test id
end
s = @distributed (+) for i in 1:10
i^2
end
@test s == 385
@mpi_do mgr n = 2
@mpi_do mgr n + 2
Computing file changes ...
