X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/895710d49f77179d9893bc76b3e31b69fae638af..162b7f2ae7f56c611a7d8f951477b3a23a53a2b4:/src/smpi/internals/smpi_global.cpp diff --git a/src/smpi/internals/smpi_global.cpp b/src/smpi/internals/smpi_global.cpp index 9d74f2d891..7544bbd081 100644 --- a/src/smpi/internals/smpi_global.cpp +++ b/src/smpi/internals/smpi_global.cpp @@ -15,10 +15,23 @@ #include /* DBL_MAX */ #include #include +#include + #if not defined(__APPLE__) #include #endif -#include + +#if defined(__APPLE__) +# include +# ifndef MAC_OS_X_VERSION_10_12 +# define MAC_OS_X_VERSION_10_12 101200 +# endif +# define HAVE_WORKING_MMAP (MAC_OS_X_VERSION_MIN_REQUIRED >= MAC_OS_X_VERSION_10_12) +#elif defined(__FreeBSD__) +# define HAVE_WORKING_MMAP 0 +#else +# define HAVE_WORKING_MMAP 1 +#endif #if HAVE_SENDFILE #include @@ -376,7 +389,7 @@ static void smpi_init_options(){ XBT_DEBUG("Running without smpi_main(); disable smpi/privatization."); smpi_privatize_global_variables = SmpiPrivStrategies::NONE; } -#if defined(__FreeBSD__) +#if HAVE_WORKING_MMAP if (smpi_privatize_global_variables == SmpiPrivStrategies::MMAP) { XBT_INFO("mmap privatization is broken on FreeBSD, switching to dlopen privatization instead."); smpi_privatize_global_variables = SmpiPrivStrategies::DLOPEN; @@ -492,7 +505,120 @@ static int visit_libs(struct dl_phdr_info* info, size_t, void* data) } #endif -int smpi_main(const char* executable, int argc, char *argv[]) +static void smpi_init_privatization_dlopen(std::string executable) +{ + // Prepare the copy of the binary (get its size) + struct stat fdin_stat; + stat(executable.c_str(), &fdin_stat); + off_t fdin_size = fdin_stat.st_size; + static std::size_t rank = 0; + + std::string libnames = simgrid::config::get_value("smpi/privatize-libs"); + if (not libnames.empty()) { + // split option + std::vector privatize_libs; + boost::split(privatize_libs, libnames, boost::is_any_of(";")); + + for (auto const& libname : privatize_libs) { + // load the library once to add it to the local libs, to get the absolute path + void* libhandle = dlopen(libname.c_str(), RTLD_LAZY); + // get library name from path + char fullpath[512] = {'\0'}; + strcpy(fullpath, libname.c_str()); +#if not defined(__APPLE__) + int ret = dl_iterate_phdr(visit_libs, fullpath); + if (ret == 0) + xbt_die("Can't find a linked %s - check the setting you gave to smpi/privatize-libs", fullpath); + else + XBT_DEBUG("Extra lib to privatize found : %s", fullpath); +#else + xbt_die("smpi/privatize-libs is not (yet) compatible with OSX"); +#endif + privatize_libs_paths.push_back(fullpath); + dlclose(libhandle); + } + } + + simix_global->default_function = [executable, fdin_size](std::vector args) { + return std::function([executable, fdin_size, args] { + + // Copy the dynamic library: + std::string target_executable = + executable + "_" + std::to_string(getpid()) + "_" + std::to_string(rank) + ".so"; + + smpi_copy_file(executable, target_executable, fdin_size); + // if smpi/privatize-libs is set, duplicate pointed lib and link each executable copy to a different one. + std::string target_lib; + for (auto const& libpath : privatize_libs_paths) { + // if we were given a full path, strip it + size_t index = libpath.find_last_of("/\\"); + std::string libname; + if (index != std::string::npos) + libname = libpath.substr(index + 1); + + if (not libname.empty()) { + // load the library to add it to the local libs, to get the absolute path + struct stat fdin_stat2; + stat(libpath.c_str(), &fdin_stat2); + off_t fdin_size2 = fdin_stat2.st_size; + + // Copy the dynamic library, the new name must be the same length as the old one + // just replace the name with 7 digits for the rank and the rest of the name. + unsigned int pad = 7; + if (libname.length() < pad) + pad = libname.length(); + target_lib = + std::string(pad - std::to_string(rank).length(), '0') + std::to_string(rank) + libname.substr(pad); + XBT_DEBUG("copy lib %s to %s, with size %lld", libpath.c_str(), target_lib.c_str(), (long long)fdin_size2); + smpi_copy_file(libpath, target_lib, fdin_size2); + + std::string sedcommand = "sed -i -e 's/" + libname + "/" + target_lib + "/g' " + target_executable; + int ret = system(sedcommand.c_str()); + if (ret != 0) + xbt_die("error while applying sed command %s \n", sedcommand.c_str()); + } + } + + rank++; + // Load the copy and resolve the entry point: + void* handle = dlopen(target_executable.c_str(), RTLD_LAZY | RTLD_LOCAL | RTLD_DEEPBIND); + int saved_errno = errno; + if (simgrid::config::get_value("smpi/keep-temps") == false) { + unlink(target_executable.c_str()); + if (not target_lib.empty()) + unlink(target_lib.c_str()); + } + if (handle == nullptr) + xbt_die("dlopen failed: %s (errno: %d -- %s)", dlerror(), saved_errno, strerror(saved_errno)); + smpi_entry_point_type entry_point = smpi_resolve_function(handle); + if (not entry_point) + xbt_die("Could not resolve entry point"); + smpi_run_entry_point(entry_point, args); + }); + }; +} + +static void smpi_init_privatization_no_dlopen(std::string executable) +{ + if (smpi_privatize_global_variables == SmpiPrivStrategies::MMAP) + smpi_prepare_global_memory_segment(); + // Load the dynamic library and resolve the entry point: + void* handle = dlopen(executable.c_str(), RTLD_LAZY | RTLD_LOCAL); + if (handle == nullptr) + xbt_die("dlopen failed for %s: %s (errno: %d -- %s)", executable.c_str(), dlerror(), errno, strerror(errno)); + smpi_entry_point_type entry_point = smpi_resolve_function(handle); + if (not entry_point) + xbt_die("main not found in %s", executable.c_str()); + if (smpi_privatize_global_variables == SmpiPrivStrategies::MMAP) + smpi_backup_global_memory_segment(); + + // Execute the same entry point for each simulated process: + simix_global->default_function = [entry_point](std::vector args) { + return std::function([entry_point, args] { smpi_run_entry_point(entry_point, args); }); + }; +} + +int smpi_main(const char* executable, int argc, char* argv[]) { srand(SMPI_RAND_SEED); @@ -505,7 +631,7 @@ int smpi_main(const char* executable, int argc, char *argv[]) TRACE_global_init(); SIMIX_global_init(&argc, argv); - MSG_init(&argc,argv); + MSG_init(&argc, argv); // FIXME Remove this MSG call. Once it's removed, we can remove the msg header include as well SMPI_switch_data_segment = &smpi_switch_data_segment; @@ -520,121 +646,10 @@ int smpi_main(const char* executable, int argc, char *argv[]) SIMIX_comm_set_copy_data_callback(smpi_comm_copy_buffer_callback); smpi_init_options(); - if (smpi_privatize_global_variables == SmpiPrivStrategies::DLOPEN) { - - std::string executable_copy = executable; - - // Prepare the copy of the binary (get its size) - struct stat fdin_stat; - stat(executable_copy.c_str(), &fdin_stat); - off_t fdin_size = fdin_stat.st_size; - static std::size_t rank = 0; - - - std::string libnames = simgrid::config::get_value("smpi/privatize-libs"); - if(not libnames.empty()){ - //split option - std::vector privatize_libs; - boost::split(privatize_libs,libnames, boost::is_any_of(";")); - - for (auto const& libname : privatize_libs) { - //load the library once to add it to the local libs, to get the absolute path - void* libhandle = dlopen(libname.c_str(), RTLD_LAZY); - //get library name from path - char fullpath[512]={'\0'}; - strcpy(fullpath, libname.c_str()); -#if not defined(__APPLE__) - int ret = dl_iterate_phdr(visit_libs, fullpath); - if(ret==0) - xbt_die("Can't find a linked %s - check the setting you gave to smpi/privatize-libs", fullpath); - else - XBT_DEBUG("Extra lib to privatize found : %s", fullpath); -#else - xbt_die("smpi/privatize-libs is not (yet) compatible with OSX"); -#endif - privatize_libs_paths.push_back(fullpath); - dlclose(libhandle); - } - } - - 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"; - - smpi_copy_file(executable_copy, target_executable, fdin_size); - //if smpi/privatize-libs is set, duplicate pointed lib and link each executable copy to a different one. - std::string target_lib; - for (auto const& libpath : privatize_libs_paths){ - //if we were given a full path, strip it - size_t index = libpath.find_last_of("/\\"); - std::string libname; - if(index!=std::string::npos) - libname=libpath.substr(index+1); - - if(not libname.empty()){ - //load the library to add it to the local libs, to get the absolute path - struct stat fdin_stat2; - stat(libpath.c_str(), &fdin_stat2); - off_t fdin_size2 = fdin_stat2.st_size; - - // Copy the dynamic library, the new name must be the same length as the old one - // just replace the name with 7 digits for the rank and the rest of the name. - unsigned int pad=7; - if(libname.length()("smpi/keep-temps") == false){ - unlink(target_executable.c_str()); - if(not target_lib.empty()) - unlink(target_lib.c_str()); - } - if (handle == nullptr) - xbt_die("dlopen failed: %s (errno: %d -- %s)", dlerror(), saved_errno, strerror(saved_errno)); - smpi_entry_point_type entry_point = smpi_resolve_function(handle); - if (not entry_point) - xbt_die("Could not resolve entry point"); - smpi_run_entry_point(entry_point, args); - }); - }; - } - else { - if (smpi_privatize_global_variables == SmpiPrivStrategies::MMAP) - smpi_prepare_global_memory_segment(); - // Load the dynamic library and resolve the entry point: - void* handle = dlopen(executable, RTLD_LAZY | RTLD_LOCAL); - if (handle == nullptr) - xbt_die("dlopen failed for %s: %s (errno: %d -- %s)", executable, dlerror(), errno, strerror(errno)); - smpi_entry_point_type entry_point = smpi_resolve_function(handle); - if (not entry_point) - xbt_die("main not found in %s", executable); - if (smpi_privatize_global_variables == SmpiPrivStrategies::MMAP) - smpi_backup_global_memory_segment(); - - // Execute the same entry point for each simulated process: - simix_global->default_function = [entry_point](std::vector args) { - return std::function([entry_point, args] { - smpi_run_entry_point(entry_point, args); - }); - }; - } + if (smpi_privatize_global_variables == SmpiPrivStrategies::DLOPEN) + smpi_init_privatization_dlopen(executable); + else + smpi_init_privatization_no_dlopen(executable); SMPI_init(); SIMIX_launch_application(argv[2]);