Changeset 1555 for XIOS/dev/branch_openmp/src/transformation

Timestamp:

06/29/18 17:16:31 (6 years ago)

Author:

yushan

Message:

all netcdf routines inside critical section

File:

• XIOS/dev/branch_openmp/src/transformation/domain_algorithm_interpolate.cpp (modified) (5 diffs)

XIOS/dev/branch_openmp/src/transformation/domain_algorithm_interpolate.cpp

@@ -807 +807 @@
   
   int my_rank_loc = client->intraComm->ep_comm_ptr->size_rank_info[1].first;
-  
-  cout<<"begin write weight info"<< endl;
+  int my_rank = client->intraComm->ep_comm_ptr->size_rank_info[0].first;
+  
+  
  
   WriteNetCdf *netCdfWriter;
 
-
   MPI_Barrier_local(client->intraComm);
+  
   if(my_rank_loc==0)
   {
-  
+    info(100)<<"rank "<< my_rank <<" create weight info file"<< std::endl;
+    
     WriteNetCdf my_writer(filename, client->intraComm);  
+    info(100)<<"rank "<< my_rank <<" file created"<< std::endl;
     netCdfWriter = &my_writer; 
   
@@ -824 +827 @@
     netCdfWriter->addDimensionWrite("n_dst", n_dst);
     netCdfWriter->addDimensionWrite("n_weight", globalNbWeight);
+    info(100)<<"rank "<< my_rank <<" addDimensionWrite : n_src, n_dst, n_weight"<< std::endl;
   
     std::vector<StdString> dims(1,"n_weight");
@@ -831 +835 @@
     netCdfWriter->addVariableWrite("dst_idx", NC_INT, dims);
     netCdfWriter->addVariableWrite("weight", NC_DOUBLE, dims);
+    
+    info(100)<<"rank "<< my_rank <<" addVariableWrite : src_idx, dst_idx, weight"<< std::endl;
 
     // End of definition
     netCdfWriter->endDefinition();
+    info(100)<<"rank "<< my_rank <<" endDefinition"<< std::endl;
   
     netCdfWriter->closeFile();
-  }
-  
-
+    info(100)<<"rank "<< my_rank <<" file closed"<< std::endl;
+  }
+  
   MPI_Barrier_local(client->intraComm);
   
@@ -844 +851 @@
   {
     // open file
+    info(100)<<"rank "<< my_rank <<" writing in weight info file"<< std::endl;
+    
     WriteNetCdf my_writer(filename, true, client->intraComm);  
+    info(100)<<"rank "<< my_rank <<" file opened"<< std::endl;
     netCdfWriter = &my_writer; 
     
@@ -853 +863 @@
       netCdfWriter->writeDataIndex(dst_idx, "dst_idx", false, 0, &start, &count);
       netCdfWriter->writeDataIndex(weights, "weight", false, 0, &start, &count);
-    }
+      
+      info(100)<<"rank "<< my_rank <<" WriteDataIndex : src_idx, dst_idx, weight"<< std::endl;
+    }
+    
+    netCdfWriter->closeFile();
+    info(100)<<"rank "<< my_rank <<" file closed"<< std::endl;
+    
   }