Even the ones that we don't control, such as gdb's...
In addition, there is no need to define sthread_inside_simgrid in
libsimgrid. We can keep it to libsthread where it belongs.
Also do some other cleanups around.
pthread_mutex_init(&mutex, NULL);
pthread_t thread1, thread2;
- fprintf(stderr, "prout\n");
pthread_create(&thread1, NULL, thread1_fun, NULL);
+ fprintf(stderr, "here\n");
pthread_create(&thread2, NULL, thread2_fun, NULL);
// pthread_join(thread1, NULL);
// pthread_join(thread2, NULL);
#include <dlfcn.h>
#include <pthread.h>
#include <semaphore.h>
+#include <stdio.h>
+
+int sthread_inside_simgrid = 1; // whether sthread should leave pthread operations, or intercept them.
/* We don't want to intercept pthread within simgrid. Instead we should provide the real implem to simgrid */
static int (*raw_pthread_create)(pthread_t*, const pthread_attr_t*, void* (*)(void*), void*);
/* Find the real __libc_start_main()... */
typeof(&__libc_start_main) orig = dlsym(RTLD_NEXT, "__libc_start_main");
-
+ fprintf(stderr, "__libc_start_main\n");
/* ... and call it with our custom main function */
return orig(main_hook, argc, argv, init, fini, rtld_fini, stack_end);
}
\ No newline at end of file
/* SimGrid's pthread interposer. Actual implementation of the symbols (see the comment in sthread.h) */
-#include <dlfcn.h>
-#include <pthread.h>
-#include <semaphore.h>
-#include <stdio.h>
-#include <stdlib.h>
-
#include "smpi/smpi.h"
#include <simgrid/actor.h>
#include <simgrid/s4u/Actor.hpp>
#include "src/internal_config.h"
#include "src/sthread/sthread.h"
+#include <dlfcn.h>
+#include <pthread.h>
+#include <semaphore.h>
+#include <sstream>
+#include <stdio.h>
+#include <stdlib.h>
+#include <thread>
+
XBT_LOG_NEW_DEFAULT_CATEGORY(sthread, "pthread intercepter");
namespace sg4 = simgrid::s4u;
int sthread_main(int argc, char** argv, char** envp, int (*raw_main)(int, char**, char**))
{
- XBT_INFO("sthread main() is starting");
- sthread_inside_simgrid = 1;
+ std::ostringstream id;
+ id << std::this_thread::get_id();
+
+ XBT_INFO("sthread main() is starting in thread %s", id.str().c_str());
sg4::Engine e(&argc, argv);
auto* zone = sg4::create_full_zone("world");
lilibeth = zone->create_host("Lilibeth", 1e15);
zone->seal();
- sthread_inside_simgrid = 0;
/* Launch the user's main() on an actor */
+ sthread_inside_simgrid = 0;
sg4::ActorPtr main_actor = sg4::Actor::create("tid 0", lilibeth, raw_main, argc, argv, envp);
XBT_INFO("sthread main() is launching the simulation");
{
static int TID = 1;
- if (TID == 0) {
- }
TID++;
int rank = 0;
#if HAVE_SMPI
if (category->initialized)
return priority >= category->threshold;
- int old_inside_simgrid = sthread_inside_simgrid;
- sthread_inside_simgrid = 1;
if (log_cat_init_mutex != nullptr)
log_cat_init_mutex->lock();
category->initialized = 1;
if (log_cat_init_mutex != nullptr)
log_cat_init_mutex->unlock();
- sthread_inside_simgrid = old_inside_simgrid;
return priority >= category->threshold;
}
std::vector<std::string> cmdline; /* all we got in argv */
} // namespace simgrid::xbt
-int sthread_inside_simgrid = 0; // whether sthread should leave pthread operations or intercept them.
-
int xbt_initialized = 0;
simgrid::config::Flag<bool> cfg_dbg_clean_atexit{
"debug/clean-atexit",
static void xbt_preinit()
{
- sthread_inside_simgrid = 1;
#ifdef _WIN32
SYSTEM_INFO si;
GetSystemInfo(&si);
xbt_log_preinit();
xbt_dict_preinit();
atexit(xbt_postexit);
- sthread_inside_simgrid = 0;
}
static void xbt_postexit()