X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/934b99618c47f4cb4b0761aa80a8147672108f58..e19e409cb82832c9b1f71b3cfaef58676b5f7ac8:/src/plugins/dirty_page_tracking.cpp diff --git a/src/plugins/dirty_page_tracking.cpp b/src/plugins/dirty_page_tracking.cpp index 5b3613ba89..9b469dc3c7 100644 --- a/src/plugins/dirty_page_tracking.cpp +++ b/src/plugins/dirty_page_tracking.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2017-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2017-2021. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -38,7 +38,6 @@ public: double get_max_downtime() const { return max_downtime_; } static simgrid::xbt::Extension EXTENSION_ID; - virtual ~DirtyPageTrackingExt() = default; DirtyPageTrackingExt() = default; }; @@ -68,22 +67,22 @@ double DirtyPageTrackingExt::computed_flops_lookup() } // namespace vm } // namespace simgrid -static void on_virtual_machine_creation(simgrid::vm::VirtualMachineImpl& vm) +static void on_virtual_machine_creation(const simgrid::s4u::VirtualMachine& vm) { - vm.extension_set(new simgrid::vm::DirtyPageTrackingExt()); + vm.get_vm_impl()->extension_set(new simgrid::vm::DirtyPageTrackingExt()); } static void on_exec_creation(simgrid::s4u::Exec const& e) { - auto exec = static_cast(e.get_impl()); + auto exec = static_cast(e.get_impl()); const simgrid::s4u::VirtualMachine* vm = dynamic_cast(exec->get_host()); if (vm == nullptr) return; - if (vm->get_impl()->extension()->is_tracking()) { - vm->get_impl()->extension()->track(exec, exec->get_remaining()); + if (vm->get_vm_impl()->extension()->is_tracking()) { + vm->get_vm_impl()->extension()->track(exec, exec->get_remaining()); } else { - vm->get_impl()->extension()->track(exec, 0.0); + vm->get_vm_impl()->extension()->track(exec, 0.0); } } @@ -96,11 +95,11 @@ static void on_exec_completion(simgrid::s4u::Exec const& e) /* If we are in the middle of dirty page tracking, we record how much computation has been done until now, and keep * the information for the lookup_() function that will called soon. */ - if (vm->get_impl()->extension()->is_tracking()) { - double delta = vm->get_impl()->extension()->get_stored_remains(exec); - vm->get_impl()->extension()->update_dirty_page_count(delta); + if (vm->get_vm_impl()->extension()->is_tracking()) { + double delta = vm->get_vm_impl()->extension()->get_stored_remains(exec); + vm->get_vm_impl()->extension()->update_dirty_page_count(delta); } - vm->get_impl()->extension()->untrack(exec); + vm->get_vm_impl()->extension()->untrack(exec); } void sg_vm_dirty_page_tracking_init() @@ -108,7 +107,7 @@ void sg_vm_dirty_page_tracking_init() if (not simgrid::vm::DirtyPageTrackingExt::EXTENSION_ID.valid()) { simgrid::vm::DirtyPageTrackingExt::EXTENSION_ID = simgrid::vm::VirtualMachineImpl::extension_create(); - simgrid::vm::VirtualMachineImpl::on_creation.connect(&on_virtual_machine_creation); + simgrid::s4u::VirtualMachine::on_creation.connect(&on_virtual_machine_creation); simgrid::s4u::Exec::on_start.connect(&on_exec_creation); simgrid::s4u::Exec::on_completion.connect(&on_exec_completion); } @@ -116,50 +115,50 @@ void sg_vm_dirty_page_tracking_init() void sg_vm_start_dirty_page_tracking(const_sg_vm_t vm) { - vm->get_impl()->extension()->start_tracking(); + vm->get_vm_impl()->extension()->start_tracking(); } void sg_vm_stop_dirty_page_tracking(const_sg_vm_t vm) { - vm->get_impl()->extension()->stop_tracking(); + vm->get_vm_impl()->extension()->stop_tracking(); } double sg_vm_lookup_computed_flops(const_sg_vm_t vm) { - return vm->get_impl()->extension()->computed_flops_lookup(); + return vm->get_vm_impl()->extension()->computed_flops_lookup(); } void sg_vm_set_dirty_page_intensity(const_sg_vm_t vm, double intensity) { - vm->get_impl()->extension()->set_intensity(intensity); + vm->get_vm_impl()->extension()->set_intensity(intensity); } double sg_vm_get_dirty_page_intensity(const_sg_vm_t vm) { - return vm->get_impl()->extension()->get_intensity(); + return vm->get_vm_impl()->extension()->get_intensity(); } void sg_vm_set_working_set_memory(const_sg_vm_t vm, sg_size_t size) { - vm->get_impl()->extension()->set_working_set_memory(size); + vm->get_vm_impl()->extension()->set_working_set_memory(size); } sg_size_t sg_vm_get_working_set_memory(const_sg_vm_t vm) { - return vm->get_impl()->extension()->get_working_set_memory(); + return vm->get_vm_impl()->extension()->get_working_set_memory(); } void sg_vm_set_migration_speed(const_sg_vm_t vm, double speed) { - vm->get_impl()->extension()->set_migration_speed(speed); + vm->get_vm_impl()->extension()->set_migration_speed(speed); } double sg_vm_get_migration_speed(const_sg_vm_t vm) { - return vm->get_impl()->extension()->get_migration_speed(); + return vm->get_vm_impl()->extension()->get_migration_speed(); } double sg_vm_get_max_downtime(const_sg_vm_t vm) { - return vm->get_impl()->extension()->get_max_downtime(); + return vm->get_vm_impl()->extension()->get_max_downtime(); }