X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9104957deccc59e0e804215d5db498fabfd40d29..14b8a433dc3ded0e9fddce253640b5b852daf793:/src/kernel/context/ContextSwapped.hpp diff --git a/src/kernel/context/ContextSwapped.hpp b/src/kernel/context/ContextSwapped.hpp index 1b815aa3f4..ed98656216 100644 --- a/src/kernel/context/ContextSwapped.hpp +++ b/src/kernel/context/ContextSwapped.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2009-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. */ @@ -8,23 +8,18 @@ #include "src/internal_config.h" // HAVE_SANITIZER_* #include "src/kernel/context/Context.hpp" +#include "src/xbt/parmap.hpp" #include -namespace simgrid { -namespace kernel { -namespace context { +namespace simgrid::kernel::context { class SwappedContext; -} // namespace context -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel::context /* Use extern "C" to make sure that this symbol is easy to recognize by name, even on exotic platforms */ extern "C" XBT_ATTRIB_NORETURN void smx_ctx_wrapper(simgrid::kernel::context::SwappedContext* context); -namespace simgrid { -namespace kernel { -namespace context { +namespace simgrid::kernel::context { class SwappedContextFactory : public ContextFactory { friend SwappedContext; // Reads whether we are in parallel mode @@ -32,7 +27,7 @@ public: SwappedContextFactory() = default; SwappedContextFactory(const SwappedContextFactory&) = delete; SwappedContextFactory& operator=(const SwappedContextFactory&) = delete; - void run_all() override; + void run_all(std::vector const& actors) override; private: /* For the sequential execution */ @@ -40,30 +35,28 @@ private: SwappedContext* maestro_context_ = nullptr; // save maestro's context /* For the parallel execution, will be created lazily with the right parameters if needed (ie, in parallel) */ - std::unique_ptr> parmap_{nullptr}; + std::unique_ptr> parmap_{nullptr}; }; class SwappedContext : public Context { friend void ::smx_ctx_wrapper(simgrid::kernel::context::SwappedContext*); public: - SwappedContext(std::function&& code, smx_actor_t get_actor, SwappedContextFactory* factory); + SwappedContext(std::function&& code, actor::ActorImpl* get_actor, SwappedContextFactory* factory); SwappedContext(const SwappedContext&) = delete; SwappedContext& operator=(const SwappedContext&) = delete; - virtual ~SwappedContext(); + ~SwappedContext() override; void suspend() override; virtual void resume(); - XBT_ATTRIB_NORETURN void stop() override; void swap_into(SwappedContext* to); +protected: unsigned char* get_stack() const { return stack_; } - // Return the address for the bottom of the stack. Depending on the stack direction it may be the lower or higher - // address - unsigned char* get_stack_bottom() const { return PTH_STACKGROWTH == -1 ? stack_ + smx_context_stack_size : stack_; } + unsigned char* get_stack_bottom() const; // Depending on the stack direction, its bottom (that Boost::make_fcontext + // needs) may be the lower or higher end -protected: // With ASan, after a context switch, check that the originating context is the expected one (see BoostContext) void verify_previous_context(const SwappedContext* context) const; @@ -74,7 +67,7 @@ private: SwappedContextFactory& factory_; // for sequential and parallel run_all() #if HAVE_VALGRIND_H - unsigned int valgrind_stack_id_; + unsigned int valgrind_stack_id_ = 0; #endif #if HAVE_SANITIZER_ADDRESS_FIBER_SUPPORT const void* asan_stack_ = nullptr; @@ -96,7 +89,5 @@ inline void SwappedContext::verify_previous_context(XBT_ATTRIB_UNUSED const Swap #endif } -} // namespace context -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel::context #endif