Changeset 1918 for XIOS/dev/dev_ym/XIOS_COUPLING/src/node/domain.hpp

Timestamp:

07/16/20 17:18:01 (4 years ago)

Author:

ymipsl

Message:

Big update on on going work related to data distribution and transfer between clients and servers.

• move all related file into distribution directorie
• implement the concept of data "View"
• implement the concept of "connector" which make the data transfer between 2 differents "Views"

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/node/domain.hpp (modified) (4 diffs)

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

@@ -18 +18 @@
 #include "server_distribution_description.hpp"
 #include "mesh.hpp"
+#include "element.hpp"
+#include "local_connector.hpp"
+#include "gatherer_connector.hpp"
 
 namespace xios {
@@ -50 +53 @@
            EVENT_ID_INDEX, EVENT_ID_LON, EVENT_ID_LAT, 
            EVENT_ID_AREA,
-           EVENT_ID_DATA_INDEX, EVENT_ID_SERVER_ATTRIBUT
+           EVENT_ID_DATA_INDEX, EVENT_ID_SERVER_ATTRIBUT,
+           EVENT_ID_DOMAIN_DISTRIBUTION
          } ;
 
@@ -216 +220 @@
        private:
 
+         static void recvDomainDistribution(CEventServer& event) ;
+         void receivedDomainDistribution(CEventServer& event, int phasis) ;
+        
+
+         void sendDomainDistribution(CContextClient* client, const string& domainId="") ; //for testing
          void sendAttributes(); // ym obsolete -> to be removed
          void sendIndex(CContextClient* client, const string& domainId="");
@@ -301 +310 @@
          static bool _dummyTransformationMapList;
 
+ 
+       private:
+         CLocalElement* localElement_ = nullptr ;
+         void initializeLocalElement(void) ;
+       
+       public:  
+         CLocalElement* getLocalElement(void) { if (localElement_==nullptr) initializeLocalElement() ; return localElement_ ; }
+         CLocalView* getLocalView(CElementView::type type) { return getLocalElement()->getView(type) ;}
+       
+       private:  
+         void addFullView(void) ;
+         void addWorkflowView(void) ;
+         void addModelView(void) ;
+        
+       private:
+         CLocalConnector* modelToWorkflowConnector_ ;
+         void computeModelToWorkflowConnector(void)  ;
+         CGathererConnector*  gathererConnector_ ;
+
+       public:
+         CLocalConnector* getModelToWorkflowConnector(void) { if (modelToWorkflowConnector_==nullptr) computeModelToWorkflowConnector() ; return modelToWorkflowConnector_ ;}
+         
          DECLARE_REF_FUNC(Domain,domain)