Skip to content

Commit 9764190

Browse files
authored
simplify test/wait (#479)
* simplify test/wait * change interface for Testany * add Status argument to get extra return type * make Recv signatures consistent
1 parent 82bff4a commit 9764190

File tree

4 files changed

+598
-471
lines changed

4 files changed

+598
-471
lines changed

src/MPI.jl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ include("environment.jl")
4646
include("datatypes.jl")
4747
include("buffers.jl")
4848
include("operators.jl")
49+
include("nonblocking.jl")
4950
include("pointtopoint.jl")
5051
include("collective.jl")
5152
include("topology.jl")

src/deprecated.jl

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -206,3 +206,21 @@ import Base: @deprecate
206206

207207
@deprecate(Accumulate(origin, rank, disp, op, win), Accumulate!(origin, rank, disp, op, win), false)
208208
@deprecate(Get_accumulate(origin, result, rank, disp, op, win), Get_accumulate!(origin, result, rank, disp, op, win), false)
209+
210+
@deprecate(Wait!(req::Request), MPI.Wait(req, MPI.Status), false)
211+
@deprecate(Test!(req::Request), MPI.Test(req, MPI.Status), false)
212+
213+
@deprecate(Waitall!(reqs::Vector{Request}), MPI.Waitall(reqs, MPI.Status), false)
214+
@deprecate(Testall!(reqs::Vector{Request}), MPI.Testall(reqs, MPI.Status), false)
215+
216+
@deprecate(Waitany!(reqs::Vector{Request}), ((i, status) = MPI.Waitany(reqs, MPI.Status); (something(i,0), status)), false)
217+
@deprecate(Testany!(reqs::Vector{Request}), ((flag, i, status) = MPI.Testany(reqs, MPI.Status); (flag, i isa Integer ? i : 0, status)), false)
218+
219+
@deprecate(Waitsome!(reqs::Vector{Request}), ((inds, statuses) = MPI.Waitsome(reqs, MPI.Status); (something(inds, Int[]), statuses)), false)
220+
@deprecate(Testsome!(reqs::Vector{Request}), ((inds, statuses) = MPI.Testsome(reqs, MPI.Status); (something(inds, Int[]), statuses)), false)
221+
222+
@deprecate(Recv!(recvbuf, src::Integer, tag::Integer, comm::Comm), Recv!(recvbuf, src, tag, comm, MPI.Status)[2], false)
223+
@deprecate(Recv(T, src::Integer, tag::Integer, comm::Comm), Recv(recvbuf, src, tag, comm, MPI.Status), false)
224+
@deprecate(recv(T, src::Integer, tag::Integer, comm::Comm), recv(recvbuf, src, tag, comm, MPI.Status), false)
225+
@deprecate(Sendrecv!(sendbuf, dest::Integer, sendtag::Integer, recvbuf, source::Integer, recvtag::Integer, comm::Comm),
226+
Sendrecv!(sendbuf, dest, sendtag, recvbuf, source, recvtag, comm, MPI.Status)[2], false)

0 commit comments

Comments
 (0)