From 38e728f7b3bcd80fc948d911a3eaa0ec2062ab69 Mon Sep 17 00:00:00 2001 From: Martin Quinson Date: Fri, 13 Jul 2018 23:02:21 +0200 Subject: [PATCH] stringify, snake_case and cleanups in k::ExecImpl --- src/kernel/activity/ActivityImpl.hpp | 1 + src/kernel/activity/ExecImpl.cpp | 22 +++++++++------------- src/kernel/activity/ExecImpl.hpp | 9 ++++----- src/plugins/dirty_page_tracking.cpp | 4 ++-- src/simix/smx_host.cpp | 2 +- 5 files changed, 17 insertions(+), 21 deletions(-) diff --git a/src/kernel/activity/ActivityImpl.hpp b/src/kernel/activity/ActivityImpl.hpp index d145e8fb36..31b4b4b843 100644 --- a/src/kernel/activity/ActivityImpl.hpp +++ b/src/kernel/activity/ActivityImpl.hpp @@ -22,6 +22,7 @@ namespace activity { class XBT_PUBLIC ActivityImpl { public: ActivityImpl(); + explicit ActivityImpl(std::string name) : name_(name) {} virtual ~ActivityImpl(); e_smx_state_t state_ = SIMIX_WAITING; /* State of the activity */ std::string name_; /* Activity name if any */ diff --git a/src/kernel/activity/ExecImpl.cpp b/src/kernel/activity/ExecImpl.cpp index ebfa43b320..17fdf8da28 100644 --- a/src/kernel/activity/ExecImpl.cpp +++ b/src/kernel/activity/ExecImpl.cpp @@ -15,20 +15,15 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_process); -simgrid::kernel::activity::ExecImpl::ExecImpl(const char* name, resource::Action* surf_action, +simgrid::kernel::activity::ExecImpl::ExecImpl(std::string name, resource::Action* surf_action, resource::Action* timeout_detector, s4u::Host* host) - : host_(host) + : ActivityImpl(name), host_(host), surf_action_(surf_action), timeout_detector_(timeout_detector) { - if (name) - this->name_ = name; this->state_ = SIMIX_RUNNING; - surf_action_ = surf_action; surf_action_->set_data(this); - if (timeout_detector != nullptr) { + if (timeout_detector != nullptr) timeout_detector->set_data(this); - timeout_detector_ = timeout_detector; - } XBT_DEBUG("Create exec %p", this); } @@ -116,7 +111,7 @@ void simgrid::kernel::activity::ExecImpl::post() timeout_detector_ = nullptr; } - onCompletion(this); + on_completion(this); /* If there are simcalls associated with the synchro, then answer them */ if (not simcalls_.empty()) SIMIX_execution_finish(this); @@ -142,13 +137,14 @@ simgrid::kernel::activity::ExecImpl::migrate(simgrid::s4u::Host* to) this->surf_action_ = new_action; } - onMigration(this, to); + on_migration(this, to); return this; } /************* * Callbacks * *************/ -simgrid::xbt::signal simgrid::kernel::activity::ExecImpl::onCreation; -simgrid::xbt::signal simgrid::kernel::activity::ExecImpl::onCompletion; -simgrid::xbt::signal simgrid::kernel::activity::ExecImpl::onMigration; +simgrid::xbt::signal simgrid::kernel::activity::ExecImpl::on_creation; +simgrid::xbt::signal simgrid::kernel::activity::ExecImpl::on_completion; +simgrid::xbt::signal + simgrid::kernel::activity::ExecImpl::on_migration; diff --git a/src/kernel/activity/ExecImpl.hpp b/src/kernel/activity/ExecImpl.hpp index d37b98745b..453d4f1bc3 100644 --- a/src/kernel/activity/ExecImpl.hpp +++ b/src/kernel/activity/ExecImpl.hpp @@ -17,7 +17,7 @@ class XBT_PUBLIC ExecImpl : public ActivityImpl { ~ExecImpl() override; public: - explicit ExecImpl(const char* name, resource::Action* surf_action, resource::Action* timeout_detector, + explicit ExecImpl(std::string name, resource::Action* surf_action, resource::Action* timeout_detector, s4u::Host* host); void suspend() override; void resume() override; @@ -36,10 +36,9 @@ private: resource::Action* timeout_detector_ = nullptr; public: - static simgrid::xbt::signal onCreation; - static simgrid::xbt::signal onCompletion; - static simgrid::xbt::signal onMigration; - + static simgrid::xbt::signal on_creation; + static simgrid::xbt::signal on_completion; + static simgrid::xbt::signal on_migration; }; } } diff --git a/src/plugins/dirty_page_tracking.cpp b/src/plugins/dirty_page_tracking.cpp index 4097976bb3..df2cc070d5 100644 --- a/src/plugins/dirty_page_tracking.cpp +++ b/src/plugins/dirty_page_tracking.cpp @@ -107,8 +107,8 @@ void sg_vm_dirty_page_tracking_init() simgrid::vm::DirtyPageTrackingExt::EXTENSION_ID = simgrid::vm::VirtualMachineImpl::extension_create(); simgrid::vm::VirtualMachineImpl::on_creation.connect(&on_virtual_machine_creation); - simgrid::kernel::activity::ExecImpl::onCreation.connect(&on_exec_creation); - simgrid::kernel::activity::ExecImpl::onCompletion.connect(&on_exec_completion); + simgrid::kernel::activity::ExecImpl::on_creation.connect(&on_exec_creation); + simgrid::kernel::activity::ExecImpl::on_completion.connect(&on_exec_completion); } } diff --git a/src/simix/smx_host.cpp b/src/simix/smx_host.cpp index 3b1cde9b47..022a54f9ee 100644 --- a/src/simix/smx_host.cpp +++ b/src/simix/smx_host.cpp @@ -76,7 +76,7 @@ SIMIX_execution_start(const char* name, double flops_amount, double priority, do new simgrid::kernel::activity::ExecImpl(name, surf_action, /*timeout_detector*/ nullptr, host)); XBT_DEBUG("Create execute synchro %p: %s", exec.get(), exec->name_.c_str()); - simgrid::kernel::activity::ExecImpl::onCreation(exec); + simgrid::kernel::activity::ExecImpl::on_creation(exec); return exec; } -- 2.20.1