X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fa22f462594acff6e8eaab9fb39453ae1927e51c..e989d2b49098728ebd426a9eea5cb35aabd470e2:/src/mc/remote/mc_protocol.h diff --git a/src/mc/remote/mc_protocol.h b/src/mc/remote/mc_protocol.h index f22cfd1876..dfe103b06f 100644 --- a/src/mc/remote/mc_protocol.h +++ b/src/mc/remote/mc_protocol.h @@ -19,22 +19,26 @@ #include #include +#include // ***** Messages namespace simgrid::mc { -XBT_DECLARE_ENUM_CLASS(MessageType, NONE, NEED_MEMINFO, NEED_MEMINFO_REPLY, 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, - ACTORS_MAXPID, ACTORS_MAXPID_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, UNIGNORE_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_SOCKET_NAME_LEN = sizeof(sockaddr_un::sun_path); constexpr unsigned SIMCALL_SERIALIZATION_BUFFER_SIZE = 2048; /** Basic structure for a MC message * - * The current version of the client/server protocol sends C structures over `AF_LOCAL` + * The current version of the client/server protocol sends C structures over `AF_UNIX` * `SOCK_SEQPACKET` sockets. This means that the protocol is ABI/architecture specific: * we currently can't model-check a x86 process from a x86_64 process. * @@ -85,6 +89,11 @@ struct s_mc_message_need_meminfo_reply_t { xbt_mheap_t mmalloc_default_mdp; }; +struct s_mc_message_fork_t { + simgrid::mc::MessageType type; + std::array socket_name; +}; + struct s_mc_message_simcall_execute_t { simgrid::mc::MessageType type; aid_t aid_; @@ -106,6 +115,7 @@ struct s_mc_message_actors_status_answer_t { }; 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` + simgrid::mc::MessageType type; aid_t aid; bool enabled; int max_considered; @@ -114,6 +124,7 @@ struct s_mc_message_actors_status_one_t { // an array of `s_mc_message_actors_st // 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; };