- ASAN_FINISH_SWITCH(fake_stack, &from->asan_ctx_->asan_stack_, &from->asan_ctx_->asan_stack_size_);
-}
-
-void UContext::stop()
-{
- Context::stop();
- throw StopRequest();
-}
-
-// ParallelUContext
-
-void ParallelUContext::run_all()
-{
- threads_working_ = 0;
-
- // We lazily create the parmap so that all options are actually processed when doing so.
- if (parmap_ == nullptr)
- parmap_ = new simgrid::xbt::Parmap<smx_actor_t>(SIMIX_context_get_nthreads(), SIMIX_context_get_parallel_mode());
-
- // Usually, Parmap::apply() executes the provided function on all elements of the array.
- // Here, the executed function does not return the control to the parmap before all the array is processed:
- // - suspend() should switch back to the worker_context (either maestro or one of its minions) to return
- // the control to the parmap. Instead, it uses parmap_->next() to steal another work, and does it directly.
- // It only yields back to worker_context when the work array is exhausted.
- // - So, resume() is only launched from the parmap for the first job of each minion.
- parmap_->apply(
- [](smx_actor_t process) {
- ParallelUContext* context = static_cast<ParallelUContext*>(process->context_);
- context->resume();
- },
- simix_global->process_to_run);
-}
-
-/** Run one particular simulated process on the current thread.
- *
- * Only applied to the N first elements of the parmap array, where N is the amount of worker threads in the parmap.
- * See ParallelUContext::run_all for details.
- */
-void ParallelUContext::resume()
-{
- // Save the thread number (my body) in an os-thread-specific area
- worker_id_ = threads_working_.fetch_add(1, std::memory_order_relaxed);
- // Save my current soul (either maestro, or one of the minions) in a permanent area
- SwappedContext* worker_context = static_cast<SwappedContext*>(self());
- workers_context_[worker_id_] = worker_context;
- // Switch my soul and the actor's one
- Context::set_current(this);
- worker_context->swap_into(this);
- // No body runs that soul anymore at this point, but it is stored in a safe place.
- // When the executed actor will do a blocking action, SIMIX_process_yield() will call suspend(), below.