X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/147d0e88c4da14c801d15e0875bedb474180bea2..325b135f0ee33c6c0242a14e2f58a54fb571b032:/main.cpp?ds=sidebyside diff --git a/main.cpp b/main.cpp index 314cac2..a40bb9f 100644 --- a/main.cpp +++ b/main.cpp @@ -2,14 +2,21 @@ #include #include #include +#include "hostdata.h" #include "misc.h" #include "options.h" #include "process.h" #include "timer.h" #include "version.h" -// Creates a new log category and makes it the default -XBT_LOG_NEW_DEFAULT_CATEGORY(simu, "Simulation messages"); +// Creates log categories +XBT_LOG_NEW_CATEGORY(simu, "Simulation messages"); +XBT_LOG_NEW_SUBCATEGORY(main, simu, "Messages from global infrastructure"); +XBT_LOG_NEW_SUBCATEGORY(comm, simu, "Messages from asynchronous pipes"); +XBT_LOG_NEW_SUBCATEGORY(proc, simu, "Messages from base process class"); +XBT_LOG_NEW_SUBCATEGORY(loba, simu, "Messages from load-balancer"); + +XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(main); // Failure exit status enum { @@ -20,13 +27,15 @@ enum { EXIT_FAILURE_CLEAN = 0x08, // error at cleanup }; -int simulation_main(int argc, char *argv[]) +#include "loba_least_loaded.h" +int simulation_main(int argc, char* argv[]) { - process proc(argc, argv); + // process proc(argc, argv); + loba_least_loaded proc(argc, argv); return proc.run(); } -int main(int argc, char *argv[]) +int main(int argc, char* argv[]) { // Note: variables used after THROW must be declared as volatile. volatile int exit_status = 0; // global exit status @@ -39,7 +48,7 @@ int main(int argc, char *argv[]) // Set default logging parameters // xbt_log_control_set("simu.thres:verbose"); - xbt_log_control_set("simu.fmt:'[%h %r] [%c/%p] %m%n'"); + xbt_log_control_set("simu.fmt:'[%h %r] [%c/%p] %m%n'"); // Initialize some MSG internal data. // Note: MSG_global_init() may throw an exception, but it seems @@ -71,14 +80,7 @@ int main(int argc, char *argv[]) // Create the platform and the application. MSG_create_environment(opt::platform_file); - if (LOG_ISENABLED(xbt_log_priority_verbose)) { - int n = MSG_get_host_number(); - m_host_t *h = MSG_get_host_table(); - VERB1("Got %d hosts.", n); - for (int i = 0; i < n; i++) - VERB2("Host #%d named \"%s\".", i, MSG_host_get_name(h[i])); - xbt_free(h); - } + hostdata::create(); MSG_launch_application(opt::application_file); exit_status = EXIT_FAILURE_SIMU; // ===== @@ -103,6 +105,7 @@ int main(int argc, char *argv[]) } // Clean the MSG simulation. + hostdata::destroy(); res = MSG_clean(); if (res != MSG_OK) { ERROR1("MSG_clean() failed with status %#x", res);