X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f9436b840852218b39dce22d6057b6f223168daa..7ac4abc35931448d0bbc5f3c1260320dfe4110c9:/src/simix/smx_global.cpp diff --git a/src/simix/smx_global.cpp b/src/simix/smx_global.cpp index 25c861ecd0..6f02d1306b 100644 --- a/src/simix/smx_global.cpp +++ b/src/simix/smx_global.cpp @@ -16,19 +16,20 @@ #include "simgrid/s4u/Host.hpp" #include "src/surf/surf_interface.hpp" -#include "src/surf/storage_interface.hpp" #include "src/surf/xml/platf.hpp" #include "smx_private.h" #include "xbt/ex.h" /* ex_backtrace_display */ + #include "mc/mc.h" -#include "src/mc/mc_replay.h" #include "simgrid/sg_config.h" +#include "src/mc/mc_replay.h" +#include "src/surf/StorageImpl.hpp" #include "src/smpi/smpi_process.hpp" -#include "src/kernel/activity/SynchroExec.hpp" -#include "src/kernel/activity/SynchroComm.hpp" -#include "src/kernel/activity/SynchroSleep.hpp" +#include "src/kernel/activity/CommImpl.hpp" +#include "src/kernel/activity/ExecImpl.hpp" +#include "src/kernel/activity/SleepImpl.hpp" #include "src/kernel/activity/SynchroIo.hpp" #include "src/kernel/activity/SynchroRaw.hpp" @@ -125,7 +126,7 @@ static void install_segvhandler() XBT_WARN("Failed to register alternate signal stack: %s", strerror(errno)); return; } - if (!(old_stack.ss_flags & SS_DISABLE)) { + if (not(old_stack.ss_flags & SS_DISABLE)) { XBT_DEBUG("An alternate stack was already installed (sp=%p, size=%zd, flags=%x). Restore it.", old_stack.ss_sp, old_stack.ss_size, old_stack.ss_flags); sigaltstack(&old_stack, nullptr); @@ -233,13 +234,12 @@ void SIMIX_global_init(int *argc, char **argv) host.extension_set(new simgrid::simix::Host()); }); - simgrid::surf::storageCreatedCallbacks.connect([](simgrid::surf::Storage* storage) { - const char* name = storage->cname(); - // TODO, create sg_storage_by_name - sg_storage_t s = xbt_lib_get_elm_or_null(storage_lib, name); - xbt_assert(s != nullptr, "Storage not found for name %s", name); + simgrid::surf::storageCreatedCallbacks.connect([](simgrid::surf::StorageImpl* storage) { + sg_storage_t s = simgrid::s4u::Storage::byName(storage->cname()); + xbt_assert(s != nullptr, "Storage not found for name %s", storage->cname()); }); } + if (not simix_timers) simix_timers = xbt_heap_new(8, [](void* p) { delete static_cast(p); @@ -653,13 +653,13 @@ void SIMIX_display_process_status() const char* synchro_description = "unknown"; - if (dynamic_cast(process->waiting_synchro) != nullptr) + if (dynamic_cast(process->waiting_synchro) != nullptr) synchro_description = "execution"; - if (dynamic_cast(process->waiting_synchro) != nullptr) + if (dynamic_cast(process->waiting_synchro) != nullptr) synchro_description = "communication"; - if (dynamic_cast(process->waiting_synchro) != nullptr) + if (dynamic_cast(process->waiting_synchro) != nullptr) synchro_description = "sleeping"; if (dynamic_cast(process->waiting_synchro) != nullptr)