Changeset 2236 for XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/grid_remote_connector.cpp

Timestamp:

09/20/21 18:18:17 (3 years ago)

Author:

ymipsl

Message:

Fix problem in remoteConnector when computing grid to sent to server.
Some optimisations when grid is not distributed need knowledge of the workflow view.
New CGridClientServerConnector class created based on CGridRemoteConnector.

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/grid_remote_connector.cpp (modified) (6 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/grid_remote_connector.cpp

@@ -111 +111 @@
 /**
   * \brief Compute the connector, i.e. compute the \b elements_ attribute. 
+  * \detail Depending of the distributions of the view computed in the computeViewDistribution() call, the connector is computed in computeConnectorMethods(), and to achieve better optimisation
+  *         some redondant ranks can be removed from the elements_ map.
+  */
+  void CGridRemoteConnector::computeConnector(void)
+  {
+    computeViewDistribution() ;
+    computeConnectorMethods() ;
+    computeRedondantRanks() ; 
+    for(auto& rank : rankToRemove_)
+      for(auto& element : elements_) element.erase(rank) ;
+  }
+/**
+  * \brief Compute the connector, i.e. compute the \b elements_ attribute. 
   * \detail In order to achive better optimisation,
   *         we distingute the case when the grid is not distributed on source grid (\bcomputeSrcNonDistributed), 
@@ -120 +133 @@
   *         redondantly the the remote servers
   */
-  void CGridRemoteConnector::computeConnector(void)
-  {
-    computeViewDistribution() ;
+  void CGridRemoteConnector::computeConnectorMethods(void)
+  {
     vector<CLocalView*> srcView ;
     vector<CDistributedView*> dstView ;
@@ -129 +141 @@
     
     bool srcViewsNonDistributed=true ;
-    for(int i=0;i<srcView_.size();i++) srcViewsNonDistributed &= !isSrcViewDistributed_[i]  ;
+    for(int i=0;i<srcView_.size();i++) srcViewsNonDistributed = srcViewsNonDistributed && !isSrcViewDistributed_[i]  ;
     
     bool dstViewsNonDistributed=true ;
-    for(int i=0;i<dstView_.size();i++) dstViewsNonDistributed &= !isDstViewDistributed_[i] ;
+    for(int i=0;i<dstView_.size();i++) dstViewsNonDistributed = dstViewsNonDistributed && !isDstViewDistributed_[i] ;
     
     if (srcViewsNonDistributed) 
@@ -184 +196 @@
     }
 
-    removeRedondantRanks() ;
   }
 
@@ -570 +581 @@
 
  /**
-  * \brief Once the connector is computed (compute \b elements_), redondant data can be send to the server. 
+  * \brief Once the connector is computed (compute \b elements_), redondant data can be avoid to be sent to the server. 
+  *        This call compute the redondant rank and store them in \b rankToRemove_ attribute.
   *        The goal of this method is to make a hash of each block of indice that determine wich data to send to a 
   *        of a specific server rank using a hash method. So data to send to a rank is associated to a hash.
   *        After we compare hash between local rank and remove redondant data corresponding to the same hash.
   */
-  void CGridRemoteConnector::removeRedondantRanks(void)
+  void CGridRemoteConnector::computeRedondantRanks(void)
   {
     int commRank ;
@@ -635 +647 @@
       // only the process with the lowest rank get in charge of sendinf data to remote server
       for(int rank : ranks) if (commRank>rank) first=false ;
-      if (!first)
-      {
-        int rankToRemove=hashRank[hash] ;
-        for(auto& element : elements_) element.erase(rankToRemove) ;
-      }
-    }
-
-
-  }
+      if (!first) rankToRemove_.insert(hashRank[hash]) ;
+    }
+  }
+
 }