X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c7ef2b0424fb2c96b9d49f50dc225767e65a27de..7d1122d12caaa3cc08cea6b302f86edaaa8a8bd7:/src/mc/Session.cpp diff --git a/src/mc/Session.cpp b/src/mc/Session.cpp index 0bd6e82d9a..1bba77a4f4 100644 --- a/src/mc/Session.cpp +++ b/src/mc/Session.cpp @@ -9,6 +9,7 @@ #include "src/internal_config.h" // HAVE_SMPI #if HAVE_SMPI #include "smpi/smpi.h" +#include "src/smpi/include/private.hpp" #endif #include "src/mc/mc_private.hpp" #include "src/mc/mc_state.hpp" @@ -69,8 +70,7 @@ Session::Session(const std::function& code) // between the model-checker process (ourselves) and the model-checked // process: int sockets[2]; - int res = socketpair(AF_LOCAL, SOCK_SEQPACKET | SOCK_CLOEXEC, 0, sockets); - xbt_assert(res != -1, "Could not create socketpair"); + xbt_assert(socketpair(AF_LOCAL, SOCK_SEQPACKET | SOCK_CLOEXEC, 0, sockets) != -1, "Could not create socketpair"); pid_t pid = fork(); xbt_assert(pid >= 0, "Could not fork model-checked process"); @@ -98,8 +98,8 @@ Session::~Session() this->close(); } -/** Take the initial snapshot of the application, that must be stopped. */ -void Session::initialize() +/** The application must be stopped. */ +void Session::take_initial_snapshot() { xbt_assert(initial_snapshot_ == nullptr); model_checker_->wait_for_requests(); @@ -144,7 +144,8 @@ void Session::close() bool Session::actor_is_enabled(aid_t pid) const { - s_mc_message_actor_enabled_t msg{}; + s_mc_message_actor_enabled_t msg; + memset(&msg, 0, sizeof msg); msg.type = simgrid::mc::MessageType::ACTOR_ENABLED; msg.aid = pid; model_checker_->channel().send(msg); @@ -154,7 +155,6 @@ bool Session::actor_is_enabled(aid_t pid) const return ((s_mc_message_int_t*)buff.data())->value; } -simgrid::mc::Session* session; - +simgrid::mc::Session* session_singleton; } }