Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Move Parallel{Boost,Raw,U}Context::{initialize,finalize} to SwappedContext
[simgrid.git] / src / kernel / context / ContextRaw.hpp
1 /* Copyright (c) 2009-2018. The SimGrid Team. All rights reserved.          */
2
3 /* This program is free software; you can redistribute it and/or modify it
4  * under the terms of the license (GNU LGPL) which comes with this package. */
5
6 #ifndef SIMGRID_SIMIX_RAW_CONTEXT_HPP
7 #define SIMGRID_SIMIX_RAW_CONTEXT_HPP
8
9 #include <atomic>
10 #include <cstdint>
11 #include <functional>
12 #include <vector>
13
14 #include <xbt/parmap.hpp>
15 #include <xbt/xbt_os_thread.h>
16
17 #include "src/kernel/context/ContextSwapped.hpp"
18
19 namespace simgrid {
20 namespace kernel {
21 namespace context {
22
23 /** @brief Fast context switching inspired from SystemV ucontexts.
24   *
25   * The main difference to the System V context is that Raw Contexts are much faster because they don't
26   * preserve the signal mask when switching. This saves a system call (at least on Linux) on each context switch.
27   */
28 class RawContext : public SwappedContext {
29 public:
30   RawContext(std::function<void()> code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process);
31   ~RawContext() override;
32   void stop() override;
33
34   void swap_into(SwappedContext* to) override;
35
36 private:
37   /** pointer to top the stack stack */
38   void* stack_top_ = nullptr;
39
40 #if HAVE_SANITIZER_ADDRESS_FIBER_SUPPORT
41   const void* asan_stack_ = nullptr;
42   size_t asan_stack_size_ = 0;
43   RawContext* asan_ctx_   = nullptr;
44   bool asan_stop_         = false;
45 #endif
46
47   static void wrapper(void* arg);
48 };
49
50 class ParallelRawContext : public RawContext {
51 public:
52   ParallelRawContext(std::function<void()> code, void_pfn_smxprocess_t cleanup_func, smx_actor_t process)
53       : RawContext(std::move(code), cleanup_func, process)
54   {
55   }
56   void suspend() override;
57   void resume() override;
58
59   static void run_all();
60 };
61
62 class RawContextFactory : public ContextFactory {
63 public:
64   RawContextFactory();
65   ~RawContextFactory() override;
66   Context* create_context(std::function<void()> code, void_pfn_smxprocess_t cleanup, smx_actor_t process) override;
67   void run_all() override;
68
69 private:
70   bool parallel_;
71 };
72 }}} // namespace
73
74 #endif