Changeset 1080 for XIOS

Timestamp:

03/29/17 19:12:27 (7 years ago)

Author:

yushan

Message:

Under development : save modification

Location:

XIOS/dev/branch_yushan

Files:

• bld.cfg (modified) (1 diff)
• src/client.cpp (modified) (2 diffs)
• src/client.hpp (modified) (1 diff)
• src/group_factory.hpp (modified) (1 diff)
• src/node/context.cpp (modified) (2 diffs)
• src/node/context.hpp (modified) (2 diffs)
• src/object_factory.hpp (modified) (1 diff)
• src/registry.hpp (modified) (1 diff)
• src/test/test_omp.f90 (modified) (3 diffs)
• src/xml_parser.cpp (modified) (1 diff)

XIOS/dev/branch_yushan/bld.cfg

@@ -36 +36 @@
 #bld::target test_remap.exe
 #bld::target test_new_features.exe test_unstruct_complete.exe 
-bld::target test_omp.exe test_client.exe #test_complete.exe 
+bld::target test_omp.exe #test_client.exe #test_complete.exe 
 bld::exe_dep
 

XIOS/dev/branch_yushan/src/client.cpp

@@ -193 +193 @@
       printf("Client %d CContext::setCurrent OK\n", getRank());
       CContext* context = CContext::create(id);
-      printf("Client %d context=CContext::create(%s) OK\n", getRank(), id);
+      printf("Client %d context=CContext::create(%s) OK, *context = %p\n", getRank(), id, &(*context));
       
       StdString idServer(id);
@@ -254 +254 @@
         MPI_Comm_dup(contextComm,&contextInterComm) ;
         CContext* contextServer = CContext::create(idServer);
-
+        
         // Firstly, initialize context on client side
         context->initClient(contextComm,contextInterComm, contextServer);

XIOS/dev/branch_yushan/src/client.hpp

@@ -23 +23 @@
         static std::list<MPI_Comm> contextInterComms;
         // #pragma omp threadprivate(contextInterComms)
+        //std::list<MPI_Comm> contextInterComms;
 
         static int serverLeader;

XIOS/dev/branch_yushan/src/group_factory.hpp

@@ -70 +70 @@
          /// Propriétés statiques ///
          static StdString CurrContext;
+         //#pragma omp threadprivate(CurrContext)
 
    }; // class CGroupFactory

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

@@ -243 +243 @@
      int tmp_rank;
      MPI_Comm_rank(intraComm, &tmp_rank);
+     MPI_Barrier(intraComm);
      
-     #pragma omp critical (_output)
-     printf("Client %d : client = new CContextClient(this,intraComm, interComm, cxtServer) \n", tmp_rank) ;
+     
      
      registryIn=new CRegistry(intraComm);
+
+     #pragma omp critical (_output)
+     printf("Client %d : registryIn=new CRegistry(intraComm), &registryIn = %p, registryIn = %p \n", tmp_rank, &registryIn, registryIn) ;
+
+     // registryIn=new CRegistry;
+     // registryIn->communicator = intraComm;
      registryIn->setPath(getId()) ;
      if (client->clientRank==0) registryIn->fromFile("xios_registry.bin") ;
@@ -1185 +1191 @@
   \return pointer to the new context or already-existed one with identity id
   */
