X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0afad4b7e2215154531cd6b2933af898ec6b781d..c1581952362f8720ca84e7f5fb5500fdeb3878b9:/src/surf/plugins/dirty_page_tracking.cpp diff --git a/src/surf/plugins/dirty_page_tracking.cpp b/src/surf/plugins/dirty_page_tracking.cpp index e75cb111de..e5232cc8bd 100644 --- a/src/surf/plugins/dirty_page_tracking.cpp +++ b/src/surf/plugins/dirty_page_tracking.cpp @@ -79,10 +79,10 @@ static void onExecCreation(simgrid::kernel::activity::ExecImplPtr exec) if (vm == nullptr) return; - if (vm->pimpl_vm_->extension()->isTracking()) { - vm->pimpl_vm_->extension()->track(exec, exec->remains()); + if (vm->getImpl()->extension()->isTracking()) { + vm->getImpl()->extension()->track(exec, exec->remains()); } else { - vm->pimpl_vm_->extension()->track(exec, 0.0); + vm->getImpl()->extension()->track(exec, 0.0); } } @@ -94,17 +94,17 @@ static void onExecCompletion(simgrid::kernel::activity::ExecImplPtr exec) /* 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->pimpl_vm_->extension()->isTracking()) { + if (vm->getImpl()->extension()->isTracking()) { double delta = - vm->pimpl_vm_->extension()->getStoredRemains(exec) - exec->remains(); - vm->pimpl_vm_->extension()->updateDirtyPageCount(delta); + vm->getImpl()->extension()->getStoredRemains(exec) - exec->remains(); + vm->getImpl()->extension()->updateDirtyPageCount(delta); } - vm->pimpl_vm_->extension()->untrack(exec); + vm->getImpl()->extension()->untrack(exec); } SG_BEGIN_DECL() -void sg_vm_live_migration_plugin_init() +void sg_vm_dirty_page_tracking_init() { if (not simgrid::vm::VmDirtyPageTrackingExt::EXTENSION_ID.valid()) { simgrid::vm::VmDirtyPageTrackingExt::EXTENSION_ID = @@ -115,59 +115,54 @@ void sg_vm_live_migration_plugin_init() } } -int sg_vm_is_migratable(sg_vm_t vm) -{ - return simgrid::vm::VmDirtyPageTrackingExt::EXTENSION_ID.valid(); -} - void sg_vm_start_dirty_page_tracking(sg_vm_t vm) { - vm->pimpl_vm_->extension()->startTracking(); + vm->getImpl()->extension()->startTracking(); } void sg_vm_stop_dirty_page_tracking(sg_vm_t vm) { - vm->pimpl_vm_->extension()->stopTracking(); + vm->getImpl()->extension()->stopTracking(); } double sg_vm_lookup_computed_flops(sg_vm_t vm) { - return vm->pimpl_vm_->extension()->computedFlopsLookup(); + return vm->getImpl()->extension()->computedFlopsLookup(); } void sg_vm_set_dirty_page_intensity(sg_vm_t vm, double intensity) { - vm->pimpl_vm_->extension()->setIntensity(intensity); + vm->getImpl()->extension()->setIntensity(intensity); } double sg_vm_get_dirty_page_intensity(sg_vm_t vm) { - return vm->pimpl_vm_->extension()->getIntensity(); + return vm->getImpl()->extension()->getIntensity(); } void sg_vm_set_working_set_memory(sg_vm_t vm, sg_size_t size) { - vm->pimpl_vm_->extension()->setWorkingSetMemory(size); + vm->getImpl()->extension()->setWorkingSetMemory(size); } sg_size_t sg_vm_get_working_set_memory(sg_vm_t vm) { - return vm->pimpl_vm_->extension()->getWorkingSetMemory(); + return vm->getImpl()->extension()->getWorkingSetMemory(); } void sg_vm_set_migration_speed(sg_vm_t vm, double speed) { - vm->pimpl_vm_->extension()->setMigrationSpeed(speed); + vm->getImpl()->extension()->setMigrationSpeed(speed); } double sg_vm_get_migration_speed(sg_vm_t vm) { - return vm->pimpl_vm_->extension()->getMigrationSpeed(); + return vm->getImpl()->extension()->getMigrationSpeed(); } double sg_vm_get_max_downtime(sg_vm_t vm) { - return vm->pimpl_vm_->extension()->getMaxDowntime(); + return vm->getImpl()->extension()->getMaxDowntime(); } SG_END_DECL()