X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3c5b31c9766da42c82473b8c9dbf5910b74f3cb0..7f0845ec805dc9b93cab3adb223eadd20aa1f169:/src/mc/mc_process.h diff --git a/src/mc/mc_process.h b/src/mc/mc_process.h index b8c551436d..84d90cd6fe 100644 --- a/src/mc/mc_process.h +++ b/src/mc/mc_process.h @@ -18,11 +18,13 @@ #include "xbt/mmalloc/mmprivate.h" #include "simix/popping_private.h" +#include "simix/smx_private.h" #include "mc_forward.h" #include "mc_mmalloc.h" // std_heap #include "mc_memory_map.h" #include "mc_address_space.h" +#include "mc_protocol.h" SG_BEGIN_DECL() @@ -38,8 +40,11 @@ typedef enum { typedef enum { MC_PROCESS_CACHE_FLAG_HEAP = 1, MC_PROCESS_CACHE_FLAG_MALLOC_INFO = 2, + MC_PROCESS_CACHE_FLAG_SIMIX_PROCESSES = 4, } e_mc_process_cache_flags_t ; +typedef struct s_mc_smx_process_info s_mc_smx_process_info_t, *mc_smx_process_info_t; + /** Representation of a process */ struct s_mc_process { @@ -57,13 +62,22 @@ struct s_mc_process { size_t object_infos_size; int memory_file; - // Cache: don't use those fields directly but with the getters - // which ensure that proper synchronisation has been done. + /** Copy of `simix_global->process_list` + * + * See mc_smx.c. + */ + xbt_dynar_t smx_process_infos; + + /** Copy of `simix_global->process_to_destroy` + * + * See mc_smx.c. + */ + xbt_dynar_t smx_old_process_infos; + /** State of the cache (which variables are up to date) */ e_mc_process_cache_flags_t cache_flags; - /** Address of the heap structure in the target process. - */ + /** Address of the heap structure in the MCed process. */ void* heap_address; /** Copy of the heap structure of the process @@ -102,6 +116,8 @@ struct s_mc_process { /** The corresponding context */ void* unw_underlying_context; + + xbt_dynar_t checkpoint_ignore; }; bool MC_is_process(mc_address_space_t p); @@ -143,6 +159,12 @@ const void* MC_process_read(mc_process_t process, void* local, const void* remote, size_t len, int process_index); +const void* MC_process_read_simple(mc_process_t process, + void* local, const void* remote, size_t len); + +const void* MC_process_read_dynar_element(mc_process_t process, + void* local, const void* remote_dynar, size_t i); + /** Write data to a process memory * * @param process the process @@ -162,6 +184,8 @@ mc_object_info_t MC_process_find_object_info_rw(mc_process_t process, const void dw_frame_t MC_process_find_function(mc_process_t process, const void* ip); +void MC_process_read_variable(mc_process_t process, const char* name, void* target, size_t size); + static inline xbt_mheap_t MC_process_get_heap(mc_process_t process) { if (MC_process_is_self(process))