X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9c916cb125de2f1050a588d972fd67ff9aac5e29..12d885f5614ca27378809979c732faa7cb0413e8:/src/msg/msg_global.c diff --git a/src/msg/msg_global.c b/src/msg/msg_global.c index a8a9bb45d4..47e85704a9 100644 --- a/src/msg/msg_global.c +++ b/src/msg/msg_global.c @@ -11,7 +11,9 @@ #include "xbt/log.h" #include "xbt/virtu.h" #include "xbt/ex.h" /* ex_backtrace_display */ +#include "xbt/replay.h" +XBT_LOG_NEW_CATEGORY(msg, "All MSG categories"); XBT_LOG_NEW_DEFAULT_SUBCATEGORY(msg_kernel, msg, "Logging specific to MSG (kernel)"); @@ -19,25 +21,20 @@ MSG_Global_t msg_global = NULL; /********************************* MSG **************************************/ -/** \ingroup msg_simulation - * \brief Initialize some MSG internal data. +/* @brief Initialize MSG with less verifications + * + * You should use the MSG_init() function instead. Failing to do so may turn into PEBKAC some day. You've been warned. */ -void MSG_global_init_args(int *argc, char **argv) -{ - MSG_global_init(argc, argv); -} +void MSG_init_nocheck(int *argc, char **argv) { -/** \ingroup msg_simulation - * \brief Initialize some MSG internal data. - */ -void MSG_global_init(int *argc, char **argv) -{ #ifdef HAVE_TRACING TRACE_global_init(argc, argv); #endif xbt_getpid = MSG_process_self_PID; if (!msg_global) { + s_msg_vm_t vm; // to compute the offset + SIMIX_global_init(argc, argv); msg_global = xbt_new0(s_MSG_Global_t, 1); @@ -49,13 +46,14 @@ void MSG_global_init(int *argc, char **argv) msg_global->sent_msg = 0; msg_global->task_copy_callback = NULL; msg_global->process_data_cleanup = NULL; + msg_global->vms = xbt_swag_new(xbt_swag_offset(vm,all_vms_hookup)); /* initialization of the action module */ _MSG_action_init(); SIMIX_function_register_process_create(MSG_process_create_from_SIMIX); SIMIX_function_register_process_cleanup(MSG_process_cleanup_from_SIMIX); - SIMIX_function_register_process_kill(MSG_process_kill_from_SIMIX); + SIMIX_function_register_process_kill(MSG_process_kill); } #ifdef HAVE_TRACING TRACE_start(); @@ -111,40 +109,8 @@ MSG_error_t MSG_main(void) fflush(stderr); if (MC_IS_ENABLED) { - MC_modelcheck(); - } - else { - SIMIX_run(); - } - return MSG_OK; -} - -MSG_error_t MSG_main_stateful(void) -{ - /* Clean IO before the run */ - fflush(stdout); - fflush(stderr); - - if (MC_IS_ENABLED) { - MC_modelcheck_stateful(); - } - else { - SIMIX_run(); - } - return MSG_OK; -} - - -MSG_error_t MSG_main_liveness(xbt_automaton_t a, char *prgm) -{ - /* Clean IO before the run */ - fflush(stdout); - fflush(stderr); - - if (MC_IS_ENABLED) { - MC_modelcheck_liveness(a, prgm); - } - else { + MC_do_the_modelcheck_for_real(); + } else { SIMIX_run(); } return MSG_OK; @@ -192,6 +158,7 @@ MSG_error_t MSG_clean(void) SIMIX_clean(); + xbt_swag_free(msg_global->vms); free(msg_global); msg_global = NULL; @@ -199,7 +166,7 @@ MSG_error_t MSG_clean(void) } -/** \ingroup msg_easier_life +/** \ingroup msg_simulation * \brief A clock (in second). */ XBT_INLINE double MSG_get_clock(void)