X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f9436b840852218b39dce22d6057b6f223168daa..30f40863fc506c7013dec1902201d4bdffe3a101:/src/mc/mc_base.cpp diff --git a/src/mc/mc_base.cpp b/src/mc/mc_base.cpp index 396db1c616..6f13189458 100644 --- a/src/mc/mc_base.cpp +++ b/src/mc/mc_base.cpp @@ -30,7 +30,7 @@ int MC_random(int min, int max) namespace simgrid { namespace mc { -void wait_for_requests(void) +void wait_for_requests() { #if SIMGRID_HAVE_MC xbt_assert(mc_model_checker == nullptr); @@ -69,7 +69,6 @@ void wait_for_requests(void) // Called from both MCer and MCed: bool request_is_enabled(smx_simcall_t req) { - unsigned int index = 0; // TODO, add support for the subtypes? switch (req->call) { @@ -79,16 +78,16 @@ bool request_is_enabled(smx_simcall_t req) case SIMCALL_COMM_WAIT: { /* FIXME: check also that src and dst processes are not suspended */ - simgrid::kernel::activity::Comm *act = - static_cast(simcall_comm_wait__get__comm(req)); + simgrid::kernel::activity::CommImpl* act = + static_cast(simcall_comm_wait__getraw__comm(req)); #if SIMGRID_HAVE_MC // Fetch from MCed memory: // HACK, type puning if (mc_model_checker != nullptr) { - simgrid::mc::Remote temp_comm; + simgrid::mc::Remote temp_comm; mc_model_checker->process().read(temp_comm, remote(act)); - act = static_cast(temp_comm.getBuffer()); + act = static_cast(temp_comm.getBuffer()); } #endif @@ -107,8 +106,8 @@ bool request_is_enabled(smx_simcall_t req) case SIMCALL_COMM_WAITANY: { xbt_dynar_t comms; - simgrid::kernel::activity::Comm *act = - static_cast(simcall_comm_wait__get__comm(req)); + simgrid::kernel::activity::CommImpl* act = + static_cast(simcall_comm_wait__getraw__comm(req)); #if SIMGRID_HAVE_MC s_xbt_dynar_t comms_buffer; @@ -132,19 +131,19 @@ bool request_is_enabled(smx_simcall_t req) comms = simcall_comm_waitany__get__comms(req); #endif - for (index = 0; index < comms->used; ++index) { + for (unsigned int index = 0; index < comms->used; ++index) { #if SIMGRID_HAVE_MC // Fetch act from MCed memory: // HACK, type puning - simgrid::mc::Remote temp_comm; + simgrid::mc::Remote temp_comm; if (mc_model_checker != nullptr) { memcpy(&act, buffer + comms->elmsize * index, sizeof(act)); mc_model_checker->process().read(temp_comm, remote(act)); - act = static_cast(temp_comm.getBuffer()); + act = static_cast(temp_comm.getBuffer()); } else #endif - act = xbt_dynar_get_as(comms, index, simgrid::kernel::activity::Comm*); + act = xbt_dynar_get_as(comms, index, simgrid::kernel::activity::CommImpl*); if (act->src_proc && act->dst_proc) return true; } @@ -154,7 +153,7 @@ bool request_is_enabled(smx_simcall_t req) case SIMCALL_MUTEX_LOCK: { smx_mutex_t mutex = simcall_mutex_lock__get__mutex(req); #if SIMGRID_HAVE_MC - simgrid::mc::Remote temp_mutex; + simgrid::mc::Remote temp_mutex; if (mc_model_checker != nullptr) { mc_model_checker->process().read(temp_mutex.getBuffer(), remote(mutex)); mutex = temp_mutex.getBuffer();