source: XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/grid_client_server_remote_connector.cpp @ 2304

#include "grid_client_server_remote_connector.hpp"

namespace xios
{
  /** 
   * \brief class constructor. 
   * \param srcView List of sources views.
   * \param dstView List of remotes views.
   * \param localComm Local MPI communicator
   * \param remoteSize Size of the remote communicator
   */ 
  CGridClientServerRemoteConnector::CGridClientServerRemoteConnector( vector<shared_ptr<CLocalView> >& srcFullView, vector<shared_ptr<CLocalView>>& srcWorkflowView, 
                                                                      vector<shared_ptr<CDistributedView>>& dstView, MPI_Comm localComm, int remoteSize) 
                       : CGridRemoteConnector(srcFullView, dstView, localComm, remoteSize) , srcWorkflowView_(srcWorkflowView)
  {}


  void CGridClientServerRemoteConnector::computeConnector(bool eliminateRedondant)
  {
    if (eliminateRedondant)
    {
      auto workflowRemoteConnector=make_shared<CGridRemoteConnector>(srcWorkflowView_,dstView_,localComm_,remoteSize_) ;
      workflowRemoteConnector->computeConnector() ;
      computeViewDistribution() ;
    
      for(int i=0;i<srcView_.size();i++) isSrcViewDistributed_[i] =  isSrcViewDistributed_[i] || workflowRemoteConnector->getIsSrcViewDistributed()[i]  ;
      computeConnectorMethods() ;
      computeRedondantRanks() ;

      for(auto& rank : rankToRemove_)
        if (workflowRemoteConnector->getRankToRemove().count(rank)!=0)
          for(auto& element : elements_) element.erase(rank) ;
    }
    else 
    {
      computeViewDistribution() ;
      computeConnectorRedundant() ;
    }
  }

}