Changeset 1784 for XIOS/dev/dev_ym/XIOS_COUPLING/src/node/context.hpp

Timestamp:

12/12/19 18:15:14 (5 years ago)

Author:

ymipsl

Message:

• Preparing coupling functionalities.
• Make some cleaner things

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/node/context.hpp (modified) (8 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/node/context.hpp

@@ -26 +26 @@
    class CContext;
    class CFile;
+   class CCouplerIn ;
+   class CCouplerOut ;
    ///--------------------------------------------------------------
 
@@ -120 +122 @@
          void solveAllInheritance(bool apply=true);
          void findEnabledFiles(void);
+         void findEnabledCouplerIn(void);
+         void findEnabledCouplerOut(void);
+         void createCouplerInterCommunicator(void) ;
          void findEnabledWriteModeFiles(void);
          void findEnabledReadModeFiles(void);
@@ -128 +133 @@
          void checkAxisDomainsGridsEligibilityForCompressedOutput();
          void prepareTimeseries(void);
-         void solveOnlyRefOfEnabledFields(bool sendToServer);         
+         void solveOnlyRefOfEnabledFields(void);         
          void buildFilterGraphOfEnabledFields();
          void postProcessFilterGraph();
@@ -140 +145 @@
          void postProcessingGlobalAttributes();         
 
-         void solveAllRefOfEnabledFieldsAndTransform(bool sendToServer);
+         void solveAllRefOfEnabledFieldsAndTransform(void);
          void checkGridEnabledFields();
          void checkGridEnabledFieldsInFiles(const std::vector<CFile*>& activeFiles);
@@ -243 +248 @@
          bool setProcessingEvent(void) {isProcessingEvent_=true ;}
          bool unsetProcessingEvent(void) {isProcessingEvent_=false ;}
+         MPI_Comm getIntraComm(void) { return intraComm_ ;}
+
+         void addCouplingChanel(const std::string& contextId, bool out) ;
 
       public :
@@ -255 +263 @@
          std::vector<CFile*> enabledWriteModeFiles;
 
+         std::vector<CCouplerIn*> enabledCouplerIn;
+         std::vector<CCouplerOut*> enabledCouplerOut;
+
+
          // List of all enabled fields whose instant data is accessible from the public API
          // but which are not part of a file
@@ -272 +284 @@
          std::vector<CContextServer*> serverPrimServer;
          std::vector<CContextClient*> clientPrimServer;
+         std::map<std::string, CContextClient*> couplerClient_ ;
+         std::map<std::string, CContextServer*> couplerServer_ ;
+
+
          std::vector<std::string> primServerId_;
 
@@ -279 +295 @@
 
         MPI_Comm intraComm_ ; //! context intra communicator
-
+        int intraCommRank_ ; //! context intra communicator rank
+        int intraCommSize_ ; //! context intra communicator size
+        
       private:
          bool isPostProcessed;