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

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

@@ -2 +2 @@
 #include "server.hpp"
 #include "servers_ressource.hpp"
+#include "timer.hpp"
 
 
@@ -43 +44 @@
   void CRessourcesManager::createPool(const string& poolId, int size)
   {
+    info(40)<<"CRessourcesManager::createPool : calling createPool : "<<poolId<<"  of size"<<size<<endl ;
+    info(40)<<"send notification to leader : "<<serverLeader_<<endl ;
     winRessources_->lockWindow(managerGlobalLeader_,0) ;
     winRessources_->updateFromWindow(managerGlobalLeader_, this, &CRessourcesManager::ressourcesDumpIn) ;
@@ -49 +52 @@
     notifyType_=NOTIFY_CREATE_POOL ;
     notifyCreatePool_=make_tuple(poolId, size) ;
+    info(40)<<"CRessourcesManager::createPool : send notification creating pool to server leader "<<serverLeader_<<endl ;
     sendNotification(serverLeader_) ; 
   }
@@ -61 +65 @@
     {
       notifyType_=NOTIFY_FINALIZE ;
+      info(40)<<"CRessourcesManager::finalize : send notification finalize to server leader "<<serverLeader_<<endl ;
       sendNotification(serverLeader_) ;
     } 
@@ -107 +112 @@
   void CRessourcesManager::eventLoop(void)
   {
-    checkNotifications() ;
+    CTimer::get("CRessourcesManager::eventLoop").resume();
+    double time=MPI_Wtime() ;
+    if (time-lastEventLoop_ > eventLoopLatency_) 
+    {
+      checkNotifications() ;
+      lastEventLoop_=time ;
+    }
+
+    CTimer::get("CRessourcesManager::eventLoop").suspend();
   }
   
@@ -114 +127 @@
     int commRank ;
     MPI_Comm_rank(xiosComm_, &commRank) ;
+    CTimer::get("CRessourcesManager::checkNotifications lock").resume();
     winNotify_->lockWindow(commRank,0) ;
+    CTimer::get("CRessourcesManager::checkNotifications lock").suspend();
+    CTimer::get("CRessourcesManager::checkNotifications pop").resume();
     winNotify_->popFromWindow(commRank, this, &CRessourcesManager::notificationsDumpIn) ;
+    CTimer::get("CRessourcesManager::checkNotifications pop").suspend();
+    CTimer::get("CRessourcesManager::checkNotifications unlock").resume();
     winNotify_->unlockWindow(commRank,0) ;
+    CTimer::get("CRessourcesManager::checkNotifications unlock").suspend();
     if (notifyType_==NOTIFY_CREATE_POOL) createPool() ;
     else if (notifyType_==NOTIFY_FINALIZE) finalizeSignal() ;
@@ -123 +142 @@
   void CRessourcesManager::createPool(void)
   {
+    
     auto& arg=notifyCreatePool_ ;
     string poolId=get<0>(arg) ;
     int size=get<1>(arg) ;
+    info(40)<<"CRessourcesManager::createPool : receive create pool notification : "<< poolId<<"  of size "<<size<<endl ;
     CServer::getServersRessource()->createPool(poolId,size) ;
   } 
@@ -131 +152 @@
   void CRessourcesManager::finalizeSignal(void)
   {
+    info(40)<<"CRessourcesManager::createPool : receive finalize notification"<<endl ;
     CServer::getServersRessource()->finalize() ;
   }