zone->seal();
/* Launch the user's main() on an actor */
- sthread_inside_simgrid = 0;
+ sthread_enable();
sg4::ActorPtr main_actor = sg4::Actor::create("tid 0", lilibeth, raw_main, argc, argv, envp);
XBT_INFO("sthread main() is launching the simulation");
return 0;
}
+
struct sthread_mutex {
s4u_Mutex* mutex;
};
if (SMPI_is_inited())
SMPI_thread_create();
#endif
- sthread_inside_simgrid = 0;
+ sthread_enable();
user_function(param);
- sthread_inside_simgrid = 1;
+ sthread_disable();
}
int sthread_create(unsigned long int* thread, const /*pthread_attr_t*/ void* attr, void* (*start_routine)(void*),
void* arg)
{
- static int TID = 1;
-
+ static int TID = 0;
TID++;
+ XBT_INFO("Create thread %d", TID);
int rank = 0;
#if HAVE_SMPI
if (SMPI_is_inited())
*thread = reinterpret_cast<unsigned long>(actor.get());
return 0;
}
+int sthread_join(sthread_t thread, void** retval)
+{
+ sg4::ActorPtr actor(reinterpret_cast<sg4::Actor*>(thread));
+ actor->join();
+ intrusive_ptr_release(actor.get());
+
+ return 0;
+}
int sthread_mutex_init(sthread_mutex_t* mutex, const /*pthread_mutexattr_t*/ void* attr)
{