/************
* Resource *
************/
-HostImpl::HostImpl(const std::string& name, s4u::Host* piface) : piface_(this), name_(name)
-{
- xbt_assert(s4u::Host::by_name_or_null(name_) == nullptr, "Refusing to create a second host named '%s'.", get_cname());
- s4u::Engine::get_instance()->host_register(name_, piface);
-}
-
HostImpl::HostImpl(const std::string& name) : piface_(this), name_(name)
{
xbt_assert(s4u::Host::by_name_or_null(name_) == nullptr, "Refusing to create a second host named '%s'.", get_cname());
- s4u::Engine::get_instance()->host_register(name_, &piface_);
}
HostImpl::~HostImpl()
for (auto const& d : disks_)
d.second->destroy();
+
+ for (auto const& vm : vms_)
+ vm.second->vm_destroy();
}
/** @brief Fire the required callbacks and destroy the object
void HostImpl::destroy()
{
s4u::Host::on_destruction(*this->get_iface());
- s4u::Engine::get_instance()->host_unregister(std::string(name_));
delete this;
}
/** Kill all actors hosted here */
void HostImpl::turn_off(const actor::ActorImpl* issuer)
{
+ /* turn_off VMs running on host */
+ for (const auto& kv : vms_) {
+ auto* actor = kernel::actor::ActorImpl::self();
+ kv.second->shutdown(actor);
+ kv.second->turn_off(actor);
+ }
for (auto& actor : actor_list_) {
XBT_DEBUG("Killing Actor %s@%s on behalf of %s which turned off that host.", actor.get_cname(),
actor.get_host()->get_cname(), issuer->get_cname());
return disks;
}
+s4u::VirtualMachine* HostImpl::create_vm(const std::string& name, int core_amount, size_t ramsize)
+{
+ auto* vm = new s4u::VirtualMachine(name, get_iface(), core_amount, ramsize);
+ vms_[name] = vm->get_vm_impl();
+
+ // Create a VCPU for this VM
+ std::vector<double> speeds;
+ for (unsigned long i = 0; i < get_iface()->get_pstate_count(); i++)
+ speeds.push_back(get_iface()->get_pstate_speed(i));
+
+ auto* cpu = englobing_zone_->get_cpu_vm_model()->create_cpu(vm, speeds)->set_core_count(core_amount);
+
+ if (get_iface()->get_pstate() != 0)
+ cpu->set_pstate(get_iface()->get_pstate());
+
+ cpu->seal();
+
+ /* Currently, a VM uses the network resource of its physical host */
+ vm->set_netpoint(get_iface()->get_netpoint());
+
+ vm->seal();
+
+ return vm;
+}
+
+void HostImpl::move_vm(VirtualMachineImpl* vm, HostImpl* destination)
+{
+ xbt_assert(vm && destination);
+
+ vms_.erase(vm->get_name());
+ destination->vms_[vm->get_name()] = vm;
+}
+
+void HostImpl::destroy_vm(const std::string& name)
+{
+ auto* vm = vms_[name];
+ vms_.erase(name);
+ vm->vm_destroy();
+}
+
+VirtualMachineImpl* HostImpl::get_vm_by_name_or_null(const std::string& name) const
+{
+ auto vm_it = vms_.find(name);
+ if (vm_it != vms_.end())
+ return vm_it->second;
+ return nullptr;
+}
+
+std::vector<s4u::VirtualMachine*> HostImpl::get_vms() const
+{
+ std::vector<s4u::VirtualMachine*> vms;
+ for (const auto& kv : vms_) {
+ vms.push_back(kv.second->get_iface());
+ }
+ return vms;
+}
+
s4u::Disk* HostImpl::create_disk(const std::string& name, double read_bandwidth, double write_bandwidth)
{
auto disk = piface_.get_netpoint()->get_englobing_zone()->get_disk_model()->create_disk(name, read_bandwidth,
/* seal its disks */
for (auto const& disk : disks_)
disk.second->seal();
+
+ /* seal its VMs */
+ for (auto const& vm : vms_)
+ vm.second->seal();
}
} // namespace resource
} // namespace kernel