Changeset 1853 for XIOS/dev/dev_ym/XIOS_COUPLING/src/node

Timestamp:

01/20/20 17:55:12 (4 years ago)

Author:

ymipsl

Message:

Coupling branch : replace hasServer and hasClient combination by the name of correct service : CLIENT, GATHERER or OUT_SERVER.

YM

Location:

XIOS/dev/dev_ym/XIOS_COUPLING/src/node

Files:

• axis.cpp (modified) (9 diffs)
• context.cpp (modified) (34 diffs)
• domain.cpp (modified) (10 diffs)
• field.cpp (modified) (22 diffs)
• field.hpp (modified) (2 diffs)
• file.cpp (modified) (9 diffs)
• grid.cpp (modified) (13 diffs)
• grid.hpp (modified) (1 diff)

XIOS/dev/dev_ym/XIOS_COUPLING/src/node/axis.cpp

@@ -319 +319 @@
       {
         // Avoid this check at writing because it fails in case of a hole
-        if (context->hasClient)
+        if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
         {
           StdSize true_size = value.numElements();
@@ -333 +333 @@
       this->checkBounds();
 
-      if (context->hasClient)
+      if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
       {
         this->checkMask();
@@ -512 +512 @@
 
      CContext* context=CContext::getCurrent();
-     if (context->hasClient && !context->hasServer) this->checkAttributes();
+     if (context->getServiceType()==CServicesManager::CLIENT) this->checkAttributes();
 
      this->areClientAttributesChecked_ = true;
@@ -529 +529 @@
 
      if (this->isClientAfterTransformationChecked) return;
-     if (context->hasClient)
+     if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
      {        
        if (orderPositionInGrid == CServerDistributionDescription::defaultDistributedDimension(globalDim.size(), distType))
@@ -556 +556 @@
 
      if (this->isChecked) return;
-     if (context->hasClient) sendAttributes(globalDim, orderPositionInGrid, distType);    
+     if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER) sendAttributes(globalDim, orderPositionInGrid, distType);    
 
      this->isChecked = true;
@@ -734 +734 @@
 
     CContext* context=CContext::getCurrent();      
-    CContextServer* server = context->server; 
 
     // We describe the distribution of client (server) on which data are written
@@ -742 +741 @@
     nBeginGlobal[0] = 0; 
     nGlob[0]        = n_glo;
-    CDistributionServer srvDist(server->intraCommSize, nBegin, nSize, nBeginGlobal, nGlob); 
+    CDistributionServer srvDist(context->intraCommSize_, nBegin, nSize, nBeginGlobal, nGlob); 
     const CArray<size_t,1>& writtenGlobalIndex  = srvDist.getGlobalIndex();
 
@@ -784 +783 @@
       size_t nbWritten = 0, indGlo;
       CContext* context=CContext::getCurrent();      
-      CContextServer* server = context->server; 
-
+ 
       // We describe the distribution of client (server) on which data are written
       std::vector<int> nBegin(1), nSize(1), nBeginGlobal(1), nGlob(1);
@@ -792 +790 @@
       nBeginGlobal[0] = 0; 
       nGlob[0]        = n_glo;
-      CDistributionServer srvDist(server->intraCommSize, nBegin, nSize, nBeginGlobal, nGlob); 
+      CDistributionServer srvDist(context->intraCommSize_, nBegin, nSize, nBeginGlobal, nGlob); 
       const CArray<size_t,1>& writtenGlobalIndex  = srvDist.getGlobalIndex();
       std::unordered_map<size_t,size_t>::const_iterator itb = globalLocalIndexMap_.begin(),

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

@@ -432 +432 @@
     server = new CContextServer(this,intraComm_, interCommServer); // check if we need to dupl. intraComm_ ?
     client = new CContextClient(this,intraCommClient,interCommClient);
+    client->setAssociatedServer(server) ;  
+    server->setAssociatedClient(client) ;  
 
   }
@@ -492 +494 @@
       client = new CContextClient(this, intraCommClient, interCommClient);
       server = new CContextServer(this, intraCommServer, interCommServer);
-    
+      client->setAssociatedServer(server) ;
+      server->setAssociatedClient(client) ;
     }
     
@@ -526 +529 @@
         MPI_Comm_dup(intraComm_, &intraCommServer) ;
 
-
-        clientPrimServer.push_back(new CContextClient(this, intraCommClient, interCommClient));
-        serverPrimServer.push_back(new CContextServer(this, intraCommServer, interCommServer));  
+        CContextClient* client = new CContextClient(this, intraCommClient, interCommClient) ;
+        CContextServer* server = new CContextServer(this, intraCommServer, interCommServer) ;
+        client->setAssociatedServer(server) ;
+        server->setAssociatedClient(client) ;
+        clientPrimServer.push_back(client);
+        serverPrimServer.push_back(server);  
+
       
       }