+   //bkp
+//   CContext* CContext::create(const StdString& id)
+//   {
+//     CContext::setCurrent(id);
+
+//     bool hasctxt = CContext::has(id);
+//     CContext* context = CObjectFactory::CreateObject<CContext>(id).get();
+//     getRoot();
+//     if (!hasctxt) CGroupFactory::AddChild(root, context->getShared());
+
+// #define DECLARE_NODE(Name_, name_) \
+//     C##Name_##Definition::create(C##Name_##Definition::GetDefName());
+// #define DECLARE_NODE_PAR(Name_, name_)
+// #include "node_type.conf"
+
+//     return (context);
+//   }
+
+
   CContext* CContext::create(const StdString& id)
   {
     CContext::setCurrent(id);
 
+
     bool hasctxt = CContext::has(id);
-    CContext* context = CObjectFactory::CreateObject<CContext>(id).get();
-    getRoot();
-    if (!hasctxt) CGroupFactory::AddChild(root, context->getShared());
+    CContext* context[omp_get_num_threads()];
+    for(int i=0; i<omp_get_num_threads(); i++)
+    {
+
+     context[i] = CObjectFactory::CreateObject<CContext>(id).get();
+     getRoot();
+     if (!hasctxt) CGroupFactory::AddChild(root, context[i]->getShared());
 
 #define DECLARE_NODE(Name_, name_) \
-    C##Name_##Definition::create(C##Name_##Definition::GetDefName());
+     C##Name_##Definition::create(C##Name_##Definition::GetDefName());
 #define DECLARE_NODE_PAR(Name_, name_)
 #include "node_type.conf"
-
-    return (context);
+    }
+    int tmp_rank;
+    MPI_Comm_rank(MPI_COMM_WORLD, &tmp_rank);
+    printf("CContext::create : num_threads = %d, my_id = %d, return add = %p\n", omp_get_num_threads(), tmp_rank, &(context[omp_get_thread_num()]));
+    
+    return (context[omp_get_thread_num()]);
   }
-
-
 
      //! Server side: Receive a message to do some post processing

XIOS/dev/branch_yushan/src/node/context.hpp

@@ -21 +21 @@
 
 
-   /// ////////////////////// Déclarations ////////////////////// ///
+   /// ////////////////////// Dclarations ////////////////////// ///
    class CContextGroup;
    class CContextAttributes;
@@ -224 +224 @@
          CRegistry* registryIn ;  //!< input registry which is read from file
          CRegistry* registryOut ; //!< output registry which will be wrote on file at the finalize
+         //#pragma omp threadprivate(registryIn, registryOut)
 
       private:

XIOS/dev/branch_yushan/src/object_factory.hpp

@@ -60 +60 @@
          /// Propriétés statiques ///
          static StdString CurrContext;
+         //#pragma omp threadprivate(CurrContext)
 
    }; // class CObjectFactory

XIOS/dev/branch_yushan/src/registry.hpp

@@ -28 +28 @@
 /** Constructor, the communicator is used for bcast or gather operation between MPI processes */
      
-      CRegistry(const ep_lib::MPI_Comm& comm=MPI_COMM_WORLD) : communicator(comm) {}
+      //CRegistry(const ep_lib::MPI_Comm& comm=MPI_COMM_WORLD) : communicator(comm) {}
+      CRegistry(const ep_lib::MPI_Comm& comm=MPI_COMM_WORLD)
+      {
+        communicator = comm;
+      }
       
      

XIOS/dev/branch_yushan/src/test/test_omp.f90

@@ -36 +36 @@
 
   CALL MPI_INIT_THREAD(3, provided, ierr)
+  print*, "provided = ", provided
+  
   CALL init_wait
 
@@ -79 +81 @@
   print*, "xios init OK", rank, size
 
+
    CALL xios_context_initialize("test",comm)
-
    print*, "xios_context init OK", rank, size 
-
-  !CALL xios_context_finalize()
-
-  
+   
+    CALL xios_get_handle("test",ctx_hdl)
+    print*, "xios_get_handle OK", rank, size 
+   
+    CALL xios_set_current_context(ctx_hdl)
+    print*, "xios_set_current_context OK", rank, size 
+ 
+    CALL xios_get_calendar_type(calendar_type)
+    print*, "xios_get_calendar_type OK", rank, size 
+
+  !CALL xios_context_finalize()  
   !print*, "xios_context finalize OK", rank, size 
 
@@ -175 +184 @@
   print *, "Client : xios_finalize "
 
-   else
-
-   CALL xios_init_server
-   print *, "Server : xios_finalize "
-  
-   endif
+    else
+
+    CALL xios_init_server
+    print *, "Server : xios_finalize "
+  
+    endif
     
 

XIOS/dev/branch_yushan/src/xml_parser.cpp

@@ -11 +11 @@
    namespace xml
    {
-      /// ////////////////////// Définitions ////////////////////// ///
+      /// ////////////////////// Dfinitions ////////////////////// ///
 
       void CXMLParser::ParseFile(const StdString & filename, const std::set<StdString>& parseContextList)