Changeset 2547 for XIOS3/trunk/src/manager/pool_ressource.hpp

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/pool_ressource.hpp (modified) (4 diffs)

XIOS3/trunk/src/manager/pool_ressource.hpp

@@ -35 +35 @@
     void createServiceOnto(const std::string& serviceId, int type, const std::string& OnServiceId) ;
     bool eventLoop(bool serviceOnly=false) ;
+    void threadEventLoop(void) ;
     bool hasService(const std::string serviceId, int partitionId) {return services_.count(make_tuple(serviceId,partitionId))>0 ;}
     CService* getService(const std::string serviceId, int partitionId) { return services_[make_tuple(serviceId,partitionId)]; }
@@ -50 +51 @@
     void createService(void) ;
     void createServiceOnto(void) ;
+    void synchronize(void) ;
     
 //    void createServiceNotify(int rank, const std::string& serviceId, int type, int size, int nbPartitions, bool in) ;
@@ -58 +60 @@
   public:
     void createNewServiceOnto(const std::string& serviceId, int type, const string& onServiceId) ;
-    
-    private:
+  
+  private:
+    bool finished_=false ;
+  public:
+    bool isFinished(void) { return finished_ ;}
+
+  private:
     MPI_Comm poolComm_ ;
     
@@ -74 +81 @@
     std::string Id_ ;
     bool finalizeSignal_ ;
-    
+        
     const double eventLoopLatency_=0; 
     double lastEventLoop_=0. ;
 
     private:
+      size_t hashId_ ;
       shared_ptr<CEventScheduler> eventScheduler_ ;
       shared_ptr<CEventScheduler> freeRessourceEventScheduler_ ;