X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4d5c6aed22b8ae1c8a73cd04d8ab800322d177bf..6658e9f2ff4a24cc2e074c654f8f818be1d79089:/src/kernel/context/ContextUnix.hpp diff --git a/src/kernel/context/ContextUnix.hpp b/src/kernel/context/ContextUnix.hpp index e295305be0..00c4832144 100644 --- a/src/kernel/context/ContextUnix.hpp +++ b/src/kernel/context/ContextUnix.hpp @@ -26,14 +26,13 @@ namespace context { class UContext : public SwappedContext { public: - UContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process); + UContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process, + SwappedContextFactory* factory); ~UContext() override; - void stop() override; void swap_into(SwappedContext* to) override; private: - void* stack_ = nullptr; /* the thread stack */ ucontext_t uc_; /* the ucontext that executes the code */ #if HAVE_SANITIZER_ADDRESS_FIBER_SUPPORT @@ -47,35 +46,11 @@ private: static void make_ctx(ucontext_t* ucp, void (*func)(int, int), UContext* arg); }; -class ParallelUContext : public UContext { +class UContextFactory : public SwappedContextFactory { public: - ParallelUContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process) - : UContext(std::move(code), cleanup_func, process) - { - } - void suspend() override; - void resume() override; + UContextFactory() : SwappedContextFactory("UContextFactory") {} - static void initialize(); - static void finalize(); - static void run_all(); - -private: - static simgrid::xbt::Parmap* parmap_; - static std::vector workers_context_; - static std::atomic threads_working_; - static thread_local uintptr_t worker_id_; -}; - -class UContextFactory : public ContextFactory { -public: - UContextFactory(); - ~UContextFactory() override; Context* create_context(std::function code, void_pfn_smxprocess_t cleanup, smx_actor_t process) override; - void run_all() override; - -private: - bool parallel_; }; }}} // namespace