Add statistics about message exchanges.

[loba.git] / main.cpp

diff --git a/main.cpp b/main.cpp
index ad59642611707298e6e9e335e23843644a122911..7af6b74759ba189fb93e9630291b0b5074eb177f 100644 (file)
--- a/main.cpp
+++ b/main.cpp
@@ -41,8 +41,16 @@ namespace {
     condition_t* proc_cond;
     unsigned proc_counter = 0;
 
     condition_t* proc_cond;
     unsigned proc_counter = 0;
 

-    statistics comps;

     statistics loads;
     statistics loads;

+    statistics comps;
+    statistics data_send_amount;
+    statistics data_recv_amount;
+    statistics data_send_count;
+    statistics data_recv_count;
+    statistics ctrl_send_amount;
+    statistics ctrl_recv_amount;
+    statistics ctrl_send_count;
+    statistics ctrl_recv_count;

 
 }
 
 
 }
 


@@ -60,8 +68,16 @@ static int simulation_main(int argc, char* argv[])
         result = proc->run();
 
         proc_mutex->acquire();
         result = proc->run();
 
         proc_mutex->acquire();

-        comps.push(proc->get_comp());

         loads.push(proc->get_real_load());
         loads.push(proc->get_real_load());

+        comps.push(proc->get_comp_amount());
+        data_send_amount.push(proc->get_data_send_amount());
+        data_recv_amount.push(proc->get_data_recv_amount());
+        data_send_count.push(proc->get_data_send_count());
+        data_recv_count.push(proc->get_data_recv_count());
+        ctrl_send_amount.push(proc->get_ctrl_send_amount());
+        ctrl_recv_amount.push(proc->get_ctrl_recv_amount());
+        ctrl_send_count.push(proc->get_ctrl_send_count());
+        ctrl_recv_count.push(proc->get_ctrl_recv_count());

 
         // Synchronization barrier...
         // The goal is to circumvent a limitation in SimGrid (at least
 
         // Synchronization barrier...
         // The goal is to circumvent a limitation in SimGrid (at least


@@ -171,8 +187,11 @@ int main(int argc, char* argv[])
         MSG_function_register_default(simulation_main);
 
         // Create the platform and the application.
         MSG_function_register_default(simulation_main);
 
         // Create the platform and the application.

+        XBT_DEBUG("Loading platform file...");

         MSG_create_environment(opt::platform_file.c_str());
         MSG_create_environment(opt::platform_file.c_str());

+        XBT_DEBUG("Creating hostdata...");

         hostdata::create();
         hostdata::create();

+        XBT_DEBUG("Deploying processes...");

         if (opt::auto_depl::enabled) {
             if (!opt::auto_depl::nhosts)
                 opt::auto_depl::nhosts = hostdata::size();
         if (opt::auto_depl::enabled) {
             if (!opt::auto_depl::nhosts)
                 opt::auto_depl::nhosts = hostdata::size();


@@ -236,6 +255,14 @@ int main(int argc, char* argv[])
         XBT_INFO(",----[ Results ]");
         PR_STATS("Load", loads);
         PR_STATS("Computation", comps);
         XBT_INFO(",----[ Results ]");
         PR_STATS("Load", loads);
         PR_STATS("Computation", comps);

+        PR_STATS("Data send", data_send_amount);
+        PR_STATS("Data recv", data_recv_amount);
+        PR_STATS("Data send #", data_send_count);
+        PR_STATS("Data recv #", data_recv_count);
+        PR_STATS("Ctrl send", ctrl_send_amount);
+        PR_STATS("Ctrl recv", ctrl_recv_amount);
+        PR_STATS("Ctrl send #", ctrl_send_count);
+        PR_STATS("Ctrl recv #", ctrl_recv_count);

         XBT_INFO("| Total simulated time...................: %g",
                  simulated_time);
         XBT_INFO("| Total simulation time..................: %g",
         XBT_INFO("| Total simulated time...................: %g",
                  simulated_time);
         XBT_INFO("| Total simulation time..................: %g",