X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5e7ea743f4e41c8fb6e0c1cce87df1ff8804a82a..9575359fcebd3a393b65891c293990d1a882eb34:/src/mc/mc_snapshot.cpp diff --git a/src/mc/mc_snapshot.cpp b/src/mc/mc_snapshot.cpp index eb9e92dd77..0dff797c92 100644 --- a/src/mc/mc_snapshot.cpp +++ b/src/mc/mc_snapshot.cpp @@ -39,7 +39,7 @@ mc_mem_region_t mc_get_snapshot_region( continue; if (region->storage_type() == simgrid::mc::StorageType::Privatized) { -#ifdef HAVE_SMPI +#if HAVE_SMPI // Use the current process index of the snapshot: if (process_index == simgrid::mc::ProcessIndexDisabled) process_index = snapshot->privatization_index; @@ -74,8 +74,11 @@ const void* MC_region_read_fragmented(mc_mem_region_t region, void* target, cons // Last byte of the memory area: void* end = (char*) addr + size - 1; + // TODO, we assume the chunks are aligned to natural chunk boundaries. + // We should remove this assumption. + // Page of the last byte of the memory area: - size_t page_end = mc_page_number(nullptr, end); + size_t page_end = simgrid::mc::mmu::split((std::uintptr_t) end).first; void* dest = target; @@ -83,9 +86,11 @@ const void* MC_region_read_fragmented(mc_mem_region_t region, void* target, cons xbt_die("Missing destination buffer for fragmented memory access"); // Read each page: - while (mc_page_number(nullptr, addr) != page_end) { + while (simgrid::mc::mmu::split((std::uintptr_t) addr).first != page_end) { void* snapshot_addr = mc_translate_address_region_chunked((uintptr_t) addr, region); - void* next_page = mc_page_from_number(nullptr, mc_page_number(NULL, addr) + 1); + void* next_page = (void*) simgrid::mc::mmu::join( + simgrid::mc::mmu::split((std::uintptr_t) addr).first + 1, + 0); size_t readable = (char*) next_page - (char*) addr; memcpy(dest, snapshot_addr, readable); addr = (char*) addr + readable; @@ -143,8 +148,8 @@ int MC_snapshot_region_memcmp( * @return same as memcmp * */ int MC_snapshot_memcmp( - const void* addr1, mc_snapshot_t snapshot1, - const void* addr2, mc_snapshot_t snapshot2, int process_index, size_t size) + const void* addr1, simgrid::mc::Snapshot* snapshot1, + const void* addr2, simgrid::mc::Snapshot* snapshot2, int process_index, size_t size) { mc_mem_region_t region1 = mc_get_snapshot_region(addr1, snapshot1, process_index); mc_mem_region_t region2 = mc_get_snapshot_region(addr2, snapshot2, process_index); @@ -154,18 +159,13 @@ int MC_snapshot_memcmp( namespace simgrid { namespace mc { -Snapshot::Snapshot(Process* process) : - AddressSpace(process), - num_state(0), - heap_bytes_used(0), - enabled_processes(), - privatization_index(0), - hash(0) -{ - -} - -Snapshot::~Snapshot() +Snapshot::Snapshot(Process* process, int _num_state) + : AddressSpace(process) + , num_state(_num_state) + , heap_bytes_used(0) + , enabled_processes() + , privatization_index(0) + , hash(0) { } @@ -229,7 +229,7 @@ XBT_TEST_UNIT("page_snapshots", test_per_snpashots, "Test per-page snapshots") static void test_snapshot(bool sparse_checkpoint) { - xbt_test_add("Initialisation"); + xbt_test_add("Initialization"); _sg_mc_sparse_checkpoint = sparse_checkpoint; xbt_assert(xbt_pagesize == getpagesize()); xbt_assert(1 << xbt_pagebits == xbt_pagesize); @@ -248,12 +248,12 @@ static void test_snapshot(bool sparse_checkpoint) { // Init memory and take snapshots: init_memory(source, byte_size); simgrid::mc::RegionSnapshot region0 = simgrid::mc::sparse_region( - simgrid::mc::RegionType::Unknown, source, source, byte_size, nullptr); + simgrid::mc::RegionType::Unknown, source, source, byte_size); for(int i=0; i