Changeset 2547 for XIOS3/trunk/src/manager/services.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/manager/services.cpp (modified) (4 diffs)

XIOS3/trunk/src/manager/services.cpp

@@ -5 +5 @@
 #include "server_context.hpp"
 #include "event_scheduler.hpp"
+#include "thread_manager.hpp"
 #include "timer.hpp"
 
@@ -41 +42 @@
     oss<<partitionId;
     name_= poolId+"__"+serviceId+"_"+oss.str();
+    
+    if (CThreadManager::isUsingThreads()) CThreadManager::spawnThread(&CService::threadEventLoop, this) ;
   }
 
@@ -124 +127 @@
 
     eventScheduler_->checkEvent() ;
+   
     for(auto it=contexts_.begin();it!=contexts_.end();++it) 
     {
@@ -134 +138 @@
       } ;
     }
+  
     CTimer::get("CService::eventLoop").suspend();
     if (contexts_.empty() && finalizeSignal_) return true ;
     else return false ;
   }
+
+  void CService::threadEventLoop(void)
+  {
+    info(100)<<"Launch Thread for  CService::threadEventLoop, service id = "<<name_<<endl ;
+    CThreadManager::threadInitialize() ; 
+    
+    do
+    {
+      CTimer::get("CService::eventLoop").resume();
+      int flag ;
+      MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, MPI_STATUS_IGNORE);
+   
+//    double time=MPI_Wtime() ;
+//    if (time-lastEventLoop_ > eventLoopLatency_) 
+//    {
+      checkNotifications() ;
+//      lastEventLoop_=time ;
+//    }
+
+
+      eventScheduler_->checkEvent() ;
+   
+      for(auto it=contexts_.begin();it!=contexts_.end();++it) 
+      {
+        if (it->second->isFinished())
+        {
+          delete it->second ; 
+          contexts_.erase(it) ;
+          // destroy server_context -> to do later
+          break ;
+        } ;
+      }
+
+      CTimer::get("CService::eventLoop").suspend();
+      if (contexts_.empty() && finalizeSignal_) finished_=true ;
+      if (!finished_) CThreadManager::yield() ;
+    } while (!finished_) ;
+    
+    CThreadManager::threadFinalize() ;
+    info(100)<<"Close thread for  CService::threadEventLoop, service id = "<<name_<<endl ;
+  }
+
 
   void CService::sendNotification(int rank)