X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7a3a100990355eb757dc81106b5aac6daed0b8e1..196327afa332e6c85827da70da72a1aaa178739a:/src/simix/smx_private.hpp diff --git a/src/simix/smx_private.hpp b/src/simix/smx_private.hpp index 1dc37d7bd1..ea586f129a 100644 --- a/src/simix/smx_private.hpp +++ b/src/simix/smx_private.hpp @@ -8,10 +8,12 @@ #include "simgrid/s4u/Actor.hpp" #include "src/kernel/context/Context.hpp" -#include +#include "src/simix/ActorImpl.hpp" +#include #include -#include +#include +#include #include /********************************** Simix Global ******************************/ @@ -20,15 +22,16 @@ namespace simgrid { namespace simix { class Global { - friend XBT_PUBLIC bool simgrid::s4u::this_actor::isMaestro(); + friend XBT_PUBLIC bool simgrid::s4u::this_actor::is_maestro(); public: smx_context_factory_t context_factory = nullptr; std::vector process_to_run; std::vector process_that_ran; std::map process_list; - boost::intrusive::list, - &ActorImpl::smx_destroy_list_hook>> + boost::intrusive::list, + &kernel::actor::ActorImpl::smx_destroy_list_hook>> process_to_destroy; #if SIMGRID_HAVE_MC /* MCer cannot read members process_list and process_to_destroy above in the remote process, so we copy the info it @@ -54,18 +57,16 @@ public: void_pfn_smxprocess_t kill_process_function = nullptr; /** Callback used when killing a SMX_process */ void_pfn_smxprocess_t cleanup_process_function = nullptr; - xbt_os_mutex_t mutex = nullptr; + std::mutex mutex; std::vector> tasks; std::vector> tasksTemp; - std::vector daemons; + std::vector daemons; }; } } -extern "C" { - XBT_PUBLIC_DATA std::unique_ptr simix_global; XBT_PUBLIC void SIMIX_clean(); @@ -74,13 +75,12 @@ XBT_PUBLIC void SIMIX_clean(); /** @brief Ask to the provided ActorImpl to raise the provided exception */ #define SMX_EXCEPTION(issuer, cat, val, msg) \ if (1) { \ - simgrid::simix::ActorImpl* _smx_throw_issuer = (issuer); /* evaluate only once */ \ + simgrid::kernel::actor::ActorImpl* _smx_throw_issuer = (issuer); /* evaluate only once */ \ xbt_ex e(XBT_THROW_POINT, msg); \ e.category = cat; \ e.value = val; \ _smx_throw_issuer->exception = std::make_exception_ptr(e); \ } else \ - ((void)0) -} + ((void)0) #endif