Changeset 2246 for XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/pool_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/pool_ressource.cpp (modified) (6 diffs)

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

@@ -6 +6 @@
 #include "type.hpp"
 #include "cxios.hpp"
+#include "timer.hpp"
 
 namespace xios
@@ -16 +17 @@
     MPI_Comm_rank(poolComm, &commRank) ;
     MPI_Comm_size(poolComm, &commSize) ;
-
-
+    info(40)<<"CPoolRessource::CPoolRessource  : creating new pool : "<<Id<<endl ;
     if (commRank==localLeader_)
     {
@@ -51 +51 @@
     occupancy_.erase(occupancy_.begin(),it) ;
     occupancy_.insert(procs_update.begin(),procs_update.end()) ;
-
+    
+    info(40)<<"CPoolRessource::createService  : notify createService to all pool members ; serviceId : "<<serviceId<<endl ;
     for(int rank=0; rank<commSize; rank++)
     {
@@ -102 +103 @@
   bool CPoolRessource::eventLoop(bool serviceOnly)
   {
-    checkCreateServiceNotification() ;
+    CTimer::get("CPoolRessource::eventLoop").resume();
+   
+    double time=MPI_Wtime() ;
+    if (time-lastEventLoop_ > eventLoopLatency_) 
+    {
+      checkCreateServiceNotification() ;
+      lastEventLoop_=time ;
+    }
+    
     for (auto it=services_.begin(); it!=services_.end() ; ++it) 
     {
@@ -112 +121 @@
       }
     }
-
+    CTimer::get("CPoolRessource::eventLoop").suspend();
     if (services_.empty() && finalizeSignal_) return true ;
     else return false ;
@@ -137 +146 @@
   void CPoolRessource::createNewService(const std::string& serviceId, int type, int size, int nbPartitions, bool in)
   {
+     
+     info(40)<<"CPoolRessource::createNewService  : receive createService notification ; serviceId : "<<serviceId<<endl ;
      MPI_Comm serviceComm, newServiceComm ;
      int commRank ;