X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3203ed1f4fb6f4617e94d5351661ba07e8b8f833..dc0b6bff49507332f7978675d174aa4fa9916fc2:/src/mc/Process.hpp diff --git a/src/mc/Process.hpp b/src/mc/Process.hpp index ff36fa1fdd..0b47eac56a 100644 --- a/src/mc/Process.hpp +++ b/src/mc/Process.hpp @@ -28,13 +28,16 @@ #include "src/simix/popping_private.h" #include "src/simix/smx_private.h" +#include "../xbt/memory_map.hpp" + #include "mc_forward.hpp" #include "mc_base.h" #include "mc_mmalloc.h" // std_heap -#include "mc_memory_map.h" #include "AddressSpace.hpp" #include "mc_protocol.h" +#include "ObjectInformation.hpp" + // Those flags are used to track down which cached information // is still up to date and which information needs to be updated. typedef int mc_process_cache_flags_t; @@ -51,6 +54,13 @@ struct IgnoredRegion { size_t size; }; +struct IgnoredHeapRegion { + int block; + int fragment; + void *address; + size_t size; +}; + /** Representation of a process */ class Process final : public AddressSpace { @@ -94,13 +104,13 @@ public: { if (!(this->cache_flags & MC_PROCESS_CACHE_FLAG_HEAP)) this->refresh_heap(); - return this->heap; + return this->heap.get(); } malloc_info* get_malloc_info() { if (!(this->cache_flags & MC_PROCESS_CACHE_FLAG_MALLOC_INFO)) this->refresh_malloc_info(); - return this->heap_info; + return this->heap_info.data(); } std::vector const& ignored_regions() const @@ -121,17 +131,11 @@ public: return running_; } - void terminate(int status) + void terminate() { - status_ = status; running_ = false; } - int status() const - { - return status_; - } - template typename std::enable_if< std::is_class::value && std::is_trivial::value, int >::type send_message(M const& m) @@ -154,6 +158,41 @@ public: void reset_soft_dirty(); void read_pagemap(uint64_t* pagemap, size_t start_page, size_t page_count); + bool privatized(ObjectInformation const& info) const + { + return privatized_ && info.executable(); + } + bool privatized() const + { + return privatized_; + } + void privatized(bool privatized) { privatized_ = privatized; } + + void ignore_global_variable(const char* name) + { + for (std::shared_ptr const& info : + this->object_infos) + info->remove_global_variable(name); + } + + std::vector& stack_areas() + { + return stack_areas_; + } + std::vector const& stack_areas() const + { + return stack_areas_; + } + + std::vector const& ignored_heap() const + { + return ignored_heap_; + } + void ignore_heap(IgnoredHeapRegion const& region); + void unignore_heap(void *address, size_t size); + + void ignore_local_variable(const char *var_name, const char *frame_name); + private: void init_memory_map_info(); void refresh_heap(); @@ -161,14 +200,17 @@ private: private: pid_t pid_; int socket_; - int status_; bool running_; - std::vector memory_map_; + std::vector memory_map_; remote_ptr maestro_stack_start_, maestro_stack_end_; int memory_file; std::vector ignored_regions_; int clear_refs_fd_; int pagemap_fd_; + bool privatized_; + std::vector stack_areas_; + std::vector ignored_heap_; + public: // object info // TODO, make private (first, objectify simgrid::mc::ObjectInformation*) std::vector> object_infos; @@ -200,7 +242,7 @@ public: // Copies of MCed SMX data structures * This is not used if the process is the current one: * use `get_heap_info()` in order to use it. */ - xbt_mheap_t heap; + std::unique_ptr heap; /** Copy of the allocation info structure * @@ -208,7 +250,7 @@ public: // Copies of MCed SMX data structures * This is not used if the process is the current one: * use `get_malloc_info()` in order to use it. */ - malloc_info* heap_info; + std::vector heap_info; public: // Libunwind-data @@ -240,10 +282,4 @@ XBT_PRIVATE int open_vm(pid_t pid, int flags); } } -SG_BEGIN_DECL() - -XBT_PRIVATE void MC_invalidate_cache(void); - -SG_END_DECL() - #endif