X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5d67901dba3dfd8e75f708c329b8144287490077..bbe4982c906909c5740a69715b80174c2b800078:/src/mc/mc_base.cpp diff --git a/src/mc/mc_base.cpp b/src/mc/mc_base.cpp index 56d1ebdf2e..7c350f7e7f 100644 --- a/src/mc/mc_base.cpp +++ b/src/mc/mc_base.cpp @@ -21,7 +21,11 @@ #include "src/mc/mc_protocol.h" #include "src/simix/Synchro.h" +#include "src/simix/SynchroIo.hpp" #include "src/simix/SynchroComm.hpp" +#include "src/simix/SynchroRaw.hpp" +#include "src/simix/SynchroSleep.hpp" +#include "src/simix/SynchroExec.hpp" #if HAVE_MC #include "src/mc/mc_request.h" @@ -73,9 +77,7 @@ void wait_for_requests(void) bool request_is_enabled(smx_simcall_t req) { unsigned int index = 0; -#if HAVE_MC - simgrid::simix::Synchro temp_synchro; -#endif + // TODO, add support for the subtypes? switch (req->call) { case SIMCALL_NONE: @@ -88,9 +90,11 @@ bool request_is_enabled(smx_simcall_t req) #if HAVE_MC // Fetch from MCed memory: + // HACK, type puning + simgrid::mc::Remote temp_comm; if (mc_model_checker != nullptr) { - mc_model_checker->process().read(&temp_synchro, remote(act)); - act = &temp_synchro; + mc_model_checker->process().read(temp_comm, remote(act)); + act = static_cast(temp_comm.getBuffer()); } #endif @@ -136,10 +140,12 @@ bool request_is_enabled(smx_simcall_t req) for (index = 0; index < comms->used; ++index) { #if HAVE_MC // Fetch act from MCed memory: + // HACK, type puning + simgrid::mc::Remote temp_comm; if (mc_model_checker != nullptr) { memcpy(&act, buffer + comms->elmsize * index, sizeof(act)); - mc_model_checker->process().read(&temp_synchro, remote(act)); - act = &temp_synchro; + mc_model_checker->process().read(temp_comm, remote(act)); + act = static_cast(temp_comm.getBuffer()); } else #endif @@ -156,10 +162,10 @@ bool request_is_enabled(smx_simcall_t req) case SIMCALL_MUTEX_LOCK: { smx_mutex_t mutex = simcall_mutex_lock__get__mutex(req); #if HAVE_MC - s_smx_mutex_t temp_mutex; + simgrid::mc::Remote temp_mutex; if (mc_model_checker != nullptr) { - mc_model_checker->process().read(&temp_mutex, remote(mutex)); - mutex = &temp_mutex; + mc_model_checker->process().read(temp_mutex.getBuffer(), remote(mutex)); + mutex = temp_mutex.getBuffer(); } #endif