Merge pull request #1983 from JasonRuonanWang/ssc-optimization

Optimize one-sided MPI in SSC
ornladios · Feb 23, 2020 · 5e19083 · 5e19083
2 parents 0c0072e + 83882cc
commit 5e19083
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/source/adios2/engine/ssc/SscReader.cpp b/source/adios2/engine/ssc/SscReader.cpp
@@ -113,7 +113,7 @@ StepStatus SscReader::BeginStep(const StepMode stepMode,
     {
         m_InitialStep = false;
         MPI_Win_create(NULL, 0, 1, MPI_INFO_NULL, MPI_COMM_WORLD, &m_MpiWin);
-        MPI_Win_fence(0, m_MpiWin);
+        MPI_Win_start(m_MpiAllWritersGroup, 0, m_MpiWin);
     }
     else
     {
@@ -161,7 +161,7 @@ void SscReader::EndStep()
     TAU_SCOPED_TIMER_FUNC();
     if (m_CurrentStep == 0)
     {
-        MPI_Win_fence(0, m_MpiWin);
+        MPI_Win_complete(m_MpiWin);
         MPI_Win_free(&m_MpiWin);
         SyncReadPattern();
         MPI_Win_create(m_Buffer.data(), m_Buffer.size(), 1, MPI_INFO_NULL,

diff --git a/source/adios2/engine/ssc/SscWriter.cpp b/source/adios2/engine/ssc/SscWriter.cpp
@@ -140,7 +140,7 @@ void SscWriter::EndStep()
         SyncWritePattern();
         MPI_Win_create(m_Buffer.data(), m_Buffer.size(), 1, MPI_INFO_NULL,
                        MPI_COMM_WORLD, &m_MpiWin);
-        PutOneSidedFencePull();
+        PutOneSidedPostPull();
         MPI_Win_free(&m_MpiWin);
         SyncReadPattern();
         MPI_Win_create(m_Buffer.data(), m_Buffer.size(), 1, MPI_INFO_NULL,