X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/eb417d0c8064e83fc1211abc819ae93687505003..347f9a2ca55bffc88bf965952b9be3a15535e908:/src/mc/mc_smx.cpp diff --git a/src/mc/mc_smx.cpp b/src/mc/mc_smx.cpp index 8372875bd8..325ea151e8 100644 --- a/src/mc/mc_smx.cpp +++ b/src/mc/mc_smx.cpp @@ -7,10 +7,11 @@ #include #include +#include -#include "simix/smx_private.h" +#include "src/simix/smx_private.h" -#include "mc_smx.h" +#include "src/mc/mc_smx.h" #include "ModelChecker.hpp" using simgrid::mc::remote; @@ -57,7 +58,7 @@ mc_smx_process_info_t MC_smx_process_get_info(smx_process_t p) * @param remote_swag Address of the process SWAG in the remote list */ static void MC_process_refresh_simix_process_list( - mc_process_t process, + simgrid::mc::Process* process, xbt_dynar_t target, xbt_swag_t remote_swag) { // swag = REMOTE(*simix_global->process_list) @@ -84,10 +85,9 @@ static void MC_process_refresh_simix_process_list( assert(i == swag.count); } -void MC_process_smx_refresh(mc_process_t process) +void MC_process_smx_refresh(simgrid::mc::Process* process) { xbt_assert(mc_mode == MC_MODE_SERVER); - xbt_assert(!process->is_self()); if (process->cache_flags & MC_PROCESS_CACHE_FLAG_SIMIX_PROCESSES) return; @@ -176,30 +176,43 @@ mc_smx_process_info_t MC_smx_resolve_process_info(smx_process_t process_remote_a const char* MC_smx_process_get_host_name(smx_process_t p) { if (mc_mode == MC_MODE_CLIENT) - return SIMIX_host_get_name(p->smx_host); + return SIMIX_host_get_name(p->host); - mc_process_t process = &mc_model_checker->process(); + simgrid::mc::Process* process = &mc_model_checker->process(); - // Currently, smx_host_t = xbt_dictelm_t. - // TODO, add an static_assert on this if switching to C++ - // The host name is host->key and the host->key_len==strlen(host->key). - s_xbt_dictelm_t host_copy; + /* Horrible hack to find the offset of the id in the simgrid::Host. + + Offsetof is not supported for non-POD types but this should + work in pratice for the targets currently supported by the MC + as long as we do not add funny features to the Host class + (such as virtual base). + + We are using a (C++11) unrestricted union in order to avoid + any construction/destruction of the simgrid::Host. + */ + union fake_host { + simgrid::Host host; + fake_host() {} + ~fake_host() {} + }; + fake_host foo; + const size_t offset = (char*) &foo.host.getName() - (char*) &foo.host; + + // Read the simgrid::xbt::string in the MCed process: mc_smx_process_info_t info = MC_smx_process_get_info(p); - if (!info->hostname) { - - // Read the hostname from the MCed process: - process->read_bytes(&host_copy, sizeof(host_copy), remote(p->smx_host)); - int len = host_copy.key_len + 1; - char hostname[len]; - process->read_bytes(hostname, len, remote(host_copy.key)); - info->hostname = mc_model_checker->get_host_name(hostname); - } + simgrid::xbt::string_data remote_string; + auto remote_string_address = remote( + (simgrid::xbt::string_data*) ((char*) p->host + offset)); + process->read_bytes(&remote_string, sizeof(remote_string), remote_string_address); + char hostname[remote_string.len]; + process->read_bytes(hostname, remote_string.len + 1, remote(remote_string.data)); + info->hostname = mc_model_checker->get_host_name(hostname); return info->hostname; } const char* MC_smx_process_get_name(smx_process_t p) { - mc_process_t process = &mc_model_checker->process(); + simgrid::mc::Process* process = &mc_model_checker->process(); if (mc_mode == MC_MODE_CLIENT) return p->name; if (!p->name) @@ -212,6 +225,7 @@ const char* MC_smx_process_get_name(smx_process_t p) return info->name; } +#ifdef HAVE_SMPI int MC_smpi_process_count(void) { if (mc_mode == MC_MODE_CLIENT) @@ -223,6 +237,7 @@ int MC_smpi_process_count(void) return res; } } +#endif unsigned long MC_smx_get_maxpid(void) {