Merge pull request #130 from JaredCrean2/waitany_fix

Waitany fix

Author: eschnett

src/mpi-base.jl

@@ -369,10 +369,10 @@ function Waitany!(reqs::Array{Request,1})
     stat = Status()
     ccall(MPI_WAITANY, Void,
           (Ptr{Cint}, Ptr{Cint}, Ptr{Cint}, Ptr{Cint}, Ptr{Cint}),
-          &count, reqvals, index, statvals, &0)
+          &count, reqvals, ind, stat.val, &0)
     index = Int(ind[])
     reqs[index].val = reqvals[index]
-    reqa[index].buffer = nothing
+    reqs[index].buffer = nothing
     (index, stat)
 end
 

test/test_wait.jl

@@ -0,0 +1,50 @@
+# tests for the various kinds of waits
+using Base.Test
+using MPI
+
+MPI.Init()
+myrank = MPI.Comm_rank(MPI.COMM_WORLD)
+commsize = MPI.Comm_rank(MPI.COMM_WORLD)
+
+nsends = 2
+send_arr = Array(Array{Int, 1}, nsends)
+recv_arr = Array(Array{Int, 1}, nsends)
+
+for i=1:nsends
+    send_arr[i] = [i]
+    recv_arr[i] = Array(Int, 1)
+end
+
+send_reqs = Array(MPI.Request, nsends)
+recv_reqs = Array(MPI.Request, nsends)
+
+# send to self
+for i=1:nsends
+    send_reqs[i] = MPI.Isend(send_arr[i], myrank, i, MPI.COMM_WORLD)
+    recv_reqs[i] = MPI.Irecv!(recv_arr[i], myrank, i, MPI.COMM_WORLD)
+end
+
+send_check = zeros(Int, nsends)
+recv_check = zeros(Int, nsends)
+for i=1:nsends
+    idx, stat = MPI.Waitany!(send_reqs)
+    send_check[idx] += 1
+    send_reqs[idx] = MPI.REQUEST_NULL
+end
+
+for i=1:nsends
+  @test send_check[i] == 1
+end
+
+for i=1:nsends
+    idx, stat = MPI.Waitany!(recv_reqs)
+    recv_check[idx] += 1
+    recv_reqs[idx] = MPI.REQUEST_NULL
+end
+
+for i=1:nsends
+  @test recv_check[i] == 1
+end
+
+MPI.Barrier(MPI.COMM_WORLD)
+MPI.Finalize()