Changeset 2547 for XIOS3/trunk/src/transport/one_sided_context_server.cpp

Timestamp:

08/29/23 17:24:04 (10 months ago)

Author:

ymipsl

Message:

Major update :

• New method to lock and unlock one-sided windows (window_dynamic) to avoid network overhead
• Introducing multithreading on server sided to manage more efficiently dead-lock occuring (similar to co-routine which will be available and implemented in futur c++ standard), based on c++ threads
• Suprression of old "attached mode" which is replaced by online writer and reder filters

YM

File:

• XIOS3/trunk/src/transport/one_sided_context_server.cpp (modified) (8 diffs)

XIOS3/trunk/src/transport/one_sided_context_server.cpp

@@ -42 +42 @@
     finished=false;
 
-    if (!isAttachedModeEnabled()) MPI_Intercomm_merge(interComm_,true,&interCommMerged_) ;
+    MPI_Intercomm_merge(interComm_,true,&interCommMerged_) ;
     MPI_Comm_split(intraComm_, intraCommRank, intraCommRank, &commSelf_) ; // for windows
     
@@ -48 +48 @@
 
     pureOneSided=CXios::getin<bool>("pure_one_sided",false); // pure one sided communication (for test)
-    if (isAttachedModeEnabled()) pureOneSided=false ; // no one sided in attach mode
       
   }
@@ -165 +164 @@
   
     if (isProcessingEvent_) return ;
-    if (isAttachedModeEnabled())
-      if (!CXios::getDaemonsManager()->isScheduledContext(remoteHashId_)) return ;
 
     auto it=completedEvents_.find(currentTimeLine);
@@ -174 +171 @@
       if (it->second.nbSenders == it->second.currentNbSenders)
       {
-        if (!scheduled && !isAttachedModeEnabled()) // Skip event scheduling for attached mode and reception on client side
+        if (!scheduled) 
         {
           eventScheduler_->registerEvent(currentTimeLine,hashId);
           scheduled=true;
         }
-        else if (isAttachedModeEnabled() || eventScheduler_->queryEvent(currentTimeLine,hashId) )
+        else if (eventScheduler_->queryEvent(currentTimeLine,hashId) )
         {
           //if (!enableEventsProcessing && isCollectiveEvent(event)) return ;
@@ -198 +195 @@
           }
 
-          if (!isAttachedModeEnabled()) eventScheduler_->popEvent() ;
+          eventScheduler_->popEvent() ;
 
           isProcessingEvent_=true ;
@@ -214 +211 @@
           currentTimeLine++;
           scheduled = false;
-          if (isAttachedModeEnabled()) CXios::getDaemonsManager()->unscheduleContext() ;
         }
       }
@@ -235 +231 @@
   void COneSidedContextServer::freeWindows()
   {
-    //if (!isAttachedModeEnabled())
-    //{
     //  for(auto& it : winComm_)
     //  {
@@ -244 +238 @@
     //    MPI_Comm_free(&winComm_[rank]) ;
     //  }
-    //}
   }