@@ -592 +599 @@
          CContextClient* client = new CContextClient(this, intraCommClient, interCommClient);
          CContextServer* server = new CContextServer(this, intraCommServer, interCommServer);
+         client->setAssociatedServer(server) ;
+         server->setAssociatedClient(client) ;
        }
        else
@@ -599 +608 @@
           CContextServer* server = new CContextServer(this, intraCommServer, interCommServer);
           CContextClient* client = new CContextClient(this, intraCommClient, interCommClient);
+          client->setAssociatedServer(server) ;
+          server->setAssociatedClient(client) ;
        }
        MPI_Comm_free(&interComm) ;
@@ -633 +644 @@
       if (server->intraCommRank==0) CXios::globalRegistry->mergeRegistry(*registryOut) ;
 
-      if (hasClient && !hasServer)
+      if (serviceType_==CServicesManager::CLIENT)
       {
         doPreTimestepOperationsForEnabledReadModeFiles(); // For now we only use server level 1 to read data
@@ -650 +661 @@
         info(100)<<"DEBUG: context "<<getId()<<" release client ok"<<endl ;
       }
-      else if (hasClient && hasServer)
+      else if (serviceType_==CServicesManager::GATHERER)
       {
          for (int i = 0; i < clientPrimServer.size(); ++i)
@@ -672 +683 @@
 
       }
