X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5a298a64b7e15c10d01ae886c4d9a1940d2c5845..30d60b272963b1b130ea80840af783ee9c146b97:/src/mc/mc_protocol.h diff --git a/src/mc/mc_protocol.h b/src/mc/mc_protocol.h index be17129e95..bd6fd13538 100644 --- a/src/mc/mc_protocol.h +++ b/src/mc/mc_protocol.h @@ -4,10 +4,12 @@ /* 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. */ -#ifndef MC_PROTOCOL_H -#define MC_PROTOCOL_H +#ifndef SIMGRID_MC_PROTOCOL_H +#define SIMGRID_MC_PROTOCOL_H -#include +#include + +#include #include "mc/datatypes.h" @@ -23,13 +25,33 @@ SG_BEGIN_DECL() /** Environment variable name used to pass the communication socket */ #define MC_ENV_SOCKET_FD "SIMGRID_MC_SOCKET_FD" +// ***** MC mode + +typedef enum { + MC_MODE_NONE = 0, + MC_MODE_CLIENT, + MC_MODE_SERVER +} e_mc_mode_t; + +extern e_mc_mode_t mc_mode; + // ***** Messages typedef enum { - MC_MESSAGE_NONE = 0, - MC_MESSAGE_HELLO = 1, - MC_MESSAGE_CONTINUE = 2, - MC_MESSAGE_IGNORE_REGION = 3, + MC_MESSAGE_NONE, + MC_MESSAGE_CONTINUE, + MC_MESSAGE_IGNORE_HEAP, + MC_MESSAGE_UNIGNORE_HEAP, + MC_MESSAGE_IGNORE_MEMORY, + MC_MESSAGE_STACK_REGION, + MC_MESSAGE_REGISTER_SYMBOL, + MC_MESSAGE_DEADLOCK_CHECK, + MC_MESSAGE_DEADLOCK_CHECK_REPLY, + MC_MESSAGE_WAITING, + MC_MESSAGE_SIMCALL_HANDLE, + MC_MESSAGE_ASSERTION_FAILED, + // MCer request to finish the restoration: + MC_MESSAGE_RESTORE, } e_mc_message_type; #define MC_MESSAGE_LENGTH 512 @@ -50,14 +72,54 @@ typedef struct s_mc_message { e_mc_message_type type; } s_mc_message_t, *mc_message_t; -typedef struct s_mc_ignore_region_message { +typedef struct s_mc_int_message { + e_mc_message_type type; + uint64_t value; +} s_mc_int_message_t, *mc_int_message_t; + +typedef struct s_mc_ignore_heap_message { + e_mc_message_type type; + int block; + int fragment; + void *address; + size_t size; +} s_mc_ignore_heap_message_t, *mc_ignore_heap_message_t; + +typedef struct s_mc_ignore_memory_message { e_mc_message_type type; - s_mc_heap_ignore_region_t region; -} s_mc_ignore_region_message_t, *mc_ignore_region_message_t; + uint64_t addr; + size_t size; +} s_mc_ignore_memory_message_t, *mc_ignore_memory_message_t; + +typedef struct s_mc_stack_region_message { + e_mc_message_type type; + s_stack_region_t stack_region; +} s_mc_stack_region_message_t, *mc_stack_region_message_t; + +typedef struct s_mc_simcall_handle_message { + e_mc_message_type type; + unsigned long pid; + int value; +} s_mc_simcall_handle_message_t, *mc_simcall_handle_message; + +typedef struct s_mc_register_symbol_message { + e_mc_message_type type; + char name[128]; + int (*callback)(void*); + void* data; +} s_mc_register_symbol_message_t, * mc_register_symbol_message_t; + +typedef struct s_mc_restore_message { + e_mc_message_type type; + int index; +} s_mc_restore_message_t, *mc_restore_message_t; + +XBT_PRIVATE int MC_protocol_send(int socket, const void* message, size_t size); +XBT_PRIVATE int MC_protocol_send_simple_message(int socket, e_mc_message_type type); +XBT_PRIVATE ssize_t MC_receive_message(int socket, void* message, size_t size, int options); -int MC_protocol_send(int socket, void* message, size_t size); -int MC_protocol_send_simple_message(int socket, int type); -int MC_protocol_hello(int socket); +XBT_PRIVATE const char* MC_message_type_name(e_mc_message_type type); +XBT_PRIVATE const char* MC_mode_name(e_mc_mode_t mode); SG_END_DECL()