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

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

@@ -6 +6 @@
 #include "register_context_info.hpp"
 #include "services.hpp"
+#include "timer.hpp"
 
 
@@ -18 +19 @@
                                  hasNotification_(false)
   {
+   info(40)<<"CCServerContext::CServerContext  : new context creation ; contextId : "<<contextId<<endl ;
    int localRank, globalRank, commSize ;
 
@@ -58 +60 @@
                                        const MPI_Comm& intraComm, MPI_Comm& interCommClient, MPI_Comm& interCommServer, bool wait)
   {
+    info(40)<<"CServerContext::createIntercomm  : context intercomm creation ; contextId : "<<contextId<<endl ;
     int intraCommRank ;
     MPI_Comm_rank(intraComm, &intraCommRank) ;
@@ -145 +148 @@
      int commSize ;
      MPI_Comm_size(contextComm_,&commSize) ;
+     info(40)<<"CServerContext::createIntercomm  : notify createContextIntercomm to all context members ; sourceContext : "<<sourceContext<<endl ;
+    
      for(int rank=0; rank<commSize; rank++)
      {
@@ -191 +196 @@
     if (!hasNotification_)
     {
-      int commRank ;
-      MPI_Comm_rank(contextComm_, &commRank) ;
-      winNotify_->lockWindow(commRank,0) ;
-      winNotify_->popFromWindow(commRank, this, &CServerContext::notificationsDumpIn) ;
-      winNotify_->unlockWindow(commRank,0) ;
+      double time=MPI_Wtime() ;
+      if (time-lastEventLoop_ > eventLoopLatency_) 
+      {
+        int commRank ;
+        MPI_Comm_rank(contextComm_, &commRank) ;
+        winNotify_->lockWindow(commRank,0) ;
+        winNotify_->popFromWindow(commRank, this, &CServerContext::notificationsDumpIn) ;
+        winNotify_->unlockWindow(commRank,0) ;
       
-      if (notifyInType_!= NOTIFY_NOTHING)
-      {
-        hasNotification_=true ;
-        auto eventScheduler=parentService_->getEventScheduler() ;
-        std::hash<string> hashString ;
-        size_t hashId = hashString(name_) ;
-        size_t currentTimeLine=0 ;
-        eventScheduler->registerEvent(currentTimeLine,hashId); 
+        if (notifyInType_!= NOTIFY_NOTHING)
+        {
+          hasNotification_=true ;
+          auto eventScheduler=parentService_->getEventScheduler() ;
+          std::hash<string> hashString ;
+          size_t hashId = hashString(name_) ;
+          size_t currentTimeLine=0 ;
+          eventScheduler->registerEvent(currentTimeLine,hashId); 
+        }
+        lastEventLoop_=time ;
       }
     }
@@ -225 +235 @@
   bool CServerContext::eventLoop(bool serviceOnly)
   {
+    CTimer::get("CServerContext::eventLoop").resume();
     bool finished=false ;
-    if (winNotify_!=nullptr) checkNotifications() ;
+    
+//    double time=MPI_Wtime() ;
+//    if (time-lastEventLoop_ > eventLoopLatency_) 
+//    {
+      if (winNotify_!=nullptr) checkNotifications() ;
+//      lastEventLoop_=time ;
+//    }
+
+
     if (!serviceOnly && context_!=nullptr)  
     {
@@ -235 +254 @@
       }
     }
-
+    CTimer::get("CServerContext::eventLoop").suspend();
     if (context_==nullptr && finalizeSignal_) finished=true ;
     return finished ;
@@ -242 +261 @@
   void CServerContext::createIntercomm(void)
   {
+    info(40)<<"CServerContext::createIntercomm  : received createIntercomm notification"<<endl ;
+
      MPI_Comm interCommServer, interCommClient ;
      auto& arg=notifyInCreateIntercomm_ ;