Changeset 2246 for XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/servers_ressource.cpp

Timestamp:

10/11/21 14:41:56 (3 years ago)

Author:

ymipsl

Message:

• Update of the tranfer protocol using one sided communication
• Introduce MPI_Improb/MPI_mrecv to listen incomming request
• Introducing latency when looping over managers

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/servers_ressource.cpp (modified) (3 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/servers_ressource.cpp

@@ -5 +5 @@
 #include "cxios.hpp"
 #include "mpi.hpp"
+#include "timer.hpp"
 #include <vector>
 #include <string>
@@ -115 +116 @@
   bool CServersRessource::eventLoop(bool serviceOnly)
   {
-    checkNotifications() ;
+    CTimer::get("CServersRessource::eventLoop").resume();
+    double time=MPI_Wtime() ;
+    if (time-lastEventLoop_ > eventLoopLatency_) 
+    {
+      checkNotifications() ;
+      lastEventLoop_=time ;
+    }
+
     if (poolRessource_!=nullptr) 
     {
@@ -124 +132 @@
       } 
     }
-
+    CTimer::get("CServersRessource::eventLoop").suspend();
     if (poolRessource_==nullptr && finalizeSignal_) return true ;
     else return false ;