Changeset 1538 for XIOS/dev/branch_openmp/src

Timestamp:

06/11/18 19:06:45 (6 years ago)

Author:

yushan

Message:

tests in XIOS OK (client, complete, remap, toy)

Location:

XIOS/dev/branch_openmp/src

Files:

• context_server.cpp (modified) (2 diffs)
• cxios.cpp (modified) (1 diff)
• io/inetcdf4.cpp (modified) (1 diff)
• node/context.cpp (modified) (8 diffs)

XIOS/dev/branch_openmp/src/context_server.cpp

@@ -120 +120 @@
     #elif _usingEP
     int rank=status.ep_src;
-    #endif
+    #endif    
 
     it=buffers.find(rank);
@@ -127 +127 @@
        StdSize buffSize = 0;
        MPI_Request request;
+       
        MPI_Irecv(&buffSize, 1, MPI_LONG, rank, 20, interComm, &request);
        MPI_Wait(&request, &status);

XIOS/dev/branch_openmp/src/cxios.cpp

@@ -108 +108 @@
       MPI_Comm_create_endpoints(MPI_COMM_WORLD->mpi_comm, num_ep, info, ep_comm);  // servers should reach here too.
       passage = ep_comm; 
-      EP_group_init();
       //::MPI_Comm_group(to_mpi_comm(MPI_COMM_WORLD->mpi_comm), &MPI_GROUP_WORLD); 
     }

XIOS/dev/branch_openmp/src/io/inetcdf4.cpp

@@ -21 +21 @@
     //mpi = comm && !multifile;
     mpi = comm && !multifile && readMetaDataPar;
-    ep_lib::MPI_Info info_null;
+    //ep_lib::MPI_Info info_null = MPI_INFO_NULL;
 
     // The file format will be detected automatically by NetCDF, it is safe to always set NC_MPIIO
     // even if Parallel NetCDF ends up being used.
     if (mpi)
-      CNetCdfInterface::openPar(filename, NC_NOWRITE | NC_MPIIO, to_mpi_comm((*comm)->mpi_comm), to_mpi_info(info_null), this->ncidp);
+      CNetCdfInterface::openPar(filename, NC_NOWRITE | NC_MPIIO, to_mpi_comm((*comm)->mpi_comm), to_mpi_info(MPI_INFO_NULL), this->ncidp);
     else
       CNetCdfInterface::open(filename, NC_NOWRITE, this->ncidp);

XIOS/dev/branch_openmp/src/node/context.cpp

@@ -27 +27 @@
   boost::shared_ptr<CContextGroup> * CContext::root_ptr = 0;
 
-   /// ////////////////////// Définitions ////////////////////// ///
+   /// ////////////////////// Dfinitions ////////////////////// ///
 
    CContext::CContext(void)
@@ -191 +191 @@
       if (!this->hasChild())
       {
-         //oss << "<!-- No definition -->" << std::endl; // fait planter l'incrémentation
+         //oss << "<!-- No definition -->" << std::endl; // fait planter l'incrmentation
       }
       else
@@ -257 +257 @@
      
 
-     //if (CServer::serverLevel != 1)
-      if (CServer::serverLevel == 0)
+     
+      //if (CServer::serverLevel == 0)
+      if (CServer::serverLevel != 1)
       // initClient is called by client
       {
@@ -290 +291 @@
        server = new CContextServer(this, intraCommServer, interCommServer);
      }
-     else if(CServer::serverLevel == 1)
+     //else if(CServer::serverLevel == 1)
+     else
      // initClient is called by primary server
      {
@@ -859 +861 @@
    void CContext::solveAllInheritance(bool apply)
    {
-     // Résolution des héritages descendants (cà d des héritages de groupes)
+     // Rsolution des hritages descendants (cd des hritages de groupes)
      // pour chacun des contextes.
       solveDescInheritance(apply);
 
-     // Résolution des héritages par référence au niveau des fichiers.
+     // Rsolution des hritages par rfrence au niveau des fichiers.
       const vector<CFile*> allFiles=CFile::getAll();
       const vector<CGrid*> allGrids= CGrid::getAll();
@@ -887 +889 @@
 
       for (unsigned int i = 0; i < allFiles.size(); i++)
-         if (!allFiles[i]->enabled.isEmpty()) // Si l'attribut 'enabled' est défini.
+         if (!allFiles[i]->enabled.isEmpty()) // Si l'attribut 'enabled' est dfini.
          {
-            if (allFiles[i]->enabled.getValue()) // Si l'attribut 'enabled' est fixé à vrai.
+            if (allFiles[i]->enabled.getValue()) // Si l'attribut 'enabled' est fix  vrai.
             {
               if (allFiles[i]->output_freq.isEmpty())
@@ -926 +928 @@
 
       if (enabledFiles.size() == 0)
-         DEBUG(<<"Aucun fichier ne va être sorti dans le contexte nommé \""
+         DEBUG(<<"Aucun fichier ne va tre sorti dans le contexte nomm \""
                << getId() << "\" !");
 
@@ -1470 +1472 @@
       if (hasClient && !hasServer) prepareTimeseries();
 
-      //Initialisation du vecteur 'enabledFiles' contenant la liste des fichiers à sortir.
+      //Initialisation du vecteur 'enabledFiles' contenant la liste des fichiers  sortir.
       findEnabledFiles();
       findEnabledWriteModeFiles();