X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/54f2eb06fc9234cde1fba6d9ba2f32bda3f59a26..f5acac9da28f84a6625be7afaa01fc4ec6c643e7:/src/simix/ThreadContext.hpp diff --git a/src/simix/ThreadContext.hpp b/src/simix/ThreadContext.hpp index d706a339b1..abed18789f 100644 --- a/src/simix/ThreadContext.hpp +++ b/src/simix/ThreadContext.hpp @@ -18,15 +18,17 @@ namespace simix { class ThreadContext; class ThreadContextFactory; -class ThreadContext : public Context { +class ThreadContext : public AttachContext { public: friend ThreadContextFactory; ThreadContext(std::function code, void_pfn_smxprocess_t cleanup_func, - smx_process_t process); + smx_process_t process, bool maestro =false); ~ThreadContext(); void stop() override; void suspend() override; + void attach_start() override; + void attach_stop() override; private: /** A portable thread */ xbt_os_thread_t thread_ = nullptr; @@ -36,6 +38,9 @@ private: xbt_os_sem_t end_ = nullptr; private: static void* wrapper(void *param); + static void* maestro_wrapper(void *param); +public: + void start(); }; class ThreadContextFactory : public ContextFactory { @@ -46,6 +51,10 @@ public: void_pfn_smxprocess_t cleanup_func, smx_process_t process) override; void run_all() override; ThreadContext* self() override; + + // Optional methods: + ThreadContext* attach(void_pfn_smxprocess_t cleanup_func, smx_process_t process) override; + ThreadContext* create_maestro(std::function code, smx_process_t process) override; }; }