X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7757612e2826fd790cbcf39d5fd8e8904747104d..1eb2acd21f33865e5a3b27b5ec3e91a6ccc17ff1:/src/mc/mc_protocol.h diff --git a/src/mc/mc_protocol.h b/src/mc/mc_protocol.h index 9623ec0ec0..64b0e7021a 100644 --- a/src/mc/mc_protocol.h +++ b/src/mc/mc_protocol.h @@ -4,8 +4,8 @@ /* 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 @@ -27,7 +27,6 @@ SG_BEGIN_DECL() typedef enum { MC_MODE_NONE = 0, - MC_MODE_STANDALONE, MC_MODE_CLIENT, MC_MODE_SERVER } e_mc_mode_t; @@ -38,11 +37,19 @@ extern e_mc_mode_t mc_mode; typedef enum { MC_MESSAGE_NONE, - MC_MESSAGE_HELLO, 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 @@ -63,20 +70,54 @@ typedef struct s_mc_message { e_mc_message_type type; } s_mc_message_t, *mc_message_t; +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; - s_mc_heap_ignore_region_t region; + 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; - void *addr; + uint64_t addr; size_t size; } s_mc_ignore_memory_message_t, *mc_ignore_memory_message_t; -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); +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); + +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()