smx_context_t BoostContextFactory::create_context(std::function<void()> code, void_pfn_smxprocess_t cleanup_func,
smx_actor_t process)
{
- if (parallel_)
- return this->new_context<ParallelBoostContext>(std::move(code), cleanup_func, process, this);
return this->new_context<BoostContext>(std::move(code), cleanup_func, process, this);
}
#endif
}
-// ParallelBoostContext
-void ParallelBoostContext::suspend()
-{
- boost::optional<smx_actor_t> next_work = parmap_->next();
- SwappedContext* next_context;
- if (next_work) {
- XBT_DEBUG("Run next process");
- next_context = static_cast<ParallelBoostContext*>(next_work.get()->context_);
- } else {
- XBT_DEBUG("No more processes to run");
- next_context = workers_context_[worker_id_];
- }
-
- Context::set_current(next_context);
- this->swap_into(next_context);
-}
-
-void ParallelBoostContext::resume()
-{
- worker_id_ = threads_working_.fetch_add(1, std::memory_order_relaxed);
-
- SwappedContext* worker_context = static_cast<SwappedContext*>(self());
- workers_context_[worker_id_] = worker_context;
-
- Context::set_current(this);
- worker_context->swap_into(this);
-}
-
-
XBT_PRIVATE ContextFactory* boost_factory()
{
XBT_VERB("Using Boost contexts. Welcome to the 21th century.");
static void wrapper(arg_type arg);
};
-class ParallelBoostContext : public BoostContext {
-public:
- ParallelBoostContext(std::function<void()> code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process,
- SwappedContextFactory* factory)
- : BoostContext(std::move(code), cleanup_func, process, factory)
- {
- }
- void suspend() override;
- void resume() override;
-};
-
class BoostContextFactory : public SwappedContextFactory {
public:
BoostContextFactory() : SwappedContextFactory("BoostContextFactory") {}
Context* RawContextFactory::create_context(std::function<void()> code, void_pfn_smxprocess_t cleanup_func,
smx_actor_t process)
{
- if (parallel_)
- return this->new_context<ParallelRawContext>(std::move(code), cleanup_func, process, this);
return this->new_context<RawContext>(std::move(code), cleanup_func, process, this);
}
ASAN_FINISH_SWITCH(fake_stack, &from->asan_ctx_->asan_stack_, &from->asan_ctx_->asan_stack_size_);
}
-// ParallelRawContext
-
-void ParallelRawContext::suspend()
-{
- /* determine the next context */
- boost::optional<smx_actor_t> next_work = parmap_->next();
- SwappedContext* next_context;
- if (next_work) {
- /* there is a next process to resume */
- XBT_DEBUG("Run next process");
- next_context = static_cast<ParallelRawContext*>(next_work.get()->context_);
- } else {
- /* all processes were run, go to the barrier */
- XBT_DEBUG("No more processes to run");
- next_context = workers_context_[worker_id_];
- XBT_DEBUG("Restoring worker stack %zu (working threads = %zu)", worker_id_, threads_working_.load());
- }
-
- Context::set_current(next_context);
- this->swap_into(next_context);
-}
-
-void ParallelRawContext::resume()
-{
- worker_id_ = threads_working_.fetch_add(1, std::memory_order_relaxed);
- SwappedContext* worker_context = static_cast<SwappedContext*>(self());
- workers_context_[worker_id_] = worker_context;
- XBT_DEBUG("Saving worker stack %zu", worker_id_);
- Context::set_current(this);
- worker_context->swap_into(this);
-}
-
ContextFactory* raw_factory()
{
XBT_VERB("Using raw contexts. Because the glibc is just not good enough for us.");
static void wrapper(void* arg);
};
-class ParallelRawContext : public RawContext {
-public:
- ParallelRawContext(std::function<void()> code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process,
- SwappedContextFactory* factory)
- : RawContext(std::move(code), cleanup_func, process, factory)
- {
- }
- void suspend() override;
- void resume() override;
-};
-
class RawContextFactory : public SwappedContextFactory {
public:
RawContextFactory() : SwappedContextFactory("RawContextFactory") {}
#include "xbt/parmap.hpp"
#include "src/kernel/context/ContextSwapped.hpp"
-#include "src/kernel/context/ContextUnix.hpp" // FIXME: temporary reverse import
#ifdef _WIN32
#include <malloc.h>