From 04e4b74194a2a469fa52ea1b29f0a7265a24434f Mon Sep 17 00:00:00 2001 From: Frederic Suter Date: Mon, 4 Nov 2019 10:03:57 +0100 Subject: [PATCH] SIMIX cosmetics --- src/simix/smx_global.cpp | 26 +++++++++++++------------- src/simix/smx_private.hpp | 22 +++++++++++----------- 2 files changed, 24 insertions(+), 24 deletions(-) diff --git a/src/simix/smx_global.cpp b/src/simix/smx_global.cpp index 1bebfe788c..1af8b5b51e 100644 --- a/src/simix/smx_global.cpp +++ b/src/simix/smx_global.cpp @@ -34,10 +34,10 @@ void (*SMPI_switch_data_segment)(simgrid::s4u::ActorPtr) = nullptr; namespace simgrid { namespace simix { -simgrid::config::Flag cfg_verbose_exit{ - "debug/verbose-exit", {"verbose-exit"}, "Display the actor status at exit", true}; -} +config::Flag cfg_verbose_exit{"debug/verbose-exit", {"verbose-exit"}, "Display the actor status at exit", true}; +} // namespace simix } // namespace simgrid + XBT_ATTRIB_NORETURN static void inthandler(int) { if (simgrid::simix::cfg_verbose_exit) { @@ -134,7 +134,7 @@ static void install_segvhandler() namespace simgrid { namespace simix { -Timer* Timer::set(double date, simgrid::xbt::Task&& callback) +Timer* Timer::set(double date, xbt::Task&& callback) { Timer* timer = new Timer(date, std::move(callback)); timer->handle_ = simix_timers.emplace(std::make_pair(date, timer)); @@ -144,7 +144,7 @@ Timer* Timer::set(double date, simgrid::xbt::Task&& callback) /** @brief cancels a timer that was added earlier */ void Timer::remove() { - simgrid::simix::simix_timers.erase(handle_); + simix_timers.erase(handle_); delete this; } @@ -173,7 +173,7 @@ bool Global::execute_tasks() void Global::empty_trash() { while (not actors_to_destroy.empty()) { - smx_actor_t actor = &actors_to_destroy.front(); + kernel::actor::ActorImpl* actor = &actors_to_destroy.front(); actors_to_destroy.pop_front(); XBT_DEBUG("Getting rid of %s (refcount: %d)", actor->get_cname(), actor->get_refcount()); intrusive_ptr_release(actor); @@ -197,10 +197,10 @@ void Global::run_all_actors() actors_to_run.clear(); } -simgrid::config::Flag cfg_breakpoint{ +config::Flag cfg_breakpoint{ "debug/breakpoint", {"simix/breakpoint"}, "When non-negative, raise a SIGTRAP after given (simulated) time", -1.0}; -} -} +} // namespace simix +} // namespace simgrid static simgrid::simix::ActorCode maestro_code; void SIMIX_set_maestro(void (*code)(void*), void* data) @@ -470,9 +470,9 @@ void SIMIX_run() * That would thus be a pure waste of time. */ - for (smx_actor_t const& process : simix_global->actors_that_ran) { - if (process->simcall.call_ != SIMCALL_NONE) { - process->simcall_handle(0); + for (auto const& actor : simix_global->actors_that_ran) { + if (actor->simcall.call_ != SIMCALL_NONE) { + actor->simcall_handle(0); } } @@ -562,7 +562,7 @@ void SIMIX_display_process_status() /* List the process and their state */ XBT_INFO("Legend of the following listing: \"Process (@): \""); for (auto const& kv : simix_global->process_list) { - smx_actor_t actor = kv.second; + simgrid::kernel::actor::ActorImpl* actor = kv.second; if (actor->waiting_synchro) { diff --git a/src/simix/smx_private.hpp b/src/simix/smx_private.hpp index 18b0131af8..bc6f1296ac 100644 --- a/src/simix/smx_private.hpp +++ b/src/simix/smx_private.hpp @@ -32,9 +32,9 @@ public: void run_all_actors(); smx_context_factory_t context_factory = nullptr; - std::vector actors_to_run; - std::vector actors_that_ran; - std::map process_list; + std::vector actors_to_run; + std::vector actors_that_ran; + std::map process_list; boost::intrusive::list, &kernel::actor::ActorImpl::smx_destroy_list_hook>> @@ -48,23 +48,23 @@ public: * That way, the MCer would not need to have the list of actors on its side. * These info could be published by the MCed to the MCer in a way inspired of vd.so */ - xbt_dynar_t actors_vector = xbt_dynar_new(sizeof(smx_actor_t), nullptr); - xbt_dynar_t dead_actors_vector = xbt_dynar_new(sizeof(smx_actor_t), nullptr); + xbt_dynar_t actors_vector = xbt_dynar_new(sizeof(kernel::actor::ActorImpl*), nullptr); + xbt_dynar_t dead_actors_vector = xbt_dynar_new(sizeof(kernel::actor::ActorImpl*), nullptr); #endif - smx_actor_t maestro_process = nullptr; + kernel::actor::ActorImpl* maestro_process = nullptr; // Maps function names to actor code: - std::unordered_map registered_functions; + std::unordered_map registered_functions; // This might be used when no corresponding function name is registered: - simgrid::simix::ActorCodeFactory default_function; + simix::ActorCodeFactory default_function; std::mutex mutex; - std::vector> tasks; - std::vector> tasksTemp; + std::vector> tasks; + std::vector> tasksTemp; - std::vector daemons; + std::vector daemons; }; } } -- 2.20.1