X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ee6ffc12bf5523e4d2d2193138c791d991ec0ae4..a0d711a05dca6280fc380173262b05a5f9fb15b3:/src/simix/smx_global.cpp diff --git a/src/simix/smx_global.cpp b/src/simix/smx_global.cpp index ea200877e1..ac17f1b797 100644 --- a/src/simix/smx_global.cpp +++ b/src/simix/smx_global.cpp @@ -11,6 +11,7 @@ # include #endif +#include "src/surf/surf_interface.hpp" #include "smx_private.h" #include "smx_private.hpp" #include "xbt/heap.h" @@ -36,6 +37,7 @@ #endif #include "src/mc/mc_record.h" +#include "src/surf/platform.hpp" #ifdef HAVE_SMPI #include "src/smpi/private.h" @@ -55,6 +57,8 @@ typedef struct s_smx_timer { void* args; } s_smx_timer_t; +void (*SMPI_switch_data_segment)(int) = NULL; + static void* SIMIX_synchro_mallocator_new_f(void); static void SIMIX_synchro_mallocator_free_f(void* synchro); static void SIMIX_synchro_mallocator_reset_f(void* synchro); @@ -97,8 +101,13 @@ static void _XBT_CALL segvhandler(int signum, siginfo_t *siginfo, void *context) fprintf(stderr, "Segmentation fault.\n"); #ifdef HAVE_SMPI if (smpi_enabled() && !smpi_privatize_global_variables) { +#ifdef HAVE_PRIVATIZATION fprintf(stderr, "Try to enable SMPI variable privatization with --cfg=smpi/privatize_global_variables:yes.\n"); +#else + fprintf(stderr, + "Sadly, your system does not support --cfg=smpi/privatize_global_variables:yes (yet).\n"); +#endif } #endif } @@ -205,7 +214,6 @@ void SIMIX_global_init(int *argc, char **argv) simix_global->synchro_mallocator = xbt_mallocator_new(65536, SIMIX_synchro_mallocator_new_f, SIMIX_synchro_mallocator_free_f, SIMIX_synchro_mallocator_reset_f); - simix_global->autorestart = SIMIX_host_restart_processes; simix_global->mutex = xbt_os_mutex_init(); surf_init(argc, argv); /* Initialize SURF structures */ @@ -227,8 +235,10 @@ void SIMIX_global_init(int *argc, char **argv) #endif /* register a function to be called by SURF after the environment creation */ sg_platf_init(); - sg_platf_postparse_add_cb(SIMIX_post_create_environment); - surf_on_host_created(SIMIX_host_create); + simgrid::surf::on_postparse.connect(SIMIX_post_create_environment); + simgrid::s4u::Host::onCreation.connect([](simgrid::s4u::Host& host) { + SIMIX_host_create(&host); + }); surf_on_storage_created(SIMIX_storage_create_); } @@ -267,10 +277,10 @@ void SIMIX_clean(void) smx_cleaned = 1; XBT_DEBUG("SIMIX_clean called. Simulation's over."); if (!xbt_dynar_is_empty(simix_global->process_to_run) && SIMIX_get_clock() == 0.0) { - XBT_CRITICAL(" "); - XBT_CRITICAL("The time is still 0, and you still have processes ready to run."); - XBT_CRITICAL("It seems that you forgot to run the simulation that you setup."); - xbt_die("Bailing out to avoid that stop-before-start madness. Please fix your code."); + XBT_CRITICAL(" "); + XBT_CRITICAL("The time is still 0, and you still have processes ready to run."); + XBT_CRITICAL("It seems that you forgot to run the simulation that you setup."); + xbt_die("Bailing out to avoid that stop-before-start madness. Please fix your code."); } /* Kill all processes (but maestro) */ SIMIX_process_killall(simix_global->maestro_process, 1); @@ -460,15 +470,15 @@ void SIMIX_run(void) XBT_DEBUG("Handling process whose action failed"); while ((action = surf_model_extract_failed_action_set(model))) { XBT_DEBUG(" Handling Action %p",action); - SIMIX_simcall_exit((smx_synchro_t) surf_action_get_data(action)); + SIMIX_simcall_exit((smx_synchro_t) action->getData()); } XBT_DEBUG("Handling process whose action terminated normally"); while ((action = surf_model_extract_done_action_set(model))) { XBT_DEBUG(" Handling Action %p",action); - if (surf_action_get_data(action) == NULL) + if (action->getData() == NULL) XBT_DEBUG("probably vcpu's action %p, skip", action); else - SIMIX_simcall_exit((smx_synchro_t) surf_action_get_data(action)); + SIMIX_simcall_exit((smx_synchro_t) action->getData()); } } } @@ -498,15 +508,15 @@ void SIMIX_run(void) XBT_DEBUG("Handling process whose action failed"); while ((action = surf_model_extract_failed_action_set(model))) { XBT_DEBUG(" Handling Action %p",action); - SIMIX_simcall_exit((smx_synchro_t) surf_action_get_data(action)); + SIMIX_simcall_exit((smx_synchro_t) action->getData()); } XBT_DEBUG("Handling process whose action terminated normally"); while ((action = surf_model_extract_done_action_set(model))) { XBT_DEBUG(" Handling Action %p",action); - if (surf_action_get_data(action) == NULL) + if (action->getData() == NULL) XBT_DEBUG("probably vcpu's action %p, skip", action); else - SIMIX_simcall_exit((smx_synchro_t) surf_action_get_data(action)); + SIMIX_simcall_exit((smx_synchro_t) action->getData()); } } @@ -530,7 +540,7 @@ void SIMIX_run(void) if (xbt_swag_size(simix_global->process_list) != 0) { - TRACE_end(); + TRACE_end(); XBT_CRITICAL("Oops ! Deadlock or code not perfectly clean."); SIMIX_display_process_status(); @@ -559,12 +569,12 @@ smx_timer_t SIMIX_timer_set(double date, void (*function)(void*), void *arg) } /** @brief cancels a timer that was added earlier */ void SIMIX_timer_remove(smx_timer_t timer) { - xbt_heap_rm_elm(simix_timers, timer, timer->date); + xbt_heap_rm_elm(simix_timers, timer, timer->date); } /** @brief Returns the date at which the timer will trigger (or 0 if NULL timer) */ double SIMIX_timer_get_date(smx_timer_t timer) { - return timer?timer->date:0; + return timer?timer->date:0; } /** @@ -696,3 +706,8 @@ xbt_dict_t SIMIX_asr_get_properties(const char *name) { return (xbt_dict_t) xbt_lib_get_or_null(as_router_lib, name, ROUTING_PROP_ASR_LEVEL); } + +int SIMIX_is_maestro() +{ + return simix_global==NULL /*SimDag*/|| SIMIX_process_self() == simix_global->maestro_process; +}