|
1 | 1 | # tests for the various kinds of waits |
2 | 2 | include("common.jl") |
3 | 3 |
|
4 | | -MPI.Init(threadlevel=:multiple) |
| 4 | +provided = MPI.Init(threadlevel=:multiple) |
5 | 5 |
|
6 | | -myrank = MPI.Comm_rank(MPI.COMM_WORLD) |
7 | | -commsize = MPI.Comm_rank(MPI.COMM_WORLD) |
| 6 | +if provided >= MPI.ThreadLevel(:multiple) |
8 | 7 |
|
9 | | -nsends = 2 |
10 | | -send_arr = [ArrayType{Int}([i]) for i = 1:nsends] |
11 | | -recv_arr = [ArrayType{Int}(undef,1) for i = 1:nsends] |
12 | | -synchronize() |
| 8 | + myrank = MPI.Comm_rank(MPI.COMM_WORLD) |
| 9 | + commsize = MPI.Comm_size(MPI.COMM_WORLD) |
13 | 10 |
|
14 | | -send_check = zeros(Int, nsends) |
15 | | -recv_check = zeros(Int, nsends) |
| 11 | + nsends = 2 |
| 12 | + send_arr = [ArrayType{Int}([i]) for i = 1:nsends] |
| 13 | + recv_arr = [ArrayType{Int}(undef,1) for i = 1:nsends] |
| 14 | + synchronize() |
16 | 15 |
|
17 | | -@sync for i = 1:nsends |
18 | | - Threads.@spawn begin |
19 | | - recv_req = MPI.Irecv!(recv_arr[i], MPI.COMM_WORLD; source=myrank, tag=i) |
20 | | - wait(recv_req) |
21 | | - @test MPI.isnull(recv_req) |
22 | | - recv_check[i] += 1 |
23 | | - end |
24 | | - Threads.@spawn begin |
25 | | - send_req = MPI.Isend(send_arr[i], MPI.COMM_WORLD; dest=myrank, tag=i) |
26 | | - wait(send_req) |
27 | | - @test MPI.isnull(send_req) |
28 | | - send_check[i] += 1 |
| 16 | + send_check = zeros(Int, nsends) |
| 17 | + recv_check = zeros(Int, nsends) |
| 18 | + |
| 19 | + @sync for i = 1:nsends |
| 20 | + Threads.@spawn begin |
| 21 | + recv_req = MPI.Irecv!(recv_arr[i], MPI.COMM_WORLD; source=myrank, tag=i) |
| 22 | + wait(recv_req) |
| 23 | + @test MPI.isnull(recv_req) |
| 24 | + recv_check[i] += 1 |
| 25 | + end |
| 26 | + Threads.@spawn begin |
| 27 | + send_req = MPI.Isend(send_arr[i], MPI.COMM_WORLD; dest=myrank, tag=i) |
| 28 | + wait(send_req) |
| 29 | + @test MPI.isnull(send_req) |
| 30 | + send_check[i] += 1 |
| 31 | + end |
29 | 32 | end |
30 | | -end |
31 | 33 |
|
32 | | -@test recv_check == ones(Int, nsends) |
33 | | -@test send_check == ones(Int, nsends) |
| 34 | + @test recv_check == ones(Int, nsends) |
| 35 | + @test send_check == ones(Int, nsends) |
| 36 | + @test all(Array(send_arr[i]) == [i] for i = 1:nsends) |
| 37 | + @test all(Array(recv_arr[i]) == [i] for i = 1:nsends) |
| 38 | + |
| 39 | +end |
34 | 40 |
|
35 | 41 | MPI.Barrier(MPI.COMM_WORLD) |
36 | 42 | MPI.Finalize() |
|
0 commit comments