Changeset 2403 for XIOS3/trunk/src/manager/services_manager.hpp

Timestamp:

09/16/22 15:20:24 (21 months ago)

Author:

ymipsl

Message:

Refactor service manager notification
YM

File:

• XIOS3/trunk/src/manager/services_manager.hpp (modified) (4 diffs)

XIOS3/trunk/src/manager/services_manager.hpp

@@ -21 +21 @@
     static const int CLIENT=0 ;
     static const int GATHERER=1 ;
-    static const int IO_SERVER=2 ;
-    static const int OUT_SERVER=3 ;
-    static const int ALL_SERVICES=4 ;
+    static const int WRITER=2 ;
+    static const int READER=3 ;
+    static const int IO_SERVER=4 ;
+    static const int OUT_SERVER=5 ;
+    static const int ALL_SERVICES=6 ;
 
+    private:
+    const int NOTIFY_NOTHING=0 ;
+    const int NOTIFY_CREATE_SERVICE=1 ;
+    const int NOTIFY_CREATE_SERVICE_ONTO=2 ;
+    
     public:
     
@@ -31 +38 @@
     
     bool createServices(const std::string& poolId, const std::string& serviceId, int type, int size, int nbPartition, bool wait=true) ;
-    void createServicesNotify(int rank, const string& serviceId, int type, int size, int nbPartitions) ;
-    void checkCreateServicesNotification(void) ;
+    bool createServicesOnto(const std::string& poolId, const std::string& serviceId, const std::string& onServiceId, bool wait=true) ;
+    
     void eventLoop(void) ;
-    void notificationsDumpOut(CBufferOut& buffer) ;
-    void notificationsDumpIn(CBufferIn& buffer) ;
     
     void registerService(const std::string& poolId, const std::string& serviceId, const int& partitionId, int type, int size, int nbPartitions, int leader) ;
@@ -45 +50 @@
     void servicesDumpOut(CBufferOut& buffer) ;
     void servicesDumpIn(CBufferIn& buffer) ;
-    
+
+    private:
+
+    void createService(void) ;
+    void createServiceOnto(void) ;    
+    void createServicesNotify(int rank, const string& serviceId, int type, int size, int nbPartitions) ;
+    void createServicesOntoNotify(int rank, const string& serviceId, const string& OnServiceId) ;
+    void sendNotification(int rank) ;
+    void checkNotifications(void) ;
+    void notificationsDumpOut(CBufferOut& buffer) ;
+    void notificationsDumpIn(CBufferIn& buffer) ;
+
 
     private :
@@ -55 +71 @@
     MPI_Comm xiosComm_ ;
 
-    std::list<std::tuple<std::string, int, int, int> > notifications_;
-    
+    int notifyType_ ;
+    tuple<std::string, int, int, int> notifyCreateService_ ;
+    tuple<std::string, std::string> notifyCreateServiceOnto_ ;
+   
     std::map<tuple<std::string, std::string, int>, std::tuple<int, int, int, int> > services_ ;