-      else if (!hasClient && hasServer)
+      else if (serviceType_==CServicesManager::IO_SERVER || serviceType_==CServicesManager::OUT_SERVER)
       {
         closeAllFile();
@@ -724 +735 @@
      checkGridEnabledFields();
 
-     setClientServerBuffer(client, (hasClient && !hasServer));
+     setClientServerBuffer(client, (serviceType_==CServicesManager::CLIENT) ) ;
      for (int i = 0; i < clientPrimServer.size(); ++i)
          setClientServerBuffer(clientPrimServer[i], true);
 
     
-     if (hasClient)
+     if (serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER)
      { 
-       if (hasServer)
+       if (serviceType_==CServicesManager::GATHERER)
        { 
          for (auto it=clientPrimServer.begin(); it!=clientPrimServer.end();++it) 
@@ -739 +750 @@
          }
        }
-       else
+       else 
        {
          this->sendAllAttributesToServer(client);   // Send all attributes of current context to server
@@ -750 +761 @@
       sendEnabledFiles(this->enabledWriteModeFiles);
       // We only use server-level 1 (for now) to read data
-      if (!hasServer)
-        sendEnabledFiles(this->enabledReadModeFiles);
+      if (serviceType_==CServicesManager::CLIENT)  sendEnabledFiles(this->enabledReadModeFiles);
 
       // Then, send all enabled fields      
       sendEnabledFieldsInFiles(this->enabledWriteModeFiles);
-      if (!hasServer)
-        sendEnabledFieldsInFiles(this->enabledReadModeFiles);
+      
+      if (serviceType_==CServicesManager::CLIENT) sendEnabledFieldsInFiles(this->enabledReadModeFiles);
 
       // Then, check whether we have domain_ref, axis_ref or scalar_ref attached to the enabled fields
       // If any, so send them to server
-       sendRefDomainsAxisScalars(this->enabledWriteModeFiles);
-      if (!hasServer)
-        sendRefDomainsAxisScalars(this->enabledReadModeFiles);        
+       sendRefDomainsAxisScalars(this->enabledWriteModeFiles); 
+     
+      if (serviceType_==CServicesManager::CLIENT) sendRefDomainsAxisScalars(this->enabledReadModeFiles);        
 
        // Check whether enabled fields have grid_ref, if any, send this info to server
@@ -780 +790 @@
       // Finally, we send information of grid itself to server 
       sendGridEnabledFieldsInFiles(this->enabledWriteModeFiles);       
-      if (!hasServer)
-        sendGridEnabledFieldsInFiles(this->enabledReadModeFiles);       
+     
+      if (serviceType_==CServicesManager::CLIENT) sendGridEnabledFieldsInFiles(this->enabledReadModeFiles);       
+     
      }
      allProcessed = true;
@@ -790 +801 @@
    TRY
    {
-      // Use correct context client to send message
-     // int nbSrvPools = (hasServer) ? clientPrimServer.size() : 1;
-    int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
-     for (int i = 0; i < nbSrvPools; ++i)
-     {
-       CContextClient* contextClientTmp = (0 != clientPrimServer.size()) ? clientPrimServer[i] : client;
+
+    int nbSrvPools ;
+    if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+    else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+    else nbSrvPools = 0 ;
+    CContextClient* contextClientTmp ;
+
+    for (int i = 0; i < nbSrvPools; ++i)
+     {
+       if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+       else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
+      
        CEventClient event(getType(),EVENT_ID_POST_PROCESS_GLOBAL_ATTRIBUTES);
 
@@ -844 +861 @@
     postProcessingGlobalAttributes();
 
-    if (hasClient) sendPostProcessingGlobalAttributes();
+    if (serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER) sendPostProcessingGlobalAttributes();
 
     // There are some processings that should be done after all of above. For example: check mask or index
     this->buildFilterGraphOfEnabledFields();
     
-     if (hasClient && !hasServer)
+     if (serviceType_==CServicesManager::CLIENT)
     {
       buildFilterGraphOfFieldsWithReadAccess();
@@ -857 +874 @@
     checkGridEnabledFields();   
 
-    if (hasClient) this->sendProcessingGridOfEnabledFields();
-    if (hasClient) this->sendCloseDefinition();
+    if (serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER) this->sendProcessingGridOfEnabledFields();
+    if (serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER) this->sendCloseDefinition();
 
     // Nettoyage de l'arborescence
-    if (hasClient) CleanTree(); // Only on client side??
-
-    if (hasClient)
-    {
-      sendCreateFileHeader();
-      if (!hasServer) startPrefetchingOfEnabledReadModeFiles();
-    }
+    if (serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER) CleanTree(); // Only on client side??
+
+    if (serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER) sendCreateFileHeader();
+    if (serviceType_==CServicesManager::CLIENT) startPrefetchingOfEnabledReadModeFiles();
+    
     CTimer::get("Context : close definition").suspend() ;
    }
@@ -1109 +1124 @@
       const vector<CGrid*> allGrids= CGrid::getAll();
 
-      if (hasClient && !hasServer)
-      //if (hasClient)
+      if (serviceType_==CServicesManager::CLIENT)
       {
         for (unsigned int i = 0; i < allFiles.size(); i++)
@@ -1229 +1243 @@
      double eps=std::numeric_limits<double>::epsilon()*10 ;
      
-     // If primary server
-     if (hasServer && hasClient)
+     if (serviceType_==CServicesManager::GATHERER)
      {
        std::ofstream ofs(("distribute_file_"+getId()+".dat").c_str(), std::ofstream::out);
@@ -1310 +1323 @@
    TRY
    {
-     // If primary server
-     if (hasServer && hasClient)
+     if (serviceType_==CServicesManager::GATHERER)
      {
        int nbPools = clientPrimServer.size();
@@ -1502 +1514 @@
    TRY
    {
-     // Use correct context client to send message
-     int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
-     for (int i = 0; i < nbSrvPools; ++i)
-     {
-       CContextClient* contextClientTmp = (hasServer) ? clientPrimServer[i] : client;
+    int nbSrvPools ;
+    if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+    else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+    else nbSrvPools = 0 ;
+    CContextClient* contextClientTmp ;
+
+    for (int i = 0; i < nbSrvPools; ++i)
+     {
+       if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+       else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
        CEventClient event(getType(),EVENT_ID_CLOSE_DEFINITION);
        if (contextClientTmp->isServerLeader())
@@ -1534 +1551 @@
    TRY
    {
-     // Use correct context client to send message
-    int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
-     for (int i = 0; i < nbSrvPools; ++i)
-     {
-       CContextClient* contextClientTmp = (hasServer) ? clientPrimServer[i] : client;
+    int nbSrvPools ;
+    if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+    else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+    else nbSrvPools = 0 ;
+    CContextClient* contextClientTmp ;
+
+    for (int i = 0; i < nbSrvPools; ++i)
+    {
+       if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+       else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
        CEventClient event(getType(),EVENT_ID_UPDATE_CALENDAR);
 
@@ -1544 +1566 @@
          {
            CMessage msg;
-           if (hasServer)
-             msg<<step;
-           else
-             msg<<step;
+           msg<<step;
            const std::list<int>& ranks = contextClientTmp->getRanksServerLeader();
            for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
@@ -1574 +1593 @@
       buffer>>step;
       updateCalendar(step);
-      if (hasClient && hasServer)
+      if (serviceType_==CServicesManager::GATHERER)
       {        
         sendUpdateCalendar(step);
@@ -1585 +1604 @@
    TRY
    {
-     // Use correct context client to send message
-     // int nbSrvPools = (hasServer) ? clientPrimServer.size() : 1;
-     int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
+     int nbSrvPools ;
+     if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+     else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+     else nbSrvPools = 0 ;
+     CContextClient* contextClientTmp ;
+
      for (int i = 0; i < nbSrvPools; ++i)
      {
-       CContextClient* contextClientTmp = (hasServer) ? clientPrimServer[i] : client;
+       if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+       else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
        CEventClient event(getType(),EVENT_ID_CREATE_FILE_HEADER);
 
@@ -1619 +1642 @@
    TRY
    {
-      if (!hasClient && hasServer) 
+      if (serviceType_==CServicesManager::IO_SERVER || serviceType_==CServicesManager::OUT_SERVER) 
         createFileHeader();
    }
@@ -1628 +1651 @@
    TRY
    {
-      // Use correct context client to send message
-     int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
+     int nbSrvPools ;
+     if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+     else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+     else nbSrvPools = 0 ;
+     CContextClient* contextClientTmp ;
+
      for (int i = 0; i < nbSrvPools; ++i)
      {
-       CContextClient* contextClientTmp = (0 != clientPrimServer.size()) ? clientPrimServer[i] : client;
+       if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+       else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
+
        CEventClient event(getType(),EVENT_ID_PROCESS_GRID_ENABLED_FIELDS);
 
@@ -1661 +1690 @@
    TRY
    {
-      // Use correct context client to send message
-     // int nbSrvPools = (hasServer) ? clientPrimServer.size() : 1;
-     int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
+     int nbSrvPools ;
+     if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+     else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+     else nbSrvPools = 0 ;
+     CContextClient* contextClientTmp ;
+
      for (int i = 0; i < nbSrvPools; ++i)
      {
-       CContextClient* contextClientTmp = (hasServer) ? clientPrimServer[i] : client;
+       if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+       else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
        CEventClient event(getType(),EVENT_ID_POST_PROCESS);
        if (contextClientTmp->isServerLeader())
@@ -1732 +1765 @@
 
       // The timeseries should only be prepared in client
-      if (hasClient && !hasServer) prepareTimeseries();
+
+      if (serviceType_==CServicesManager::CLIENT) prepareTimeseries();
 
       //Initialisation du vecteur 'enabledFiles' contenant la liste des fichiers à sortir.
@@ -1754 +1788 @@
       //   findAllEnabledFieldsInFiles(this->enabledReadModeFiles);      
 
-      if (hasClient && !hasServer)
+      if (serviceType_==CServicesManager::CLIENT)
       {
         initReadFiles();
@@ -1768 +1802 @@
 
       // Find all fields with read access from the public API
-      if (hasClient && !hasServer) findFieldsWithReadAccess();
+      if (serviceType_==CServicesManager::CLIENT) findFieldsWithReadAccess();
       // and solve the all reference for them
-      if (hasClient && !hasServer) solveAllRefOfFieldsWithReadAccess();
+      if (serviceType_==CServicesManager::CLIENT) solveAllRefOfFieldsWithReadAccess();
 
       isPostProcessed = true;
@@ -1920 +1954 @@
    TRY
    {
-     if (!hasClient) return;
+     if (!(serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER)) return;
 
      const vector<CAxis*> allAxis = CAxis::getAll();
@@ -1940 +1974 @@
    TRY
    {
-     if (!hasClient) return;
+     if (!(serviceType_==CServicesManager::CLIENT || serviceType_==CServicesManager::GATHERER)) return;
 
      const std::vector<CFile*> allFiles = CFile::getAll();
@@ -2146 +2180 @@
       if (prevStep < step)
       {
-        if (hasClient && !hasServer) // For now we only use server level 1 to read data
+        if (serviceType_==CServicesManager::CLIENT) // For now we only use server level 1 to read data
         {
           doPreTimestepOperationsForEnabledReadModeFiles();
@@ -2158 +2192 @@
   #endif
 
-        if (hasClient && !hasServer) // For now we only use server level 1 to read data
+        if (serviceType_==CServicesManager::CLIENT) // For now we only use server level 1 to read data
         {
           doPostTimestepOperationsForEnabledReadModeFiles();
@@ -2268 +2302 @@
     registryOut->hierarchicalGatherRegistry() ;
 
-    // Use correct context client to send message
-    int nbSrvPools = (this->hasServer) ? (this->hasClient ? this->clientPrimServer.size() : 0) : 1;
+    int nbSrvPools ;
+    if (serviceType_==CServicesManager::CLIENT) nbSrvPools = 1 ;
+    else if (serviceType_==CServicesManager::GATHERER) nbSrvPools = this->clientPrimServer.size() ;
+    else nbSrvPools = 0 ;
+    CContextClient* contextClientTmp ;
+
     for (int i = 0; i < nbSrvPools; ++i)
     {
-      CContextClient* contextClientTmp = (hasServer) ? clientPrimServer[i] : client;
+      if (serviceType_==CServicesManager::CLIENT) contextClientTmp = client ;
+      else if (serviceType_==CServicesManager::GATHERER ) contextClientTmp = clientPrimServer[i] ;
+
       CEventClient event(CContext::GetType(), CContext::EVENT_ID_SEND_REGISTRY);
-        if (contextClientTmp->isServerLeader())
-        {
-           CMessage msg ;
-           if (contextClientTmp->clientRank==0) msg<<*registryOut ;
-           const std::list<int>& ranks = contextClientTmp->getRanksServerLeader();
-           for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
+      if (contextClientTmp->isServerLeader())
+      {
+        CMessage msg ;
+        if (contextClientTmp->clientRank==0) msg<<*registryOut ;
+        const std::list<int>& ranks = contextClientTmp->getRanksServerLeader();
+        for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
              event.push(*itRank,1,msg);
-           contextClientTmp->sendEvent(event);
-         }
-         else contextClientTmp->sendEvent(event);
+        contextClientTmp->sendEvent(event);
+      }
+      else contextClientTmp->sendEvent(event);
     }
   }

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

@@ -1727 +1727 @@
 
      if (this->isClientAfterTransformationChecked) return;
-     if (context->hasClient)
+     if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
      {
       this->computeConnectedClients();
        if (hasLonLat)
-         if (!context->hasServer)
+         if (context->getServiceType()==CServicesManager::CLIENT)
            this->completeLonLatClient();
      }
@@ -1748 +1748 @@
      CContext* context=CContext::getCurrent();
 
-      if (context->hasClient && !context->hasServer)
+      if (context->getServiceType()==CServicesManager::CLIENT)
       {
         this->checkDomain();
@@ -1756 +1756 @@
       }
 
-      if (context->hasClient && !context->hasServer)
+      if (context->getServiceType()==CServicesManager::CLIENT)
       { // Ct client uniquement
          this->checkMask();
@@ -1780 +1780 @@
 
      if (this->isChecked) return;
-     if (context->hasClient)
+     if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
      {
        sendAttributes();
@@ -1799 +1799 @@
       this->checkArea();
 
-      if (context->hasClient)
+      if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
       { // Ct client uniquement
          this->checkMask();
@@ -1811 +1811 @@
       }
 
-      if (context->hasClient)
+      if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
       {
         this->computeConnectedClients();
@@ -1972 +1972 @@
 
       CContext* context=CContext::getCurrent();      
-      CContextServer* server = context->server;  
 
       std::vector<int> nBegin(2), nSize(2), nBeginGlobal(2), nGlob(2);
@@ -1979 +1978 @@
       nBeginGlobal[0] = 0; nBeginGlobal[1] = 0;
       nGlob[0]        = ni_glo;   nGlob[1] = nj_glo;
-      CDistributionServer srvDist(server->intraCommSize, nBegin, nSize, nBeginGlobal, nGlob); 
+      CDistributionServer srvDist(context->intraCommSize_, nBegin, nSize, nBeginGlobal, nGlob); 
       const CArray<size_t,1>& writtenGlobalIndex  = srvDist.getGlobalIndex();
 
@@ -2018 +2017 @@
       size_t nbWritten = 0, indGlo;
       CContext* context=CContext::getCurrent();      
-      CContextServer* server = context->server;  
 
       std::vector<int> nBegin(2), nSize(2), nBeginGlobal(2), nGlob(2);
@@ -2025 +2023 @@
       nBeginGlobal[0] = 0; nBeginGlobal[1] = 0;
       nGlob[0]        = ni_glo;   nGlob[1] = nj_glo;
-      CDistributionServer srvDist(server->intraCommSize, nBegin, nSize, nBeginGlobal, nGlob); 
+      CDistributionServer srvDist(context->intraCommSize_, nBegin, nSize, nBeginGlobal, nGlob); 
       const CArray<size_t,1>& writtenGlobalIndex  = srvDist.getGlobalIndex();
 

XIOS/dev/dev_ym/XIOS_COUPLING/src/node/field.cpp

@@ -143 +143 @@
   CATCH
 
-  void CField::sendUpdateData(const CArray<double,1>& data)
+  void CField::sendUpdateData(const CArray<double,1>& data, CContextClient* client)
   TRY
   {
     CTimer::get("Field : send data").resume();
-
-    CContext* context = CContext::getCurrent();
-    CContextClient* client = (!context->hasServer) ? context->client : this->file->getContextClient();
     int receiverSize = client->serverSize;
 
@@ -319 +316 @@
     \param [in] tsDataRequested timestamp when the call is made
   */
-  bool CField::sendReadDataRequest(const CDate& tsDataRequested)
+  bool CField::sendReadDataRequest(const CDate& tsDataRequested, CContextClient* client)
   TRY
   {
     CContext* context = CContext::getCurrent();
-    // CContextClient* client = context->client;
-
-    // This code is for future: If we want to read file with level-2 servers
-    CContextClient* client = (!context->hasServer) ? context->client : this->file->getContextClient();
 
     lastDataRequestedFromServer = tsDataRequested;
@@ -372 +365 @@
       info(20) << "lastDataRequestedFromServer + file->output_freq.getValue() : " << lastDataRequestedFromServer + file->output_freq << endl ;
 
-      dataRequested |= sendReadDataRequest(lastDataRequestedFromServer + file->output_freq);
+      dataRequested |= sendReadDataRequest(lastDataRequestedFromServer + file->output_freq, file->getContextClient());
     }
 
@@ -385 +378 @@
     StdString fieldId;
     *buffer >> fieldId;
-    get(fieldId)->recvReadDataRequest();
+    get(fieldId)->recvReadDataRequest(event.getContextServer());
   }
   CATCH
@@ -395 +388 @@
     In the future, this should (only) be done by the last level servers.
   */
-  void CField::recvReadDataRequest(void)
+  void CField::recvReadDataRequest(CContextServer* server)
   TRY
   {
-    CContext* context = CContext::getCurrent();
-    CContextClient* client = context->client;
-
+    CContextClient* client = server->getAssociatedClient() ;
     CEventClient event(getType(), EVENT_ID_READ_DATA_READY);
     std::list<CMessage> msgs;
@@ -532 +523 @@
     if (!nstepMaxRead)
     {
-       MPI_Allreduce(MPI_IN_PLACE, &nstepMax, 1, MPI_INT, MPI_MAX, context->server->intraComm);
+       MPI_Allreduce(MPI_IN_PLACE, &nstepMax, 1, MPI_INT, MPI_MAX, context->intraComm_);
        nstepMaxRead = true;
     }
@@ -809 +800 @@
    {
      CContext* context = CContext::getCurrent();
-     if (context->hasClient && !context->hasServer)
+     if (context->getServiceType()==CServicesManager::CLIENT)
      {
        if (grid && !grid->isTransformed() && hasDirectFieldReference() && grid != getDirectFieldReference()->grid)
@@ -826 +817 @@
    {
      CContext* context = CContext::getCurrent();
-     if (context->hasClient && !context->hasServer)
+     if (context->getServiceType()==CServicesManager::CLIENT)
      {
        std::map<CGrid*,std::pair<bool,StdString> >& gridSrcMap = grid->getTransGridSource();
@@ -913 +904 @@
    {
      CContext* context = CContext::getCurrent();
-     bool hasClient = context->hasClient;
-     bool hasServer = context->hasServer;
 
      if (!isReferenceSolvedAndTransformed)
@@ -920 +909 @@
         isReferenceSolvedAndTransformed = true;
 
-        if (hasClient && !hasServer)
+        if (context->getServiceType()==CServicesManager::CLIENT)
         {
           solveRefInheritance(true);
@@ -926 +915 @@
         }
 
-        if (hasServer)
+        if (context->getServiceType()==CServicesManager::GATHERER || context->getServiceType()==CServicesManager::OUT_SERVER)
           solveServerOperation();
 
         solveGridReference();
 
-        if (hasClient && !hasServer)
+       if (context->getServiceType()==CServicesManager::CLIENT)
        {
          solveGenerateGrid();
@@ -939 +928 @@
        solveGridDomainAxisRef(false);
 
-       if (hasClient && !hasServer)
+       if (context->getServiceType()==CServicesManager::CLIENT)
        {
          solveTransformedGrid();
@@ -984 +973 @@
         isReferenceSolved = true;
 
-        if (context->hasClient && !context->hasServer)
+        if (context->getServiceType()==CServicesManager::CLIENT)
         {
           solveRefInheritance(true);
@@ -990 +979 @@
         }
 
-        if (context->hasServer)
+        if (context->getServiceType()==CServicesManager::GATHERER || context->getServiceType()==CServicesManager::OUT_SERVER)
           solveServerOperation();
 
@@ -996 +985 @@
         grid->solveDomainAxisRefInheritance(true); // make it again to solve grid reading from file
 
-        if (context->hasClient && !context->hasServer)
+       if (context->getServiceType()==CServicesManager::CLIENT)
        {
          solveGenerateGrid();
@@ -1015 +1004 @@
         areAllReferenceSolved = true;
        
-        if (context->hasClient && !context->hasServer)
+        if (context->getServiceType()==CServicesManager::CLIENT)
         {
           solveRefInheritance(true);
           if (hasDirectFieldReference()) getDirectFieldReference()->solveAllReferenceEnabledField(false);
         }
-        else if (context->hasServer)
+        else if (context->getServiceType()==CServicesManager::GATHERER || context->getServiceType()==CServicesManager::OUT_SERVER)
           solveServerOperation();
 
@@ -1028 +1017 @@
      solveGridDomainAxisRef(doSending2Server);
 
-     if (context->hasClient && !context->hasServer)
+     if (context->getServiceType()==CServicesManager::CLIENT)
      {
        solveTransformedGrid();
@@ -1065 +1054 @@
       CContext* context = CContext::getCurrent();
 
-      if (!context->hasServer || !hasOutputFile) return;
+      if (context->getServiceType()==CServicesManager::CLIENT || !hasOutputFile) return;
 
       if (freq_op.isEmpty())
@@ -1126 +1115 @@
 
      CContext* context = CContext::getCurrent();
-     bool hasWriterServer = context->hasServer && !context->hasClient;
-     bool hasIntermediateServer = context->hasServer && context->hasClient;
+     bool hasWriterServer = context->getServiceType()==CServicesManager::OUT_SERVER ;
+     bool hasIntermediateServer = context->getServiceType()==CServicesManager::GATHERER ;
 
      if (hasWriterServer)
@@ -1155 +1144 @@
          if (file && (file->mode.isEmpty() || file->mode == CFile::mode_attr::write))
          {
-           fileWriterFilter = std::shared_ptr<CFileWriterFilter>(new CFileWriterFilter(gc, this));
+           fileWriterFilter = std::shared_ptr<CFileWriterFilter>(new CFileWriterFilter(gc, this, file->getContextClient()));
            instantDataFilter->connectOutput(fileWriterFilter, 0);
          }
@@ -1217 +1206 @@
          if (file && (file->mode.isEmpty() || file->mode == CFile::mode_attr::write))
          {
-           fileWriterFilter = std::shared_ptr<CFileWriterFilter>(new CFileWriterFilter(gc, this));
+           fileWriterFilter = std::shared_ptr<CFileWriterFilter>(new CFileWriterFilter(gc, this, file->getContextClient()));
            getTemporalDataFilter(gc, file->output_freq)->connectOutput(fileWriterFilter, 0);
          }
@@ -1736 +1725 @@
      CContext* context = CContext::getCurrent();
      client = contextClient;
-     if (context->hasClient)
-     {
-       // A grid is sent by a client (both for read or write) or by primary server (write only)
-       if (context->hasServer)
-       {
-         if (file->mode.isEmpty() || (!file->mode.isEmpty() && file->mode == CFile::mode_attr::write))
-           grid->setContextClient(contextClient);
-       }
-       else
-           grid->setContextClient(contextClient);
-     }
+  
+     // A grid is sent by a client (both for read or write) or by primary server (write only)
+     if (context->getServiceType()==CServicesManager::GATHERER)
+     {
+       if (file->mode.isEmpty() || (!file->mode.isEmpty() && file->mode == CFile::mode_attr::write))
+         grid->setContextClient(contextClient);
+     }
+     else if (context->getServiceType()==CServicesManager::CLIENT)
+       grid->setContextClient(contextClient);
    }
    CATCH_DUMP_ATTR

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

@@ -46 +46 @@
    END_DECLARE_ATTRIBUTE_MAP(CField)
 
+   class CContextClient ;
    ///--------------------------------------------------------------
    class CField
@@ -167 +168 @@
         void recvUpdateData(std::map<int,CBufferIn*>& rankBuffers);
         void writeField(void);
-        bool sendReadDataRequest(const CDate& tsDataRequested);
+        bool sendReadDataRequest(const CDate& tsDataRequested, CContextClient* client);
         bool sendReadDataRequestIfNeeded(void);
         static void recvReadDataRequest(CEventServer& event);
-        void recvReadDataRequest(void);
+        void recvReadDataRequest(CContextServer* server);
         EReadField readField(void);
         static void recvReadDataReady(CEventServer& event);

XIOS/dev/dev_ym/XIOS_COUPLING/src/node/file.cpp

@@ -226 +226 @@
       CContext* context = CContext::getCurrent();
       const CDate& currentDate = context->calendar->getCurrentDate();
-      CContextServer* server = context->server;
 
       lastSync  = currentDate;
@@ -294 +293 @@
     {
       CContext* context = CContext::getCurrent();
-      CContextServer* server = context->server;
 
       // create sub communicator for file
@@ -307 +305 @@
 
       int color = allZoneEmpty ? 0 : 1;
-      MPI_Comm_split(server->intraComm, color, server->intraCommRank, &fileComm);
+      MPI_Comm_split(context->intraComm_, color, context->intraCommRank_, &fileComm);
       if (allZoneEmpty) MPI_Comm_free(&fileComm);
     }
@@ -443 +441 @@
    {
       CContext* context = CContext::getCurrent();
-      CContextServer* server = context->server;
-
+      
       if (!allZoneEmpty)
       {
@@ -560 +557 @@
             MPI_Comm_rank(fileComm, &commRank);
 
-            if (server->intraCommSize > 1)
+            if (context->intraCommSize_ > 1)
             {
               oss << "_" ;
@@ -636 +633 @@
   {
     CContext* context = CContext::getCurrent();
-    CContextServer* server = context->server;
     MPI_Comm readComm = this->fileComm;
 
@@ -683 +679 @@
         MPI_Comm_rank(readComm, &commRank);
 
-        if (server->intraCommSize > 1)
+        if (context->intraCommSize_ > 1)
         {
           oss << "_";
@@ -699 +695 @@
       bool isCollective = par_access.isEmpty() || par_access == par_access_attr::collective;
       bool readMetaDataPar = true;
-      if (!context->hasServer) readMetaDataPar = (read_metadata_par.isEmpty()) ? false : read_metadata_par;
+      if (context->getServiceType()==CServicesManager::CLIENT) readMetaDataPar = (read_metadata_par.isEmpty()) ? false : read_metadata_par;
 
       if (isOpen) data_out->closeFile();
@@ -1005 +1001 @@
      int size = this->enabledFields.size();
      for (int i = 0; i < size; ++i)
-       this->enabledFields[i]->sendReadDataRequest(CContext::getCurrent()->getCalendar()->getCurrentDate());
+       this->enabledFields[i]->sendReadDataRequest(CContext::getCurrent()->getCalendar()->getCurrentDate(), getContextClient());
    }
    CATCH_DUMP_ATTR

XIOS/dev/dev_ym/XIOS_COUPLING/src/node/grid.cpp

@@ -331 +331 @@
    {
      CContext* context = CContext::getCurrent();
-     if (context->hasClient && this->isChecked && doSendingIndex && !isIndexSent) 
-     { 
-       if (isScalarGrid())  sendIndexScalarGrid();
-       else  sendIndex();
-       this->isIndexSent = true; 
+     if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)     
+     {
+       if (this->isChecked && doSendingIndex && !isIndexSent) 
+       { 
+         if (isScalarGrid())  sendIndexScalarGrid();
+         else  sendIndex();
+         this->isIndexSent = true; 
+       }
      }
 
@@ -726 +729 @@
           }
 
-          if (doGridHaveDataDistributed(client) && (nbIndex != localIndex.numElements()))
+          if (nbIndex != localIndex.numElements())
                ERROR("void CGrid::computeClientIndex()",
                   << "Number of local index on client is different from number of received global index"
@@ -892 +895 @@
      {
        computeClientIndexScalarGrid();
-       if (context->hasClient)
+       if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
        {
          computeConnectedClientsScalarGrid();
@@ -900 +903 @@
      {
        computeClientIndex();
-       if (context->hasClient)
+       if (context->getServiceType()==CServicesManager::CLIENT || context->getServiceType()==CServicesManager::GATHERER)
        {
          computeConnectedClients();
@@ -1474 +1477 @@
           }
 
-          if (context->hasClient && !context->hasServer)
+          if (context->getServiceType()==CServicesManager::CLIENT)  
             storeIndex_fromSrv_.insert(std::make_pair(rank, CArray<int,1>(outLocalIndexToServer)));
 
@@ -1497 +1500 @@
           }
 
-          if (context->hasClient && !context->hasServer)
+          if (context->getServiceType()==CServicesManager::CLIENT)
             storeIndex_fromSrv_.insert(std::make_pair(rank, CArray<int,1>(outLocalIndexToServer)));
         }
@@ -1544 +1547 @@
           {
             storeIndex_toSrv_[client].insert(std::make_pair(*itRank, CArray<int,1>(outLocalIndexToServer)));
-            if (context->hasClient && !context->hasServer)
+            if (context->getServiceType()==CServicesManager::CLIENT)
               storeIndex_fromSrv_.insert(std::make_pair(*itRank, CArray<int,1>(outLocalIndexToServer)));
             
@@ -1644 +1647 @@
       buffers.push_back(buffer);
     }
-    get(gridId)->recvIndex(ranks, buffers);
+    get(gridId)->recvIndex(ranks, buffers, event.getContextServer());
   }
   CATCH
 
-  void CGrid::recvIndex(vector<int> ranks, vector<CBufferIn*> buffers)
+  void CGrid::recvIndex(vector<int> ranks, vector<CBufferIn*> buffers, CContextServer* server)
   TRY
   {
@@ -1655 +1658 @@
 
     nbReadSenders_.clear();
-    CContextServer* server = context->server  ;
-    CContextClient* client = context->client;   
+    CContextClient* client = server->getAssociatedClient();   
       
     int idx = 0, numElement = axis_domain_order.numElements();
@@ -1811 +1813 @@
     if (isScalarGrid()) return;
 
-    nbReadSenders_[client] = CClientServerMappingDistributed::computeConnectedClients(context->client->serverSize, context->client->clientSize, context->client->intraComm, ranks);
+    nbReadSenders_[client] = CClientServerMappingDistributed::computeConnectedClients(client->serverSize, client->clientSize,
+                                                                                      client->intraComm, ranks);
 
   }
@@ -2222 +2225 @@
     {
       CDomain* pDom = CDomain::get(*it);
-      if (context->hasClient && !context->hasServer)      
+      if (context->getServiceType()==CServicesManager::CLIENT)
       {
         pDom->solveRefInheritance(apply);
@@ -2234 +2237 @@
     {
       CAxis* pAxis = CAxis::get(*it);
-      if (context->hasClient && !context->hasServer)
+      if (context->getServiceType()==CServicesManager::CLIENT)
       {
         pAxis->solveRefInheritance(apply);
@@ -2246 +2249 @@
     {
       CScalar* pScalar = CScalar::get(*it);
-      if (context->hasClient && !context->hasServer)
+      if (context->getServiceType()==CServicesManager::CLIENT)
       {
         pScalar->solveRefInheritance(apply);

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

@@ -160 +160 @@
          static bool dispatchEvent(CEventServer& event);
          static void recvIndex(CEventServer& event);
-         void recvIndex(vector<int> ranks, vector<CBufferIn*> buffers);
+         void recvIndex(vector<int> ranks, vector<CBufferIn*> buffers, CContextServer* server);
          void sendIndex(void);
          void sendIndexScalarGrid();