add exo expose and remove old ex2

Yushan-Wang · Yushan-Wang · commit 271ecb44178c · 2025-07-23T11:29:14.000+02:00
diff --git a/ex2.log b/ex2.log
diff --git a/expose/CMakeLists.txt b/expose/CMakeLists.txt
@@ -0,0 +1,36 @@
+#=============================================================================
+# Copyright (C) 2015-2023 Commissariat a l'energie atomique et aux energies alternatives (CEA)
+# 
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+# 
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+# 
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+#=============================================================================
+
+cmake_minimum_required(VERSION 3.16)
+project(pdi_init LANGUAGES C)
+
+find_package(spdlog)
+find_package(MPI REQUIRED COMPONENTS C)
+find_package(paraconf 1.0.0 REQUIRED COMPONENTS C)
+find_package(PDI 1.9.0 REQUIRED COMPONENTS C)
+
+set(CMAKE_C_STANDARD 99)
+
+add_executable(main main.c)
+target_link_libraries(main m MPI::MPI_C paraconf::paraconf PDI::pdi)
+
+
diff --git a/expose/config.yml b/expose/config.yml
@@ -3,8 +3,6 @@ alpha: 0.125
 # global data-size (excluding the number of ghost layers for boundary conditions)
 global_size: { height: 60, width: 12 }
 # degree of parallelism (number of blocks in each dimension)
-parallelism: { height: 1, width: 1 }
+parallelism: { height: 2, width: 2 }
 
 pdi:
-#*** PDI configuration: use the trace plugin to print all the PDI activities
-#...
diff --git a/expose/main.c b/expose/main.c
@@ -30,7 +30,6 @@
 #include <time.h>
 
 #include <paraconf.h>
-// load the PDI header
 #include <pdi.h>
 
 // size of the local data as [HEIGHT, WIDTH] including the number of ghost
