Changeset 1385 for XIOS/dev/branch_openmp/extern/ep_dev/main.cpp

Timestamp:

12/19/17 17:50:40 (6 years ago)

Author:

yushan

Message:

dev EP-RMA : MPI_Get_accumulate

File:

• XIOS/dev/branch_openmp/extern/ep_dev/main.cpp (modified) (4 diffs)

XIOS/dev/branch_openmp/extern/ep_dev/main.cpp

@@ -682 +682 @@
 
     MPI_Win ep_win;
-    MPI_Aint buf_size(1);
+    MPI_Aint buf_size=1;
     int buf = rank;
     int local_buf = rank;
+    int result_buf = -1;
     MPI_Win_create(&buf, buf_size, sizeof(int), info, comm, &ep_win);
     MPI_Barrier(comm);
@@ -699 +700 @@
     {
       local_buf = 99;
-      MPI_Aint displs(0);
+      MPI_Aint displs=0;
       MPI_Put(&local_buf, 1, MPI_INT, size-1, displs, 1, MPI_INT, ep_win);
     }
@@ -711 +712 @@
     MPI_Win_fence(0, ep_win);
 
-    if(rank == 0)
-    {
-      MPI_Aint displs(0);
-      MPI_Accumulate(&local_buf, 1, MPI_INT, size-1, displs, 1, MPI_INT, MPI_SUM, ep_win);
+    if(rank == 1)
+    {
+      MPI_Aint displs=0;
+      MPI_Accumulate(&local_buf, 1, MPI_INT, size-1, displs, 1, MPI_INT, MPI_REPLACE, ep_win);
     }
 
@@ -722 +723 @@
     MPI_Win_fence(0, ep_win);
 
+    if(rank == 2)
+    {
+      MPI_Aint displs = 0;
+      MPI_Get_accumulate(&local_buf, 1, MPI_INT, &result_buf, 
+                         1, MPI_INT, size-2, displs,
+                         1, MPI_INT, MPI_SUM, ep_win);
+    }
+
     
     MPI_Win_free(&ep_win);
-    printf("rank = %d, buf = %d, local_buf = %d\n", rank, buf, local_buf);
+    printf("rank = %d, buf = %d, local_buf = %d, result_buf = %d\n", rank, buf, local_buf, result_buf);
     
     MPI_Comm_free(&comm);