Changeset 2397 for XIOS3/trunk/src/node/axis.cpp

Timestamp:

08/31/22 17:23:56 (22 months ago)

Author:

ymipsl

Message:

• Optimize remote connector computation in case of read (reverse way).
• don't compute anymore clientFromServerConnector (and all intermediate computation) for non reading case.

YM

File:

• XIOS3/trunk/src/node/axis.cpp (modified) (4 diffs)

XIOS3/trunk/src/node/axis.cpp

@@ -982 +982 @@
   }
  
-  void CAxis::distributeToServer(CContextClient* client, std::map<int, CArray<size_t,1>>& globalIndexOut, std::map<int, CArray<size_t,1>>& globalIndexIn, 
+  void CAxis::distributeToServer(CContextClient* client, bool inOut, std::map<int, CArray<size_t,1>>& globalIndexOut, std::map<int, CArray<size_t,1>>& globalIndexIn, 
                                  shared_ptr<CScattererConnector> &scattererConnector, const string& axisId)
   {
@@ -1042 +1042 @@
     // phase 3 : compute connector to receive from server
     ////////////
+    if (inOut)
     {
       auto scatteredElement = make_shared<CDistributedElement>(n_glo, globalIndexIn) ;
@@ -1128 +1129 @@
 //      gathererConnector_ -> computeConnector() ;
     }
-    else if (phasis==3)
+    else if (phasis==3) // only for server -> client
     {
       elementTo_ = make_shared<CDistributedElement>(event) ;
@@ -1145 +1146 @@
     serverFromClientConnector_ = make_shared<CGathererConnector>(elementFrom_->getView(CElementView::FULL), localElement_->getView(CElementView::WORKFLOW)) ;
     serverFromClientConnector_->computeConnector() ;
-      
-    serverToClientConnector_ = make_shared<CScattererConnector>(localElement_->getView(CElementView::WORKFLOW), elementTo_->getView(CElementView::FULL),
+    elementFrom_.reset() ;
+
+    if (elementTo_)
+    {
+      serverToClientConnector_ = make_shared<CScattererConnector>(localElement_->getView(CElementView::WORKFLOW), elementTo_->getView(CElementView::FULL),
                                                                 context->getIntraComm(), client->getRemoteSize()) ;
-    serverToClientConnector_->computeConnector() ;
+      serverToClientConnector_->computeConnector() ;
+      elementTo_.reset() ;
+    }
   }
   CATCH_DUMP_ATTR