Wrapped Ibarrier

Author: kshyatt

deps/CMakeLists.txt

@@ -49,6 +49,7 @@ FortranCInterface_HEADER(jlmpi_f2c.h MACRO_NAMESPACE "JLMPI_" SYMBOLS
   MPI_GATHERV
   MPI_GET_COUNT
   MPI_GET_PROCESSOR_NAME
+  MPI_IBARRIER
   MPI_INIT
   MPI_INITIALIZED
   MPI_IPROBE

deps/gen_functions.c

@@ -37,6 +37,7 @@ int main(int argc, char *argv[]) {
   printf("    :MPI_GET_COUNT          => \"%s\",\n", STRING(MPI_GET_COUNT));
   printf("    :MPI_GET_PROCESSOR_NAME => \"%s\",\n",
          STRING(MPI_GET_PROCESSOR_NAME));
+  printf("    :MPI_IBARRIER           => \"%s\",\n", STRING(MPI_IBARRIER));
   printf("    :MPI_INIT               => \"%s\",\n", STRING(MPI_INIT));
   printf("    :MPI_INITIALIZED        => \"%s\",\n", STRING(MPI_INITIALIZED));
   printf("    :MPI_IPROBE             => \"%s\",\n", STRING(MPI_IPROBE));

src/mpi-base.jl

@@ -463,6 +463,11 @@ function Cancel!(req::Request)
 end
 
 # Collective communication
+function Ibarrier(comm::Comm)
+    rval = Ref{Cint}()
+    ccall(MPI_IBARRIER, Void, (Ptr{Cint},Ptr{Cint},Ptr{Cint}), &comm.val, rval, &0)
+    Request(rval[], nothing)
+end
 
 function Barrier(comm::Comm)
     ccall(MPI_BARRIER, Void, (Ptr{Cint},Ptr{Cint}), &comm.val, &0)

src/win_mpiconstants.jl

@@ -51,6 +51,7 @@ const MPI_INIT = (:MPI_INIT, "msmpi.dll")
 const MPI_COMM_RANK = (:MPI_COMM_RANK, "msmpi.dll")
 const MPI_COMM_SIZE = (:MPI_COMM_SIZE, "msmpi.dll")
 const MPI_BARRIER = (:MPI_BARRIER, "msmpi.dll")
+const MPI_IBARRIER = (:MPI_IBARRIER, "msmpi.dll")
 const MPI_FINALIZE = (:MPI_FINALIZE, "msmpi.dll")
 const MPI_BCAST = (:MPI_BCAST, "msmpi.dll")
 const MPI_REDUCE = (:MPI_REDUCE, "msmpi.dll")

test/test_comm.jl

@@ -9,6 +9,8 @@ comm2 = MPI.Comm_dup(comm)
 MPI.Barrier(comm2)
 comm3 = MPI.Comm_dup(comm2)
 MPI.Barrier(comm3)
+comm4 = MPI.Comm_dup(comm3)
+barreq = MPI.Ibarrier(comm4)
 MPI.Comm_free(comm2)
 MPI.Barrier(comm3)
 # Don't free comm2