X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/87c589b94e563580e8e0585079cdba97914d791d..3e9453209f1da7deb92fe629428e49f3528217bd:/src/kernel/context/ContextBoost.hpp diff --git a/src/kernel/context/ContextBoost.hpp b/src/kernel/context/ContextBoost.hpp index 580ec7ec61..22295c55a1 100644 --- a/src/kernel/context/ContextBoost.hpp +++ b/src/kernel/context/ContextBoost.hpp @@ -1,10 +1,10 @@ -/* Copyright (c) 2015-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2015-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#ifndef SIMGRID_SIMIX_BOOST_CONTEXT_HPP -#define SIMGRID_SIMIX_BOOST_CONTEXT_HPP +#ifndef SIMGRID_KERNEL_CONTEXT_BOOST_CONTEXT_HPP +#define SIMGRID_KERNEL_CONTEXT_BOOST_CONTEXT_HPP #include #if BOOST_VERSION < 106100 @@ -18,70 +18,34 @@ #include #include -#include -#include -#include - -#include "src/internal_config.h" -#include "src/kernel/context/Context.hpp" #include "src/kernel/context/ContextSwapped.hpp" +#include "src/xbt/parmap.hpp" -namespace simgrid { -namespace kernel { -namespace context { +namespace simgrid::kernel::context { /** @brief Userspace context switching implementation based on Boost.Context */ class BoostContext : public SwappedContext { public: - BoostContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process); - ~BoostContext() override; - void stop() override; - - void swap_into(SwappedContext* to) override; + BoostContext(std::function&& code, actor::ActorImpl* actor, SwappedContextFactory* factory); private: -#if BOOST_VERSION < 105600 - boost::context::fcontext_t* fc_ = nullptr; - typedef intptr_t arg_type; -#elif BOOST_VERSION < 106100 - boost::context::fcontext_t fc_; - typedef intptr_t arg_type; +#if BOOST_VERSION < 106100 + boost::context::fcontext_t fc_{}; + using arg_type = intptr_t; #else - boost::context::detail::fcontext_t fc_; - typedef boost::context::detail::transfer_t arg_type; -#endif -#if HAVE_SANITIZER_ADDRESS_FIBER_SUPPORT - const void* asan_stack_ = nullptr; - size_t asan_stack_size_ = 0; - BoostContext* asan_ctx_ = nullptr; - bool asan_stop_ = false; + boost::context::detail::fcontext_t fc_{}; + using arg_type = boost::context::detail::transfer_t; #endif - static void wrapper(arg_type arg); -}; + XBT_ATTRIB_NORETURN static void wrapper(arg_type arg); -class ParallelBoostContext : public BoostContext { -public: - ParallelBoostContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process) - : BoostContext(std::move(code), cleanup_func, process) - { - } - void suspend() override; - void resume() override; - - static void run_all(); + void swap_into_for_real(SwappedContext* to) override; }; -class BoostContextFactory : public ContextFactory { +class BoostContextFactory : public SwappedContextFactory { public: - BoostContextFactory(); - ~BoostContextFactory() override; - Context* create_context(std::function code, void_pfn_smxprocess_t cleanup, smx_actor_t process) override; - void run_all() override; - -private: - bool parallel_; + BoostContext* create_context(std::function&& code, actor::ActorImpl* actor) override; }; -}}} // namespace +} // namespace simgrid::kernel::context #endif