X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9e9882ce69af88130c9047bf152c92e19acc805d..0c586d7f087b772253980cafd92796edcbd58c50:/include/simgrid/s4u/VirtualMachine.hpp diff --git a/include/simgrid/s4u/VirtualMachine.hpp b/include/simgrid/s4u/VirtualMachine.hpp index 94af590ce8..41be4d1974 100644 --- a/include/simgrid/s4u/VirtualMachine.hpp +++ b/include/simgrid/s4u/VirtualMachine.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2015-2017. 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. */ @@ -6,64 +6,100 @@ #ifndef SIMGRID_S4U_VM_HPP #define SIMGRID_S4U_VM_HPP -#include "simgrid/datatypes.h" -#include "simgrid/s4u/Host.hpp" -#include "simgrid/s4u/forward.hpp" - -enum e_surf_vm_state_t { - SURF_VM_STATE_CREATED, /**< created, but not yet started */ - SURF_VM_STATE_RUNNING, - SURF_VM_STATE_SUSPENDED, /**< Suspend/resume does not involve disk I/O, so we assume there is no transition states. */ - SURF_VM_STATE_DESTROYED -}; +#include +#include +#include namespace simgrid { -namespace vm { -class VirtualMachineImpl; -}; 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 * - * A VM is a virtual machine that contains actors. The total computing power that the contained - * processes can get is constrained to the virtual machine size. + * A VM represents a virtual machine (or a container) that hosts actors. + * The total computing power that the contained actors can get is constrained to the virtual machine size. * */ -XBT_PUBLIC_CLASS VirtualMachine : public s4u::Host -{ +class XBT_PUBLIC VirtualMachine : public s4u::Host { + kernel::resource::VirtualMachineImpl* const pimpl_vm_; public: - explicit VirtualMachine(const char* name, s4u::Host* hostPm, int coreAmount); - explicit VirtualMachine(const char* name, s4u::Host* hostPm, int coreAmount, size_t ramsize); + 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); +#ifndef DOXYGEN // No copy/move VirtualMachine(VirtualMachine const&) = delete; VirtualMachine& operator=(VirtualMachine const&) = delete; +#endif -private: - virtual ~VirtualMachine(); -public: + // enum class State { ... } + XBT_DECLARE_ENUM_CLASS(State, + CREATED, /**< created, but not yet started */ + RUNNING, + SUSPENDED, /**< Suspend/resume does not involve disk I/O, so we assume there is no transition states. */ + DESTROYED + ); +#ifndef DOXYGEN + using state XBT_ATTRIB_DEPRECATED_v332("Please use VirtualMachine::State") = State; +#endif + + kernel::resource::VirtualMachineImpl* get_vm_impl() const { return pimpl_vm_; } void start(); void suspend(); void resume(); + void shutdown(); + void destroy() override; - bool isMigrating(); - - void getParameters(vm_params_t params); - void setParameters(vm_params_t params); - simgrid::s4u::Host* getPm(); - size_t getRamsize(); - void setRamsize(size_t ramsize); - void setBound(double bound); + Host* get_pm() const; + VirtualMachine* set_pm(Host* pm); + size_t get_ramsize() const; + VirtualMachine* set_ramsize(size_t ramsize); + VirtualMachine* set_bound(double bound); - e_surf_vm_state_t getState(); + State get_state() const; + 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); + } +#ifndef DOXYGEN + /* FIXME the signals should be private */ + static xbt::signal on_migration_start; + static xbt::signal on_migration_end; + static xbt::signal on_destruction; +#endif - /* FIXME: protect me */ - simgrid::vm::VirtualMachineImpl* pimpl_vm_ = nullptr; +private: + 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; }; -} -} // namespace simgrid::s4u +} // namespace s4u +} // namespace simgrid -#endif /* SIMGRID_S4U_HOST_HPP */ +#endif