X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f3348af357bc527d926d3dd454a9fa0840d812b3..a4e7a60bca6c13451f237201eb5a7534e5da0838:/src/kernel/context/ContextBoost.hpp?ds=sidebyside diff --git a/src/kernel/context/ContextBoost.hpp b/src/kernel/context/ContextBoost.hpp index b0634592a9..067e872439 100644 --- a/src/kernel/context/ContextBoost.hpp +++ b/src/kernel/context/ContextBoost.hpp @@ -31,12 +31,19 @@ class BoostContextFactory; /** @brief Userspace context switching implementation based on Boost.Context */ class BoostContext : public Context { -protected: // static - static simgrid::xbt::Parmap* parmap_; - static std::vector workers_context_; - static uintptr_t threads_working_; - static xbt_os_thread_key_t worker_id_key_; - static unsigned long process_index_; +public: + BoostContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process); + ~BoostContext() override; + void stop() override; + virtual void resume() = 0; + + static void swap(BoostContext* from, BoostContext* to); + static BoostContext* getMaestro() { return maestro_context_; } + static void setMaestro(BoostContext* maestro) { maestro_context_ = maestro; } + +private: + static BoostContext* maestro_context_; + void* stack_ = nullptr; #if BOOST_VERSION < 105600 boost::context::fcontext_t* fc_ = nullptr; @@ -48,32 +55,18 @@ protected: // static boost::context::detail::fcontext_t fc_; typedef boost::context::detail::transfer_t arg_type; #endif - static void wrapper(arg_type arg); - static void swap(BoostContext* from, BoostContext* to); - #if HAVE_SANITIZE_ADDRESS_FIBER_SUPPORT const void* asan_stack_ = nullptr; size_t asan_stack_size_ = 0; bool asan_stop_ = false; #endif - void* stack_ = nullptr; -public: - BoostContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process); - ~BoostContext() override; - void stop() override; - virtual void resume() = 0; - - static BoostContext* getMaestro() { return maestro_context_; } - static void setMaestro(BoostContext* maestro) { maestro_context_ = maestro; } - - friend BoostContextFactory; - -private: - static BoostContext* maestro_context_; + static void wrapper(arg_type arg); }; class SerialBoostContext : public BoostContext { + friend BoostContextFactory; + public: SerialBoostContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process) : BoostContext(std::move(code), cleanup_func, process) @@ -81,10 +74,15 @@ public: } void suspend() override; void resume() override; + +private: + static unsigned long process_index_; }; #if HAVE_THREAD_CONTEXTS class ParallelBoostContext : public BoostContext { + friend BoostContextFactory; + public: ParallelBoostContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process) : BoostContext(std::move(code), cleanup_func, process) @@ -92,6 +90,12 @@ public: } void suspend() override; void resume() override; + +private: + static simgrid::xbt::Parmap* parmap_; + static std::vector workers_context_; + static uintptr_t threads_working_; + static xbt_os_thread_key_t worker_id_key_; }; #endif