Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
leaks -- with smp algos
[simgrid.git] / src / smpi / smpi_memory.cpp
1 /* Copyright (c) 2015. The SimGrid Team.
2  * All rights reserved.                                                     */
3
4 /* This program is free software; you can redistribute it and/or modify it
5  * under the terms of the license (GNU LGPL) which comes with this package. */
6
7 #include <iostream>
8
9 #include <limits.h>
10 #include <stdlib.h>
11 #include <sys/types.h>
12 #ifndef WIN32
13 #include <sys/mman.h>
14 #include <unistd.h>
15
16 #include "../xbt/memory_map.hpp"
17
18 #include "private.h"
19
20 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_memory, smpi, "Memory layout support for SMPI");
21
22 #define TOPAGE(addr) (void *)(((unsigned long)(addr) / xbt_pagesize) * xbt_pagesize)
23
24 #define PROT_RWX (PROT_READ | PROT_WRITE | PROT_EXEC)
25 #define PROT_RW (PROT_READ | PROT_WRITE )
26 #define PROT_RX (PROT_READ | PROT_EXEC )
27
28 void smpi_get_executable_global_size(void)
29 {
30   char buffer[PATH_MAX];
31   char* full_name = realpath(xbt_binary_name, buffer);
32   if (full_name == nullptr)
33     xbt_die("Could not resolve binary file name");
34
35   std::vector<simgrid::xbt::VmMap> map = simgrid::xbt::get_memory_map(getpid());
36   for (auto i = map.begin(); i != map.end() ; ++i) {
37     // TODO, In practice, this implementation would not detect a completely
38     // anonymous data segment. This does not happen in practice, however.
39
40     // File backed RW entry:
41     if (i->pathname == full_name && (i->prot & PROT_RWX) == PROT_RW) {
42       smpi_start_data_exe = (char*) i->start_addr;
43       smpi_size_data_exe = i->end_addr - i->start_addr;
44       ++i;
45       /* Here we are making the assumption that a suitable empty region
46          following the rw- area is the end of the data segment. It would
47          be better to check with the size of the data segment. */
48       if (i != map.end() && i->pathname.empty() && (i->prot & PROT_RWX) == PROT_RW
49           && i->start_addr == (std::uint64_t) smpi_start_data_exe + smpi_size_data_exe) {
50         smpi_size_data_exe = i->end_addr - (std::uint64_t) smpi_start_data_exe;
51       }
52       return;
53     }
54   }
55   xbt_die("Did not find my data segment.");
56 }
57 #endif