@@ -152,15 +151,13 @@ int main(int argc, char *argv[]) {
   MPI_Init(&argc, &argv);
 
   // load the configuration tree
-  PC_tree_t conf = PC_parse_path("ex2.yml");
-
+  PC_tree_t conf = PC_parse_path("config.yml");
+  PDI_init(PC_get(conf, ".pdi"));
+  
   // NEVER USE MPI_COMM_WORLD IN THE CODE, use our own communicator main_comm
   // instead
   MPI_Comm main_comm = MPI_COMM_WORLD;
 
-  // initialize PDI, it can replace our main communicator by its own
-  PDI_init(PC_get(conf, ".pdi"));
-
   // load the MPI rank & size
   int psize_1d;
   MPI_Comm_size(main_comm, &psize_1d);
@@ -172,8 +169,9 @@ int main(int argc, char *argv[]) {
   // load the alpha parameter
   PC_double(PC_get(conf, ".alpha"), &alpha);
 
-  // load the global data-size
   int global_size[2];
+  // load the global data-size
+  // you can use paraconf to read some parameters from the yml config file
   PC_int(PC_get(conf, ".global_size.height"), &longval);
   global_size[0] = longval;
   PC_int(PC_get(conf, ".global_size.width"), &longval);
@@ -211,23 +209,8 @@ int main(int argc, char *argv[]) {
   // our loop counter so as to be able to use it outside the loop
   int ii = 0;
 
-  //*** share useful configuration bits with PDI
-  //*** pcoord, psize, dsize
-  PDI_share("pcoord", pcoord, PDI_OUT);
-  PDI_reclaim("pcoord");
-  PDI_share("psize", psize, PDI_OUT);
-  PDI_reclaim("psize");
-  PDI_share("dsize", dsize, PDI_OUT);
-  PDI_reclaim("dsize");
-
   // the main loop
-  for (; ii < 4; ++ii) {
-    // share the loop counter & main field at each iteration
-    PDI_share("ii", &ii, PDI_OUT);
-    PDI_share("main_field", cur, PDI_OUT);
-    PDI_reclaim("main_field");
-    PDI_reclaim("ii");
-
+  for (; ii < 10; ++ii) {
     // compute the values for the next iteration
     iter(cur, next);
 
@@ -239,21 +222,14 @@ int main(int argc, char *argv[]) {
     cur = next;
     next = tmp;
   }
-  // finally share the loop counter and main field after the main loop body
-  PDI_share("ii", &ii, PDI_OUT);
-  PDI_reclaim("ii");
-  PDI_share("main_field", cur, PDI_OUT);
-  PDI_reclaim("main_field");
-
-  // finalize PDI
-  PDI_finalize();
 
   // destroy the paraconf configuration tree
   PC_tree_destroy(&conf);
 
   // free the allocated memory
   free(cur);
   free(next);
+  PDI_finalize();
 
   // finalize MPI
   MPI_Finalize();
diff --git a/expose/solution/CMakeLists.txt b/expose/solution/CMakeLists.txt
@@ -0,0 +1,36 @@
+#=============================================================================
+# Copyright (C) 2015-2023 Commissariat a l'energie atomique et aux energies alternatives (CEA)
+# 
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+# 
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+# 
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+#=============================================================================
+
+cmake_minimum_required(VERSION 3.16)
+project(pdi_init LANGUAGES C)
+
+find_package(spdlog)
+find_package(MPI REQUIRED COMPONENTS C)
+find_package(paraconf 1.0.0 REQUIRED COMPONENTS C)
+find_package(PDI 1.9.0 REQUIRED COMPONENTS C)
+
+set(CMAKE_C_STANDARD 99)
+
+add_executable(main main.c)
+target_link_libraries(main m MPI::MPI_C paraconf::paraconf PDI::pdi)
+
+
diff --git a/expose/solution/config.yml b/expose/solution/config.yml
@@ -3,10 +3,13 @@ alpha: 0.125
 # global data-size (excluding the number of ghost layers for boundary conditions)
 global_size: { height: 60, width: 12 }
 # degree of parallelism (number of blocks in each dimension)
-parallelism: { height: 1, width: 1 }
+parallelism: { height: 2, width: 2 }
 
-#*** PDI configuration
 pdi:
+  metadata:
+    local_size: {type: array, subtype: int, size: 2}
+  data:
+    iteration: int
+    temp: {type: array, subtype: double, size: ['$local_size[0]', '$local_size[1]']}
   plugins:
     trace:
-      logging: { pattern: '[PDI][%n-plugin] *** %l: %v' }
diff --git a/expose/solution/main.c b/expose/solution/main.c
@@ -30,7 +30,6 @@
 #include <time.h>
 
 #include <paraconf.h>
-// load the PDI header
 #include <pdi.h>
 
 // size of the local data as [HEIGHT, WIDTH] including the number of ghost
@@ -152,15 +151,13 @@ int main(int argc, char *argv[]) {
   MPI_Init(&argc, &argv);
 
   // load the configuration tree
-  PC_tree_t conf = PC_parse_path("ex2.yml");
-
+  PC_tree_t conf = PC_parse_path("config.yml");
+  PDI_init(PC_get(conf, ".pdi"));
+  
   // NEVER USE MPI_COMM_WORLD IN THE CODE, use our own communicator main_comm
   // instead
   MPI_Comm main_comm = MPI_COMM_WORLD;
 
-  // initialize PDI, it can replace our main communicator by its own
-  PDI_init(PC_get(conf, ".pdi"));
-
   // load the MPI rank & size
   int psize_1d;
   MPI_Comm_size(main_comm, &psize_1d);
@@ -172,8 +169,9 @@ int main(int argc, char *argv[]) {
   // load the alpha parameter
   PC_double(PC_get(conf, ".alpha"), &alpha);
 
-  // load the global data-size
   int global_size[2];
+  // load the global data-size
+  // you can use paraconf to read some parameters from the yml config file
   PC_int(PC_get(conf, ".global_size.height"), &longval);
   global_size[0] = longval;
   PC_int(PC_get(conf, ".global_size.width"), &longval);
@@ -195,6 +193,8 @@ int main(int argc, char *argv[]) {
   dsize[0] = global_size[0] / psize[0] + 2;
   dsize[1] = global_size[1] / psize[1] + 2;
 
+  PDI_expose("local_size", dsize, PDI_OUT);
+
   // create a 2D Cartesian MPI communicator & get our coordinate (rank) in it
   int cart_period[2] = {1, 1};
   MPI_Comm cart_comm;
@@ -211,15 +211,9 @@ int main(int argc, char *argv[]) {
   // our loop counter so as to be able to use it outside the loop
   int ii = 0;
 
-  //*** share useful configuration bits with PDI
-  //*** pcoord, psize, dsize
-  //...
-
   // the main loop
-  for (; ii < 4; ++ii) {
-    //*** share the loop counter & main field at each iteration
-    //...
-
+  for (; ii < 10; ++ii) {
+    PDI_expose("temp", cur, PDI_OUT);
     // compute the values for the next iteration
     iter(cur, next);
 
@@ -231,18 +225,15 @@ int main(int argc, char *argv[]) {
     cur = next;
     next = tmp;
   }
-  //*** finally share the loop counter and main field after the main loop body
-  //...
-
-  // finalize PDI
-  PDI_finalize();
+  PDI_expose("temp", cur, PDI_OUT);
 
   // destroy the paraconf configuration tree
   PC_tree_destroy(&conf);
 
   // free the allocated memory
   free(cur);
   free(next);
+  PDI_finalize();
 
   // finalize MPI
   MPI_Finalize();
