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

Timestamp:

12/19/17 17:16:01 (6 years ago)

Author:

yushan

Message:

dev EP-RMA : MPI_Put, MPI_Get

File:

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

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

@@ -30 +30 @@
   MPI_Comm_size(MPI_COMM_WORLD, &mpi_size);
  
-  
-
-
-
-
-
-  //omp_set_num_threads(4);
-
-  
-
   #pragma omp parallel default(shared)
   {
@@ -693 +683 @@
     MPI_Win ep_win;
     MPI_Aint buf_size(1);
-    int buf;
+    int buf = rank;
+    int local_buf = rank;
     MPI_Win_create(&buf, buf_size, sizeof(int), info, comm, &ep_win);
     MPI_Barrier(comm);
@@ -703 +694 @@
     MPI_Barrier(comm);
 
-    MPI_Win_fence(MPI_MODE_NOSUCCEED, ep_win);
-
-    MPI_Barrier(comm);
+    MPI_Win_fence(0, ep_win);
+
+    if(rank == 0)
+    {
+      local_buf = 99;
+      MPI_Aint displs(0);
+      MPI_Put(&local_buf, 1, MPI_INT, size-1, displs, 1, MPI_INT, ep_win);
+    }
+
+    if(rank == size-2)
+    {
+      MPI_Aint displs(0);
+      MPI_Get(&local_buf, 1, MPI_INT, 2, displs, 1, MPI_INT, ep_win);
+    }
+
+
+    MPI_Barrier(comm);
+
+    MPI_Win_fence(0, ep_win);
 
     
     MPI_Win_free(&ep_win);
-    printf("comm free\n");
+    printf("rank = %d, buf = %d, local_buf = %d\n", rank, buf, local_buf);
     
     MPI_Comm_free(&comm);