X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/237fd22b56db7d1c67360c37559ce3aab16a002d..d4e5297feb8df40f3ccb3782f7cb326a69d58cad:/include/simgrid/s4u/VirtualMachine.hpp diff --git a/include/simgrid/s4u/VirtualMachine.hpp b/include/simgrid/s4u/VirtualMachine.hpp index 76e83805ae..8a7a33cd6d 100644 --- a/include/simgrid/s4u/VirtualMachine.hpp +++ b/include/simgrid/s4u/VirtualMachine.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2015-2021. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2015-2022. 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. */ @@ -13,6 +13,16 @@ namespace simgrid { namespace s4u { +/** @brief Host extension for the VMs */ +class VmHostExt { +public: + static xbt::Extension EXTENSION_ID; + + sg_size_t ramsize = 0; /* available ramsize (0= not taken into account) */ + bool overcommit = true; /* Whether the host allows overcommiting more VM than the avail ramsize allows */ + static void ensureVmExtInstalled(); +}; + /** @ingroup s4u_api * * @tableofcontents @@ -22,12 +32,21 @@ namespace s4u { * */ class XBT_PUBLIC VirtualMachine : public s4u::Host { - vm::VirtualMachineImpl* const pimpl_vm_; - ~VirtualMachine() override; + kernel::resource::VirtualMachineImpl* const pimpl_vm_; + + /* Signals about the life cycle of the VM */ + static xbt::signal on_creation; + static xbt::signal on_start; + static xbt::signal on_started; + static xbt::signal on_shutdown; + static xbt::signal on_suspend; + static xbt::signal on_resume; + static xbt::signal on_migration_start; + static xbt::signal on_migration_end; + static xbt::signal on_destruction; public: - explicit VirtualMachine(const std::string& name, Host* physical_host, int core_amount); - explicit VirtualMachine(const std::string& name, Host* physical_host, int core_amount, size_t ramsize); + explicit VirtualMachine(const std::string& name, Host* physical_host, int core_amount, size_t ramsize = 1024); #ifndef DOXYGEN // No copy/move @@ -46,7 +65,7 @@ public: using state XBT_ATTRIB_DEPRECATED_v332("Please use VirtualMachine::State") = State; #endif - vm::VirtualMachineImpl* get_vm_impl() const { return pimpl_vm_; } + kernel::resource::VirtualMachineImpl* get_vm_impl() const { return pimpl_vm_; } void start(); void suspend(); void resume(); @@ -58,15 +77,27 @@ public: size_t get_ramsize() const; VirtualMachine* set_ramsize(size_t ramsize); VirtualMachine* set_bound(double bound); + void start_migration() const; + void end_migration() const; State get_state() const; - static xbt::signal on_start; - static xbt::signal on_started; - static xbt::signal on_shutdown; - static xbt::signal on_suspend; - static xbt::signal on_resume; - static xbt::signal on_migration_start; - static xbt::signal on_migration_end; + + /* Callbacks on signals */ + static void on_creation_cb(const std::function& cb) { on_creation.connect(cb); } + static void on_start_cb(const std::function& cb) { on_start.connect(cb); } + static void on_started_cb(const std::function& cb) { on_started.connect(cb); } + static void on_shutdown_cb(const std::function& cb) { on_shutdown.connect(cb); } + static void on_suspend_cb(const std::function& cb) { on_suspend.connect(cb); } + static void on_resume_cb(const std::function& cb) { on_resume.connect(cb); } + static void on_destruction_cb(const std::function& cb) { on_destruction.connect(cb); } + static void on_migration_start_cb(const std::function& cb) + { + on_migration_start.connect(cb); + } + static void on_migration_end_cb(const std::function& cb) + { + on_migration_end.connect(cb); + } }; } // namespace s4u } // namespace simgrid