X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/94f511befd8ea7dea78746c1f6ae818a778e67e7..593f7525c1fbd75ab6c4f105f9f340401464fe0b:/src/kernel/context/ContextSwapped.hpp diff --git a/src/kernel/context/ContextSwapped.hpp b/src/kernel/context/ContextSwapped.hpp index 6e56bb166f..aba97d5b95 100644 --- a/src/kernel/context/ContextSwapped.hpp +++ b/src/kernel/context/ContextSwapped.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2009-2019. 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. */ @@ -18,7 +18,7 @@ class SwappedContext; class SwappedContextFactory : public ContextFactory { friend SwappedContext; // Reads whether we are in parallel mode public: - SwappedContextFactory(std::string name); + SwappedContextFactory(); ~SwappedContextFactory() override; void run_all() override; @@ -30,12 +30,12 @@ private: /* For the parallel execution */ simgrid::xbt::Parmap* parmap_; std::vector workers_context_; /* space to save the worker's context in each thread */ - std::atomic threads_working_; /* number of threads that have started their work */ + std::atomic threads_working_{0}; /* number of threads that have started their work */ }; class SwappedContext : public Context { public: - SwappedContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process, + SwappedContext(std::function code, void_pfn_smxprocess_t cleanup_func, smx_actor_t get_actor, SwappedContextFactory* factory); virtual ~SwappedContext(); @@ -45,18 +45,20 @@ public: virtual void swap_into(SwappedContext* to) = 0; // Defined in Raw, Boost and UContext subclasses - static SwappedContext* get_maestro() { return maestro_context_; } - static void set_maestro(SwappedContext* maestro) { maestro_context_ = maestro; } + void* get_stack(); - // FIXME: Killme static thread_local uintptr_t worker_id_; -protected: - void* stack_ = nullptr; /* the thread stack */ +#if HAVE_SANITIZER_ADDRESS_FIBER_SUPPORT + const void* asan_stack_ = nullptr; + size_t asan_stack_size_ = 0; + SwappedContext* asan_ctx_ = nullptr; + bool asan_stop_ = false; +#endif private: - static SwappedContext* maestro_context_; - SwappedContextFactory* factory_; // for sequential and parallel run_all() + void* stack_ = nullptr; /* the thread stack */ + SwappedContextFactory* const factory_; // for sequential and parallel run_all() }; } // namespace context