X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4ea83ea565b18593a9e6864b7e43d02fc8500f23..573a49afcc1a146f9776a7a772d87efd9db77657:/src/mc/mc_snapshot.cpp diff --git a/src/mc/mc_snapshot.cpp b/src/mc/mc_snapshot.cpp index f0f36b10e5..54f07bab33 100644 --- a/src/mc/mc_snapshot.cpp +++ b/src/mc/mc_snapshot.cpp @@ -29,10 +29,10 @@ mc_mem_region_t mc_get_snapshot_region( size_t n = snapshot->snapshot_regions_count; for (size_t i = 0; i != n; ++i) { mc_mem_region_t region = snapshot->snapshot_regions[i]; - if (!(region && mc_region_contain(region, addr))) + if (!(region && region->contain(simgrid::mc::remote(addr)))) continue; - if (region->storage_type == MC_REGION_STORAGE_TYPE_PRIVATIZED) { + if (region->storage_type() == simgrid::mc::StorageType::Privatized) { #ifdef HAVE_SMPI // Use the current process index of the snapshot: if (process_index == simgrid::mc::ProcessIndexDisabled) { @@ -44,9 +44,9 @@ mc_mem_region_t mc_get_snapshot_region( if (process_index >= (int) region->privatized_data().size()) { xbt_die("Invalid process index"); } - mc_mem_region_t priv_region = region->privatized_data()[process_index].get(); - xbt_assert(mc_region_contain(priv_region, addr)); - return priv_region; + simgrid::mc::RegionSnapshot& priv_region = region->privatized_data()[process_index]; + xbt_assert(priv_region.contain(simgrid::mc::remote(addr))); + return &priv_region; #else xbt_die("Privatized region in a non SMPI build (this should not happen)"); #endif @@ -114,8 +114,8 @@ int MC_snapshot_region_memcmp( // Using alloca() for large allocations may trigger stack overflow: // use malloc if the buffer is too big. bool stack_alloc = size < 64; - const bool region1_need_buffer = region1==NULL || region1->storage_type==MC_REGION_STORAGE_TYPE_FLAT; - const bool region2_need_buffer = region2==NULL || region2->storage_type==MC_REGION_STORAGE_TYPE_FLAT; + const bool region1_need_buffer = region1==NULL || region1->storage_type()==simgrid::mc::StorageType::Flat; + const bool region2_need_buffer = region2==NULL || region2->storage_type()==simgrid::mc::StorageType::Flat; void* buffer1a = region1_need_buffer ? NULL : stack_alloc ? alloca(size) : malloc(size); void* buffer2a = region2_need_buffer ? NULL : stack_alloc ? alloca(size) : malloc(size); const void* buffer1 = MC_region_read(region1, buffer1a, addr1, size); @@ -159,28 +159,22 @@ Snapshot::Snapshot() : heap_bytes_used(0), snapshot_regions(nullptr), snapshot_regions_count(0), - enabled_processes(0), + enabled_processes(), privatization_index(0), - stack_sizes(nullptr), + stack_sizes(), stacks(nullptr), - to_ignore(nullptr), - hash(0), - ignored_data(nullptr), - total_fd(0), - current_fd(nullptr) + hash(0) { } + Snapshot::~Snapshot() { for (size_t i = 0; i < this->snapshot_regions_count; i++) { delete this->snapshot_regions[i]; } xbt_free(this->snapshot_regions); - xbt_free(this->stack_sizes); xbt_dynar_free(&(this->stacks)); - xbt_dynar_free(&(this->to_ignore)); - xbt_dynar_free(&this->ignored_data); } const void* Snapshot::read_bytes(void* buffer, std::size_t size, @@ -256,55 +250,52 @@ static void test_snapshot(bool sparse_checkpoint) { // Init memory and take snapshots: init_memory(source, byte_size); - mc_mem_region_t region0 = mc_region_new_sparse( - MC_REGION_TYPE_UNKNOWN, source, source, byte_size); + simgrid::mc::RegionSnapshot region0 = simgrid::mc::sparse_region( + simgrid::mc::RegionType::Unknown, source, source, byte_size); for(int i=0; i