X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e0ba02850ce33d8eda9ba10a68db10af76f0ef29..0cc2ed4bab5f24d02f1bc2af0820c64ff0da24aa:/src/smpi/smpi_global.cpp diff --git a/src/smpi/smpi_global.cpp b/src/smpi/smpi_global.cpp index 5910e15e82..9b6cb53df9 100644 --- a/src/smpi/smpi_global.cpp +++ b/src/smpi/smpi_global.cpp @@ -463,7 +463,7 @@ static void smpi_init_options(){ smpi_privatize_global_variables = SMPI_PRIVATIZE_NONE; else - xbt_die("Invalid value for smpi/privatization: %s", smpi_privatize_option); + xbt_die("Invalid value for smpi/privatization: '%s'", smpi_privatize_option); if (smpi_cpu_threshold < 0) smpi_cpu_threshold = DBL_MAX; @@ -554,28 +554,26 @@ int smpi_main(const char* executable, int argc, char *argv[]) std::string executable_copy = executable; - // Prepare the copy of the binary (open the file and get its size) - // (fdin will remain open for the whole process execution. That's a sort of leak but we can live with it) - int fdin = open(executable_copy.c_str(), O_RDONLY); - xbt_assert(fdin >= 0, "Cannot read from %s", executable_copy.c_str()); + // Prepare the copy of the binary (get its size) struct stat fdin_stat; - fstat(fdin, &fdin_stat); + stat(executable_copy.c_str(), &fdin_stat); off_t fdin_size = fdin_stat.st_size; - simix_global->default_function = [executable_copy, fdin, fdin_size](std::vector args) { - return std::function([executable_copy, fdin, fdin_size, args] { + simix_global->default_function = [executable_copy, fdin_size](std::vector args) { + return std::function([executable_copy, fdin_size, args] { // Copy the dynamic library: std::string target_executable = executable_copy + "_" + std::to_string(getpid()) + "_" + std::to_string(rank++) + ".so"; + int fdin = open(executable_copy.c_str(), O_RDONLY); + xbt_assert(fdin >= 0, "Cannot read from %s", executable_copy.c_str()); int fdout = open(target_executable.c_str(), O_CREAT | O_RDWR, S_IRWXU); xbt_assert(fdout >= 0, "Cannot write into %s", target_executable.c_str()); #if HAVE_SENDFILE - off_t offset = 0; - sendfile(fdout, fdin, &offset, fdin_size); + sendfile(fdout, fdin, NULL, fdin_size); #else XBT_WARN("Copy %d bytes into %s", static_cast(fdin_size), target_executable.c_str()); const int bufsize = 1024 * 1024 * 4; @@ -597,13 +595,14 @@ int smpi_main(const char* executable, int argc, char *argv[]) } } #endif + close(fdin); close(fdout); // Load the copy and resolve the entry point: void* handle = dlopen(target_executable.c_str(), RTLD_LAZY | RTLD_LOCAL | RTLD_DEEPBIND); unlink(target_executable.c_str()); if (handle == nullptr) - xbt_die("dlopen failed"); + xbt_die("dlopen failed: %s (errno: %d -- %s)", dlerror(), errno, strerror(errno)); smpi_entry_point_type entry_point = smpi_resolve_function(handle); if (!entry_point) xbt_die("Could not resolve entry point");