X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a15797ea55151ddfdbae48147e74159efe01b411..d6d15fab29caf0608cc43bffc3fa8f16baf6e638:/src/simix/popping.cpp diff --git a/src/simix/popping.cpp b/src/simix/popping.cpp index 8e938734d8..1314c04c7e 100644 --- a/src/simix/popping.cpp +++ b/src/simix/popping.cpp @@ -5,17 +5,16 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ #include "smx_private.h" -#include "xbt/fifo.h" #include "xbt/xbt_os_thread.h" #if HAVE_MC #include "src/mc/mc_private.h" #endif -#include "src/simix/SynchroExec.hpp" -#include "src/simix/SynchroComm.hpp" -#include "src/simix/SynchroSleep.hpp" -#include "src/simix/SynchroRaw.hpp" -#include "src/simix/SynchroIo.hpp" +#include "src/kernel/activity/SynchroExec.hpp" +#include "src/kernel/activity/SynchroComm.hpp" +#include "src/kernel/activity/SynchroSleep.hpp" +#include "src/kernel/activity/SynchroRaw.hpp" +#include "src/kernel/activity/SynchroIo.hpp" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_popping, simix, "Popping part of SIMIX (transmuting from user request into kernel handlers)"); @@ -30,12 +29,12 @@ void SIMIX_simcall_answer(smx_simcall_t simcall) * weird in process scheduling. */ /* if(!xbt_dynar_member(simix_global->process_to_run, &(simcall->issuer))) */ - xbt_dynar_push_as(simix_global->process_to_run, smx_process_t, simcall->issuer); + xbt_dynar_push_as(simix_global->process_to_run, smx_actor_t, simcall->issuer); /* else DIE_IMPOSSIBLE; */ } } -void SIMIX_simcall_exit(smx_synchro_t synchro) +void SIMIX_simcall_exit(smx_activity_t synchro) { synchro->post(); } @@ -44,3 +43,16 @@ void SIMIX_run_kernel(std::function const* code) { (*code)(); } + +/** Kernel code for run_blocking + * + * The implementtion looks a lot like SIMIX_run_kernel ^^ + * + * However, this `run_blocking` is blocking so the process will not be woken + * up until `SIMIX_simcall_answer(simcall)`` is called by the kernel. + * This means that `code` is responsible for doing this. + */ +void SIMIX_run_blocking(std::function const* code) +{ + (*code)(); +}