Changeset 2258 for XIOS/dev/dev_ym/XIOS_COUPLING/src/buffer_client.cpp

Timestamp:

11/16/21 17:37:42 (3 years ago)

Author:

ymipsl

Message:

One sided protocol improvment.
YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/buffer_client.cpp (modified) (2 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/buffer_client.cpp

@@ -16 +16 @@
   CClientBuffer::CClientBuffer(MPI_Comm interComm, vector<MPI_Win>& windows, int clientRank, int serverRank, StdSize bufferSize, StdSize estimatedMaxEventSize)
     : interComm(interComm)
-    , clientRank_(clientRank)
+    , clientRank_(0)
     , serverRank(serverRank)
     , bufferSize(bufferSize)
@@ -378 +378 @@
   bool CClientBuffer::isNotifiedFinalized(void)
   {
-   
-    bool ret ;
-    lockBuffer() ;
-    ret=*notify[current] == notifyFinalize_ ? true : false ;
-    unlockBuffer() ;
-
-    return ret;
+    if (!isFinalized_)
+    {
+      double time=MPI_Wtime() ;
+//      if (time - lastCheckedNotify_ > latency_)
+      {
+        int flag ;
+        MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, MPI_STATUS_IGNORE);
+        lockBuffer() ;
+        isFinalized_=*notify[current] == notifyFinalize_ ? true : false ;
+        unlockBuffer() ;
+        lastCheckedNotify_=time ;
+      }
+    }
+    return isFinalized_ ;
   }