X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7ecb4ca0914cfbd58786dac35ec97fc7c5518332..ce87516da629c9b6a350d8c28f806926863aa94a:/src/mc/mc_smx.cpp?ds=sidebyside diff --git a/src/mc/mc_smx.cpp b/src/mc/mc_smx.cpp index 2830defe05..d9ba8b9d9e 100644 --- a/src/mc/mc_smx.cpp +++ b/src/mc/mc_smx.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2015-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2015-2020. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -31,7 +31,7 @@ static inline simgrid::mc::ActorInformation* actor_info_cast(smx_actor_t actor) * @param target Local vector (to be filled with copies of `s_smx_actor_t`) * @param remote_dynar Address of the process dynar in the remote list */ -static void MC_process_refresh_simix_actor_dynar(simgrid::mc::RemoteClient* process, +static void MC_process_refresh_simix_actor_dynar(const simgrid::mc::RemoteSimulation* process, std::vector& target, simgrid::mc::RemotePtr remote_dynar) { @@ -45,8 +45,8 @@ static void MC_process_refresh_simix_actor_dynar(simgrid::mc::RemoteClient* proc // Load each element of the vector from the MCed process: for (unsigned int i = 0; i < dynar.used; ++i) { - simgrid::mc::ActorInformation info; + info.address = simgrid::mc::RemotePtr(data[i]); info.hostname = nullptr; process->read_bytes(&info.copy, sizeof(info.copy), remote(data[i])); @@ -57,9 +57,9 @@ static void MC_process_refresh_simix_actor_dynar(simgrid::mc::RemoteClient* proc namespace simgrid { namespace mc { -void RemoteClient::refresh_simix() +void RemoteSimulation::refresh_simix() { - if (this->cache_flags_ & RemoteClient::cache_simix_processes) + if (this->cache_flags_ & RemoteSimulation::cache_simix_processes) return; // TODO, avoid to reload `&simix_global`, `simix_global`, `*simix_global` @@ -81,7 +81,7 @@ void RemoteClient::refresh_simix() MC_process_refresh_simix_actor_dynar(this, this->smx_dead_actors_infos, remote(simix_global.get_buffer()->dead_actors_vector)); - this->cache_flags_ |= RemoteClient::cache_simix_processes; + this->cache_flags_ |= RemoteSimulation::cache_simix_processes; } } @@ -101,13 +101,13 @@ smx_actor_t MC_smx_simcall_get_issuer(s_smx_simcall const* req) xbt_assert(mc_model_checker != nullptr); // This is the address of the smx_actor in the MCed process: - auto address = simgrid::mc::remote(req->issuer); + auto address = simgrid::mc::remote(req->issuer_); // Lookup by address: - for (auto& actor : mc_model_checker->process().actors()) + for (auto& actor : mc_model_checker->get_remote_simulation().actors()) if (actor.address == address) return actor.copy.get_buffer(); - for (auto& actor : mc_model_checker->process().dead_actors()) + for (auto& actor : mc_model_checker->get_remote_simulation().dead_actors()) if (actor.address == address) return actor.copy.get_buffer(); @@ -119,11 +119,12 @@ const char* MC_smx_actor_get_host_name(smx_actor_t actor) if (mc_model_checker == nullptr) return actor->get_host()->get_cname(); - simgrid::mc::RemoteClient* process = &mc_model_checker->process(); + const simgrid::mc::RemoteSimulation* process = &mc_model_checker->get_remote_simulation(); // Read the simgrid::xbt::string in the MCed process: simgrid::mc::ActorInformation* info = actor_info_cast(actor); - auto remote_string_address = remote((simgrid::xbt::string_data*)&actor->get_host()->get_name()); + auto remote_string_address = + remote(reinterpret_cast(&actor->get_host()->get_name())); simgrid::xbt::string_data remote_string = process->read(remote_string_address); char hostname[remote_string.len]; process->read_bytes(hostname, remote_string.len + 1, remote(remote_string.data)); @@ -133,7 +134,7 @@ const char* MC_smx_actor_get_host_name(smx_actor_t actor) const char* MC_smx_actor_get_name(smx_actor_t actor) { - simgrid::mc::RemoteClient* process = &mc_model_checker->process(); + const simgrid::mc::RemoteSimulation* process = &mc_model_checker->get_remote_simulation(); if (mc_model_checker == nullptr) return actor->get_cname(); @@ -148,7 +149,9 @@ const char* MC_smx_actor_get_name(smx_actor_t actor) unsigned long MC_smx_get_maxpid() { unsigned long maxpid; - mc_model_checker->process().read_variable("simix_process_maxpid", - &maxpid, sizeof(maxpid)); + const char* name = "simgrid::kernel::actor::maxpid"; + if (mc_model_checker->get_remote_simulation().find_variable(name) == nullptr) + name = "maxpid"; // We seem to miss the namespaces when compiling with GCC + mc_model_checker->get_remote_simulation().read_variable(name, &maxpid, sizeof(maxpid)); return maxpid; }