X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5ed37babb2fa9097abe82df299c0aa259ed84d5a..2fbcc71ab230e6a05e64189f6bd7c49c1df31907:/src/mc/remote/mc_protocol.h diff --git a/src/mc/remote/mc_protocol.h b/src/mc/remote/mc_protocol.h index 2f8e34b973..920f43f379 100644 --- a/src/mc/remote/mc_protocol.h +++ b/src/mc/remote/mc_protocol.h @@ -12,24 +12,26 @@ #include "src/kernel/actor/SimcallObserver.hpp" -#include "mc/datatypes.h" #include "simgrid/forward.h" // aid_t +#include "src/mc/datatypes.h" +#include "src/xbt/mmalloc/mmalloc.h" +#include + #include #include -#include -#include -#include // ***** Messages namespace simgrid::mc { -XBT_DECLARE_ENUM_CLASS(MessageType, NONE, INITIAL_ADDRESSES, CONTINUE, IGNORE_HEAP, UNIGNORE_HEAP, IGNORE_MEMORY, - STACK_REGION, REGISTER_SYMBOL, DEADLOCK_CHECK, DEADLOCK_CHECK_REPLY, WAITING, SIMCALL_EXECUTE, - SIMCALL_EXECUTE_ANSWER, ASSERTION_FAILED, ACTORS_STATUS, ACTORS_STATUS_REPLY, FINALIZE, - FINALIZE_REPLY); +XBT_DECLARE_ENUM_CLASS(MessageType, NONE, NEED_MEMINFO, NEED_MEMINFO_REPLY, FORK, FORK_REPLY, WAIT_CHILD, + WAIT_CHILD_REPLY, CONTINUE, IGNORE_HEAP, UNIGNORE_HEAP, IGNORE_MEMORY, STACK_REGION, + REGISTER_SYMBOL, DEADLOCK_CHECK, DEADLOCK_CHECK_REPLY, WAITING, SIMCALL_EXECUTE, + SIMCALL_EXECUTE_REPLY, ASSERTION_FAILED, ACTORS_STATUS, ACTORS_STATUS_REPLY_COUNT, + ACTORS_STATUS_REPLY_SIMCALL, ACTORS_STATUS_REPLY_TRANSITION, ACTORS_MAXPID, ACTORS_MAXPID_REPLY, + FINALIZE, FINALIZE_REPLY); } // namespace simgrid::mc -constexpr unsigned MC_MESSAGE_LENGTH = 512; +constexpr unsigned MC_MESSAGE_LENGTH = 512; constexpr unsigned SIMCALL_SERIALIZATION_BUFFER_SIZE = 2048; /** Basic structure for a MC message @@ -53,12 +55,6 @@ struct s_mc_message_int_t { }; /* Client->Server */ -struct s_mc_message_initial_addresses_t { - simgrid::mc::MessageType type; - xbt_mheap_t mmalloc_default_mdp; - unsigned long* maxpid; -}; - struct s_mc_message_ignore_heap_t { simgrid::mc::MessageType type; int block; @@ -86,6 +82,11 @@ struct s_mc_message_register_symbol_t { }; /* Server -> client */ +struct s_mc_message_need_meminfo_reply_t { + simgrid::mc::MessageType type; + xbt_mheap_t mmalloc_default_mdp; +}; + struct s_mc_message_simcall_execute_t { simgrid::mc::MessageType type; aid_t aid_; @@ -106,11 +107,19 @@ struct s_mc_message_actors_status_answer_t { int count; }; struct s_mc_message_actors_status_one_t { // an array of `s_mc_message_actors_status_one_t[count]` is sent right after - // after a s_mc_message_actors_status_answer_t + // after a `s_mc_message_actors_status_answer_t` + simgrid::mc::MessageType type; aid_t aid; bool enabled; int max_considered; }; +// Answer from an actor to the question "what are you about to run?" +struct s_mc_message_simcall_probe_one_t { // a series of `s_mc_message_simcall_probe_one_t` + // is sent right after `s_mc_message_actors_status_one_t[]` + simgrid::mc::MessageType type; + std::array buffer; +}; + #endif // __cplusplus #endif